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
- JpegBitmapEncoder.cs
- ProfileParameter.cs
- BrowserCapabilitiesFactory.cs
- DisableDpiAwarenessAttribute.cs
- FilePrompt.cs
- Line.cs
- ObjectDisposedException.cs
- RadioButton.cs
- ConcurrentQueue.cs
- PointAnimationClockResource.cs
- HandledEventArgs.cs
- TrimSurroundingWhitespaceAttribute.cs
- FormsAuthenticationConfiguration.cs
- ToolStripSeparator.cs
- CapabilitiesSection.cs
- ObjectStateEntry.cs
- SByte.cs
- CngKeyBlobFormat.cs
- XmlSchemaGroup.cs
- EntityDataSourceEntitySetNameItem.cs
- PrintingPermission.cs
- DriveNotFoundException.cs
- GB18030Encoding.cs
- DesignerObject.cs
- TextPointer.cs
- BitmapPalettes.cs
- DataGridViewColumnEventArgs.cs
- QueryOutputWriter.cs
- Wildcard.cs
- QilFunction.cs
- XmlDocumentSerializer.cs
- ListSurrogate.cs
- SettingsPropertyCollection.cs
- WebPartMovingEventArgs.cs
- CodeCommentStatementCollection.cs
- SpinLock.cs
- NetworkInterface.cs
- LayoutEditorPart.cs
- MenuItem.cs
- MsmqIntegrationOutputChannel.cs
- AutomationIdentifierGuids.cs
- PropertyEmitter.cs
- GlyphTypeface.cs
- PlatformCulture.cs
- UniformGrid.cs
- NativeMethods.cs
- FixedSchema.cs
- DefinitionUpdate.cs
- BamlReader.cs
- WebPartAuthorizationEventArgs.cs
- TabItemAutomationPeer.cs
- BindingsCollection.cs
- TimelineClockCollection.cs
- OleDbConnectionFactory.cs
- TaskExceptionHolder.cs
- MenuCommands.cs
- SafeWaitHandle.cs
- WSSecurityXXX2005.cs
- OpacityConverter.cs
- WebPartConnectionsCloseVerb.cs
- ScriptMethodAttribute.cs
- WindowsGraphics.cs
- PointConverter.cs
- IIS7WorkerRequest.cs
- WasHostedComPlusFactory.cs
- TabletDevice.cs
- PolygonHotSpot.cs
- GPRECTF.cs
- TextEndOfSegment.cs
- DiagnosticsConfigurationHandler.cs
- BooleanToVisibilityConverter.cs
- Collection.cs
- WinInetCache.cs
- CommandCollectionEditor.cs
- ToolStripItemImageRenderEventArgs.cs
- DSASignatureDeformatter.cs
- UserControlParser.cs
- FileDialog.cs
- DictionaryGlobals.cs
- MenuItemCollection.cs
- Compiler.cs
- ListViewUpdateEventArgs.cs
- TextSchema.cs
- DataGridViewColumnDividerDoubleClickEventArgs.cs
- UnmanagedMarshal.cs
- ControlOperationInvoker.cs
- Attributes.cs
- SqlBuilder.cs
- StorageAssociationTypeMapping.cs
- ClientTarget.cs
- ChannelListenerBase.cs
- Decimal.cs
- LayoutSettings.cs
- SchemaInfo.cs
- WindowInteractionStateTracker.cs
- DisplayInformation.cs
- DrawingDrawingContext.cs
- BasicCommandTreeVisitor.cs
- ProfilePropertySettingsCollection.cs
- HandlerBase.cs