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
- EventLogger.cs
- ZoomPercentageConverter.cs
- DataGridViewAdvancedBorderStyle.cs
- GenericAuthenticationEventArgs.cs
- XPathDocument.cs
- DbConnectionOptions.cs
- ColorAnimationUsingKeyFrames.cs
- DataGridCell.cs
- SafeNativeMethods.cs
- StringComparer.cs
- StrongTypingException.cs
- DataGridViewColumnStateChangedEventArgs.cs
- OpCodes.cs
- ListItemParagraph.cs
- SqlServer2KCompatibilityAnnotation.cs
- IpcChannel.cs
- DataColumnPropertyDescriptor.cs
- templategroup.cs
- TextLineBreak.cs
- XPathExpr.cs
- XmlDomTextWriter.cs
- DigestComparer.cs
- ServiceDebugElement.cs
- Types.cs
- _CookieModule.cs
- TextProperties.cs
- PropertyFilter.cs
- ErrorWrapper.cs
- ZoneButton.cs
- FileStream.cs
- SafeCryptHandles.cs
- AppDomainFactory.cs
- NativeMethods.cs
- InitializationEventAttribute.cs
- CodeCommentStatement.cs
- FixUpCollection.cs
- XmlNamespaceDeclarationsAttribute.cs
- StrokeSerializer.cs
- SecurityTokenParameters.cs
- ToolStripSplitStackLayout.cs
- XmlQuerySequence.cs
- MimeFormatExtensions.cs
- CounterSample.cs
- RemoteArgument.cs
- VariableDesigner.xaml.cs
- WasEndpointConfigContainer.cs
- CodeMethodReturnStatement.cs
- StateRuntime.cs
- TabControl.cs
- GeneralTransformCollection.cs
- WeakRefEnumerator.cs
- DataColumnCollection.cs
- DataGridViewRowsAddedEventArgs.cs
- DiagnosticTraceRecords.cs
- SmiEventSink_DeferedProcessing.cs
- VerificationAttribute.cs
- CharacterMetricsDictionary.cs
- ActiveXContainer.cs
- TemplateParser.cs
- CodeMemberProperty.cs
- CompensationDesigner.cs
- CompiledRegexRunner.cs
- PerformanceCounterPermissionAttribute.cs
- MethodInfo.cs
- PointCollectionConverter.cs
- TimeZone.cs
- SystemIPv6InterfaceProperties.cs
- TaiwanLunisolarCalendar.cs
- XmlDocumentSurrogate.cs
- ExtentCqlBlock.cs
- WebPartConnectionsDisconnectVerb.cs
- XmlILStorageConverter.cs
- ListViewCancelEventArgs.cs
- CellTreeNodeVisitors.cs
- TreeNodeSelectionProcessor.cs
- StyleBamlRecordReader.cs
- OdbcInfoMessageEvent.cs
- TraceSection.cs
- HandledEventArgs.cs
- FixedMaxHeap.cs
- ProgressPage.cs
- TypeInitializationException.cs
- UnionExpr.cs
- SelectionItemProviderWrapper.cs
- PropertyItem.cs
- Util.cs
- Icon.cs
- OpenFileDialog.cs
- BaseCAMarshaler.cs
- DeleteIndexBinder.cs
- SQLSingle.cs
- AsyncCompletedEventArgs.cs
- TextTreeTextNode.cs
- BoundConstants.cs
- TypeExtension.cs
- MatrixKeyFrameCollection.cs
- WebScriptMetadataMessageEncoderFactory.cs
- XsltQilFactory.cs
- InheritanceContextHelper.cs
- TypeConstant.cs