Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / MessageEncoder.cs / 1 / MessageEncoder.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.IO; using System.Net.Mime; using System.Runtime.Serialization; using System.ServiceModel.Diagnostics; public abstract class MessageEncoder { public abstract string ContentType { get; } public abstract string MediaType { get; } public abstract MessageVersion MessageVersion { get; } public virtual T GetProperty() where T : class { if (typeof(T) == typeof(FaultConverter)) { return (T)(object)FaultConverter.GetDefaultFaultConverter(this.MessageVersion); } return null; } public Message ReadMessage(Stream stream, int maxSizeOfHeaders) { return ReadMessage(stream, maxSizeOfHeaders, null); } public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType); public Message ReadMessage(ArraySegment buffer, BufferManager bufferManager) { return ReadMessage(buffer, bufferManager, null); } public abstract Message ReadMessage(ArraySegment buffer, BufferManager bufferManager, string contentType); // used for buffered streaming internal ArraySegment BufferMessageStream(Stream stream, BufferManager bufferManager, int maxBufferSize) { byte[] buffer = bufferManager.TakeBuffer(ConnectionOrientedTransportDefaults.ConnectionBufferSize); int offset = 0; int currentBufferSize = Math.Min(buffer.Length, maxBufferSize); while (offset < currentBufferSize) { int count = stream.Read(buffer, offset, currentBufferSize - offset); if (count == 0) { stream.Close(); break; } offset += count; if (offset == currentBufferSize) { if (currentBufferSize >= maxBufferSize) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(MaxMessageSizeStream.CreateMaxReceivedMessageSizeExceededException(maxBufferSize)); } currentBufferSize = Math.Min(currentBufferSize * 2, maxBufferSize); byte[] temp = bufferManager.TakeBuffer(currentBufferSize); Buffer.BlockCopy(buffer, 0, temp, 0, offset); bufferManager.ReturnBuffer(buffer); buffer = temp; } } return new ArraySegment (buffer, 0, offset); } // used for buffered streaming internal virtual Message ReadMessage(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType) { return ReadMessage(BufferMessageStream(stream, bufferManager, maxBufferSize), bufferManager, contentType); } public override string ToString() { return ContentType; } public abstract void WriteMessage(Message message, Stream stream); public ArraySegment WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager) { return WriteMessage(message, maxMessageSize, bufferManager, 0); } public abstract ArraySegment WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset); public virtual bool IsContentTypeSupported(string contentType) { if (contentType == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("contentType")); return IsContentTypeSupported(contentType, this.ContentType, this.MediaType); } internal bool IsContentTypeSupported(string contentType, string supportedContentType, string supportedMediaType) { if (supportedContentType == contentType) return true; if (contentType.Length > supportedContentType.Length && contentType.StartsWith(supportedContentType, StringComparison.Ordinal) && contentType[supportedContentType.Length] == ';') return true; // now check case-insensitively if (contentType.StartsWith(supportedContentType, StringComparison.OrdinalIgnoreCase)) { if (contentType.Length == supportedContentType.Length) { return true; } else if (contentType.Length > supportedContentType.Length) { char ch = contentType[supportedContentType.Length]; // Linear Whitespace is allowed to appear between the end of one property and the semicolon. // LWS = [CRLF]? (SP | HT)+ if (ch == ';') { return true; } // Consume the [CRLF]? int i = supportedContentType.Length; if (ch == '\r' && contentType.Length > supportedContentType.Length + 1 && contentType[i + 1] == '\n') { i += 2; ch = contentType[i]; } // Look for a ';' or nothing after (SP | HT)+ if (ch == ' ' || ch == '\t') { i++; while (i < contentType.Length) { ch = contentType[i]; if (ch != ' ' && ch != '\t') break; ++i; } } if (ch == ';' || i == contentType.Length) return true; } } // sometimes we get a contentType that has parameters, but our encoders // merely expose the base content-type, so we will check a stripped version try { ContentType parsedContentType = new ContentType(contentType); if (supportedMediaType.Length > 0 && !supportedMediaType.Equals(parsedContentType.MediaType, StringComparison.OrdinalIgnoreCase)) return false; if (!IsCharSetSupported(parsedContentType.CharSet)) return false; } catch (FormatException) { // bad content type, so we definitely don't support it! return false; } return true; } internal virtual bool IsCharSetSupported(string charset) { return false; } internal void ThrowIfMismatchedMessageVersion(Message message) { if (message.Version != MessageVersion) { throw TraceUtility.ThrowHelperError( new ProtocolException(SR.GetString(SR.EncoderMessageVersionMismatch, message.Version, MessageVersion)), message); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ComboBox.cs
- DES.cs
- RegexParser.cs
- Nodes.cs
- SrgsElementFactory.cs
- UpnEndpointIdentity.cs
- QueryStringParameter.cs
- LinqDataSourceSelectEventArgs.cs
- MembershipPasswordException.cs
- FormatStringEditor.cs
- MemoryFailPoint.cs
- ButtonPopupAdapter.cs
- FieldCollectionEditor.cs
- HttpCachePolicyBase.cs
- XmlJsonReader.cs
- SecurityDocument.cs
- HexParser.cs
- DataServiceKeyAttribute.cs
- ObjectDataProvider.cs
- Privilege.cs
- SettingsSection.cs
- FormsAuthenticationUserCollection.cs
- Control.cs
- SafeNativeMethodsMilCoreApi.cs
- RegexCharClass.cs
- NumericUpDownAcceleration.cs
- HtmlInputButton.cs
- ChildrenQuery.cs
- CompositeScriptReferenceEventArgs.cs
- EditorResources.cs
- DocumentPageTextView.cs
- DesignerForm.cs
- LoadWorkflowCommand.cs
- ProgressBarRenderer.cs
- AuthenticateEventArgs.cs
- WindowsListViewGroupSubsetLink.cs
- SmtpClient.cs
- FigureParaClient.cs
- CodeTypeMember.cs
- OleDbCommand.cs
- SmiXetterAccessMap.cs
- ColumnPropertiesGroup.cs
- SQLInt32.cs
- NumberFormatInfo.cs
- StorageAssociationTypeMapping.cs
- COM2FontConverter.cs
- LinearQuaternionKeyFrame.cs
- ProfileSettingsCollection.cs
- UnsafeNativeMethods.cs
- _NetworkingPerfCounters.cs
- ConnectionsZone.cs
- DesignerRegionCollection.cs
- DeflateInput.cs
- BitmapEffectGroup.cs
- _SslSessionsCache.cs
- BaseTemplateParser.cs
- TextDecoration.cs
- DataGridDesigner.cs
- ValidationEventArgs.cs
- GridViewRow.cs
- dataprotectionpermission.cs
- TreeWalkHelper.cs
- AtomPub10CategoriesDocumentFormatter.cs
- NameValueConfigurationCollection.cs
- ExtentCqlBlock.cs
- HtmlSelect.cs
- EncryptedPackageFilter.cs
- SortQuery.cs
- ScrollItemProviderWrapper.cs
- VirtualPath.cs
- CodeIdentifier.cs
- SplitterPanel.cs
- EdmItemCollection.cs
- DataControlFieldsEditor.cs
- ImpersonateTokenRef.cs
- DataGridViewAutoSizeColumnsModeEventArgs.cs
- XmlRootAttribute.cs
- ReferencedType.cs
- GridViewColumnHeaderAutomationPeer.cs
- BitmapImage.cs
- _UncName.cs
- HeaderUtility.cs
- ToolboxComponentsCreatingEventArgs.cs
- ReflectionTypeLoadException.cs
- OneOfConst.cs
- SelectionRangeConverter.cs
- TemplateAction.cs
- IItemContainerGenerator.cs
- SafeRightsManagementHandle.cs
- EventManager.cs
- XmlElementElementCollection.cs
- PageEventArgs.cs
- DesignerDataView.cs
- SurrogateEncoder.cs
- SwitchCase.cs
- ServiceSettingsResponseInfo.cs
- MultiPageTextView.cs
- InvalidCardException.cs
- PerformanceCounterPermissionEntryCollection.cs
- ProfilePropertyMetadata.cs