Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / PeerInputChannel.cs / 1 / PeerInputChannel.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.Diagnostics; using System.ServiceModel; using System.ServiceModel.Diagnostics; using System.Threading; class PeerInputChannel : InputChannel { EndpointAddress to; Uri via; PeerNode peerNode; bool released = false; public PeerInputChannel(PeerNodeImplementation peerNode, PeerNodeImplementation.Registration registration, ChannelManagerBase channelManager, EndpointAddress localAddress, Uri via) : base(channelManager, localAddress) { PeerNodeImplementation.ValidateVia(via); if(registration != null) { peerNode = PeerNodeImplementation.Get(via, registration); } this.peerNode = new PeerNode(peerNode); this.to = localAddress; this.via = via; } public override T GetProperty() { if(typeof(T) == typeof(PeerNode)) { return (T) (object) this.peerNode; } else if(typeof(T) == typeof(PeerNodeImplementation)) { return (T) (object) this.peerNode.InnerNode; } else if(typeof(T) == typeof(IOnlineStatus)) { return (T) (object) this.peerNode; } else if (typeof(T) == typeof(FaultConverter)) { return (T)(object)FaultConverter.GetDefaultFaultConverter(MessageVersion.Soap12WSAddressing10); } return base.GetProperty (); } protected override void OnAbort() { base.OnAbort(); if (this.State < CommunicationState.Closed) { try { this.peerNode.InnerNode.Abort(); } catch(Exception e) { if(DiagnosticUtility.IsFatal(e)) throw; DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } } protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state) { // first close the node, then the base return new ChainedAsyncResult(timeout, callback, state, OnBeginCloseNode, OnEndCloseNode, base.OnBeginClose, base.OnEndClose); } // fisrt step in the chained async close IAsyncResult OnBeginCloseNode(TimeSpan timeout, AsyncCallback callback, object state) { return this.peerNode.InnerNode.BeginClose(timeout, callback, state); } protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state) { // open the base, then the node return new ChainedAsyncResult(timeout, callback, state, base.OnBeginOpen, base.OnEndOpen, OnBeginOpenNode, OnEndOpenNode); } // second step in the chained async open IAsyncResult OnBeginOpenNode(TimeSpan timeout, AsyncCallback callback, object state) { IAsyncResult result = this.peerNode.InnerNode.BeginOpen(timeout, callback, state, true); return result; } protected override void OnClose(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); this.peerNode.InnerNode.Close(timeoutHelper.RemainingTime()); base.OnClose(timeoutHelper.RemainingTime()); } protected override void OnClosing() { base.OnClosing(); ReleaseNode(); } void ReleaseNode() { if (!this.released) { bool release = false; lock(ThisLock) { if (!this.released) { release = this.released = true; } } if (release) { this.peerNode.InnerNode.Release(); } } } protected override void OnEndClose(IAsyncResult result) { ChainedAsyncResult.End(result); } void OnEndCloseNode(IAsyncResult result) { PeerNodeImplementation.EndClose(result); } protected override void OnEndOpen(IAsyncResult result) { ChainedAsyncResult.End(result); } void OnEndOpenNode(IAsyncResult result) { PeerNodeImplementation.EndOpen(result); } protected override void OnEnqueueItem(Message message) { // set the message's via to the uri on which it was received message.Properties.Via = this.via; if (DiagnosticUtility.ShouldTraceInformation) { TraceUtility.TraceEvent(TraceEventType.Information, TraceCode.PeerChannelMessageReceived, this, message); } } protected override void OnOpen(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); base.OnOpen(timeoutHelper.RemainingTime()); this.peerNode.OnOpen(); this.peerNode.InnerNode.Open(timeoutHelper.RemainingTime(), true); } protected override void OnFaulted() { base.OnFaulted(); ReleaseNode(); } } } // 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
- CodeDirectiveCollection.cs
- ToolStripSettings.cs
- DesignerAdRotatorAdapter.cs
- BufferedWebEventProvider.cs
- EntityClientCacheKey.cs
- RelatedCurrencyManager.cs
- SchemaManager.cs
- SystemEvents.cs
- IfAction.cs
- Button.cs
- TileModeValidation.cs
- TextParaClient.cs
- XmlNullResolver.cs
- StrokeNodeOperations.cs
- WebPartTransformer.cs
- _HTTPDateParse.cs
- StructuredTypeInfo.cs
- BuilderInfo.cs
- TabPage.cs
- OAVariantLib.cs
- diagnosticsswitches.cs
- ADRole.cs
- AstTree.cs
- XslException.cs
- BlobPersonalizationState.cs
- EventRecord.cs
- InplaceBitmapMetadataWriter.cs
- LocalizationComments.cs
- GACMembershipCondition.cs
- DefaultAssemblyResolver.cs
- BridgeDataRecord.cs
- AttributeData.cs
- EmptyElement.cs
- RenderingBiasValidation.cs
- ProxyElement.cs
- DataGridItem.cs
- KoreanCalendar.cs
- TextChange.cs
- XmlUrlResolver.cs
- RuntimeArgumentHandle.cs
- ADMembershipUser.cs
- TraceHandler.cs
- ArraySegment.cs
- arabicshape.cs
- FixedDocumentSequencePaginator.cs
- ApplicationDirectory.cs
- DoubleLinkListEnumerator.cs
- WebServicesInteroperability.cs
- BCryptNative.cs
- PlanCompiler.cs
- MonthChangedEventArgs.cs
- XmlWhitespace.cs
- TraceHandler.cs
- UnmanagedBitmapWrapper.cs
- WSDualHttpBindingCollectionElement.cs
- AppDomainAttributes.cs
- CursorConverter.cs
- UIElementCollection.cs
- TypeNameParser.cs
- HttpHostedTransportConfiguration.cs
- XmlNotation.cs
- VirtualDirectoryMapping.cs
- ObjectMemberMapping.cs
- SqlNodeAnnotations.cs
- WebServiceErrorEvent.cs
- GeneralTransform3DTo2D.cs
- FactoryGenerator.cs
- QuadraticBezierSegment.cs
- EncodingStreamWrapper.cs
- AttributeCollection.cs
- ToolStripPanelRow.cs
- xmlsaver.cs
- CaseStatement.cs
- SmiEventSink.cs
- Site.cs
- _FtpControlStream.cs
- DrawingContextWalker.cs
- XmlConvert.cs
- DocumentPageView.cs
- SaveFileDialog.cs
- ToolStripItemEventArgs.cs
- SafeArrayTypeMismatchException.cs
- InstanceNotReadyException.cs
- ParameterModifier.cs
- AsyncResult.cs
- ReadWriteSpinLock.cs
- TableRowCollection.cs
- TableCell.cs
- TextModifier.cs
- SubclassTypeValidator.cs
- XmlNullResolver.cs
- ComplexPropertyEntry.cs
- DataBindEngine.cs
- DiscardableAttribute.cs
- IntersectQueryOperator.cs
- Win32Native.cs
- OutputCacheSection.cs
- GeometryModel3D.cs
- LogManagementAsyncResult.cs
- X509SecurityToken.cs