Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx35 / System.ServiceModel.Web / System / ServiceModel / Channels / HttpStreamMessage.cs / 1305376 / HttpStreamMessage.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- #pragma warning disable 1634 // Stops compiler from warning about unknown warnings (for Presharp) namespace System.ServiceModel.Channels { using System; using System.IO; using System.Runtime; using System.ServiceModel; using System.Xml; using DiagnosticUtility = System.ServiceModel.DiagnosticUtility; class HttpStreamMessage : Message { internal const string StreamElementName = "Binary"; BodyWriter bodyWriter; MessageHeaders headers; MessageProperties properties; public HttpStreamMessage(Stream stream) { if (stream == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("stream"); } this.bodyWriter = new HttpStreamBodyWriter(stream); this.headers = new MessageHeaders(MessageVersion.None, 1); this.properties = new MessageProperties(); } public HttpStreamMessage(BodyWriter writer) { if (writer == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("writer"); } this.bodyWriter = writer; this.headers = new MessageHeaders(MessageVersion.None, 1); this.properties = new MessageProperties(); } public HttpStreamMessage(MessageHeaders headers, MessageProperties properties, BodyWriter bodyWriter) { if (bodyWriter == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("bodyWriter"); } this.headers = new MessageHeaders(headers); this.properties = new MessageProperties(properties); this.bodyWriter = bodyWriter; } public override MessageHeaders Headers { get { if (IsDisposed) { #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); } return headers; } } public override bool IsEmpty { get { return false; } } public override bool IsFault { get { return false; } } public override MessageProperties Properties { get { if (IsDisposed) { #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); } return properties; } } public override MessageVersion Version { get { if (IsDisposed) { #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); } return MessageVersion.None; } } protected override void OnBodyToString(XmlDictionaryWriter writer) { if (this.bodyWriter.IsBuffered) { bodyWriter.WriteBodyContents(writer); } else { writer.WriteString(SR2.GetString(SR2.MessageBodyIsStream)); } } protected override void OnClose() { Exception ex = null; try { base.OnClose(); } catch (Exception e) { if (Fx.IsFatal(e)) { throw; } ex = e; } try { if (properties != null) { properties.Dispose(); } } catch (Exception e) { if (Fx.IsFatal(e)) { throw; } if (ex == null) { ex = e; } } if (ex != null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex); } this.bodyWriter = null; } protected override MessageBuffer OnCreateBufferedCopy(int maxBufferSize) { BodyWriter bufferedBodyWriter; if (this.bodyWriter.IsBuffered) { bufferedBodyWriter = this.bodyWriter; } else { bufferedBodyWriter = this.bodyWriter.CreateBufferedCopy(maxBufferSize); } return new HttpStreamMessageBuffer(this.Headers, new MessageProperties(this.Properties), bufferedBodyWriter); } protected override void OnWriteBodyContents(XmlDictionaryWriter writer) { this.bodyWriter.WriteBodyContents(writer); } Exception CreateDisposedException() { return new ObjectDisposedException("", SR2.GetString(SR2.MessageClosed)); } class HttpStreamBodyWriter : BodyWriter { Stream stream; Object thisLock; public HttpStreamBodyWriter(Stream stream) : base(false) { if (stream == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("stream"); } this.stream = stream; thisLock = new Object(); } object ThisLock { get { return thisLock; } } protected override BodyWriter OnCreateBufferedCopy(int maxBufferSize) { using (BufferManagerOutputStream bufferedStream = new BufferManagerOutputStream(SR2.MaxReceivedMessageSizeExceeded, maxBufferSize)) { using (HttpStreamXmlDictionaryWriter writer = new HttpStreamXmlDictionaryWriter(bufferedStream)) { OnWriteBodyContents(writer); writer.Flush(); int size; byte[] bytesArray = bufferedStream.ToArray(out size); return new BufferedBytesBodyWriter(bytesArray, size); } } } protected override void OnWriteBodyContents(XmlDictionaryWriter writer) { lock (ThisLock) { writer.WriteStartElement(StreamElementName, string.Empty); writer.WriteValue(new HttpStreamProvider(this.stream)); writer.WriteEndElement(); } } class HttpStreamProvider : IStreamProvider { Stream stream; internal HttpStreamProvider(Stream stream) { this.stream = stream; } public Stream GetStream() { return stream; } public void ReleaseStream(Stream stream) { //Noop } } } class BufferedBytesBodyWriter : BodyWriter { byte[] array; int size; public BufferedBytesBodyWriter(byte[] array, int size) : base(true) { this.array = array; this.size = size; } protected override void OnWriteBodyContents(XmlDictionaryWriter writer) { writer.WriteStartElement(StreamElementName, string.Empty); writer.WriteBase64(this.array, 0, size); writer.WriteEndElement(); } } class HttpStreamMessageBuffer : MessageBuffer { BodyWriter bodyWriter; bool closed; MessageHeaders headers; MessageProperties properties; object thisLock = new object(); public HttpStreamMessageBuffer(MessageHeaders headers, MessageProperties properties, BodyWriter bodyWriter) : base() { this.bodyWriter = bodyWriter; this.headers = headers; this.properties = properties; } public override int BufferSize { get { return 0; } } object ThisLock { get { return thisLock; } } public override void Close() { lock (ThisLock) { if (!closed) { closed = true; bodyWriter = null; headers = null; properties = null; } } } public override Message CreateMessage() { lock (ThisLock) { if (closed) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); } return new HttpStreamMessage(this.headers, this.properties, this.bodyWriter); } } Exception CreateDisposedException() { return new ObjectDisposedException("", SR2.GetString(SR2.MessageBufferIsClosed)); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- RuleInfoComparer.cs
- TreeNodeEventArgs.cs
- DllNotFoundException.cs
- SQLBytes.cs
- ArithmeticException.cs
- COM2ExtendedUITypeEditor.cs
- WebHttpSecurityModeHelper.cs
- NullableDecimalMinMaxAggregationOperator.cs
- Transaction.cs
- WebFormDesignerActionService.cs
- GacUtil.cs
- MasterPageParser.cs
- UnsafeNativeMethods.cs
- CSharpCodeProvider.cs
- PrivilegedConfigurationManager.cs
- SafeThreadHandle.cs
- _AcceptOverlappedAsyncResult.cs
- CodeExporter.cs
- ManagedWndProcTracker.cs
- HttpHandler.cs
- Conditional.cs
- CompiledAction.cs
- x509utils.cs
- LoadMessageLogger.cs
- HierarchicalDataSourceConverter.cs
- ListSortDescription.cs
- CompositeActivityCodeGenerator.cs
- WrappedReader.cs
- ImmutableObjectAttribute.cs
- BasicViewGenerator.cs
- ParentControlDesigner.cs
- NetPipeSection.cs
- SymbolMethod.cs
- ListView.cs
- CodeGroup.cs
- HitTestFilterBehavior.cs
- SystemNetworkInterface.cs
- UpdatePanelControlTrigger.cs
- Label.cs
- ViewGenResults.cs
- SafeFileMappingHandle.cs
- StoragePropertyMapping.cs
- IsolatedStoragePermission.cs
- ClosableStream.cs
- XmlUtf8RawTextWriter.cs
- SpecialFolderEnumConverter.cs
- SapiAttributeParser.cs
- _BaseOverlappedAsyncResult.cs
- InvalidProgramException.cs
- X509Certificate2.cs
- KeyValueSerializer.cs
- CodeTypeParameterCollection.cs
- DoubleAnimationUsingKeyFrames.cs
- SymbolPair.cs
- ModelTypeConverter.cs
- DynamicMethod.cs
- OleDbDataReader.cs
- SizeAnimationBase.cs
- PerformanceCounterLib.cs
- EntityTemplateUserControl.cs
- DependencyObjectProvider.cs
- StorageInfo.cs
- SelfIssuedTokenFactoryCredential.cs
- SecurityContextCookieSerializer.cs
- PackageFilter.cs
- HtmlTableCell.cs
- BinaryMethodMessage.cs
- MenuDesigner.cs
- ValidatingReaderNodeData.cs
- ButtonChrome.cs
- UpdateException.cs
- DBConcurrencyException.cs
- unsafenativemethodsother.cs
- MouseGestureConverter.cs
- SqlSelectClauseBuilder.cs
- DesignRelationCollection.cs
- NetSectionGroup.cs
- PerfCounterSection.cs
- _NtlmClient.cs
- AuthorizationRuleCollection.cs
- MarshalByValueComponent.cs
- DataTableTypeConverter.cs
- TextBoxRenderer.cs
- RoleService.cs
- ItemList.cs
- TimelineCollection.cs
- Vector3DAnimationUsingKeyFrames.cs
- AssociationSet.cs
- BaseValidator.cs
- DataGridViewRowCollection.cs
- SafeTimerHandle.cs
- BridgeDataReader.cs
- SignedXml.cs
- HttpConfigurationContext.cs
- WindowsGrip.cs
- DataBoundControlDesigner.cs
- IsolationInterop.cs
- UpdateRecord.cs
- Column.cs
- DiscreteKeyFrames.cs