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
- DataStreams.cs
- SizeChangedInfo.cs
- PrimaryKeyTypeConverter.cs
- DBSqlParserColumnCollection.cs
- EntityType.cs
- TextProperties.cs
- XPathNavigatorKeyComparer.cs
- RegisteredHiddenField.cs
- DocumentPage.cs
- PackageDigitalSignatureManager.cs
- ResourceIDHelper.cs
- StretchValidation.cs
- TopClause.cs
- NameSpaceExtractor.cs
- RadialGradientBrush.cs
- OracleFactory.cs
- HttpModule.cs
- SecurityPolicySection.cs
- DragDeltaEventArgs.cs
- DataListItemEventArgs.cs
- FixedSOMPageConstructor.cs
- MimeTextImporter.cs
- ObjectListCommand.cs
- XhtmlBasicTextViewAdapter.cs
- NativeMethods.cs
- PropertyInfoSet.cs
- HtmlFormWrapper.cs
- IPEndPoint.cs
- CloudCollection.cs
- CdpEqualityComparer.cs
- DataGridTextColumn.cs
- StringSorter.cs
- ResizeGrip.cs
- CorrelationHandle.cs
- Utils.cs
- XmlHierarchyData.cs
- SmiMetaDataProperty.cs
- SessionEndedEventArgs.cs
- SmiTypedGetterSetter.cs
- CompilationSection.cs
- HtmlHistory.cs
- FolderBrowserDialog.cs
- SizeF.cs
- MsmqTransportSecurity.cs
- TabControlEvent.cs
- DialogResultConverter.cs
- BindingMemberInfo.cs
- VisualBasicHelper.cs
- TrustSection.cs
- UserControlAutomationPeer.cs
- UnauthorizedWebPart.cs
- ColumnCollection.cs
- EllipseGeometry.cs
- ByValueEqualityComparer.cs
- DropShadowBitmapEffect.cs
- UnSafeCharBuffer.cs
- RichTextBox.cs
- CryptoApi.cs
- RotateTransform.cs
- ActivityDesignerLayoutSerializers.cs
- SemaphoreSecurity.cs
- WindowsFormsHost.cs
- CachingHintValidation.cs
- SelectedDatesCollection.cs
- InternalControlCollection.cs
- DbTransaction.cs
- XmlWriterTraceListener.cs
- DockPanel.cs
- ConnectionConsumerAttribute.cs
- CodeArrayCreateExpression.cs
- Utils.cs
- BoundingRectTracker.cs
- PassportIdentity.cs
- ResourcesChangeInfo.cs
- LoadedOrUnloadedOperation.cs
- AddInSegmentDirectoryNotFoundException.cs
- StringAnimationUsingKeyFrames.cs
- DbTransaction.cs
- SqlUtils.cs
- _SslState.cs
- ImageButton.cs
- DiscoveryClientDocuments.cs
- ClientConvert.cs
- DropTarget.cs
- QueryRewriter.cs
- CriticalFileToken.cs
- Models.cs
- SystemWebCachingSectionGroup.cs
- InheritablePropertyChangeInfo.cs
- CqlLexer.cs
- WpfWebRequestHelper.cs
- SnapLine.cs
- NegotiateStream.cs
- Rotation3DKeyFrameCollection.cs
- RC2.cs
- DataGridViewCell.cs
- ArglessEventHandlerProxy.cs
- SafeSecurityHelper.cs
- WebPartTransformer.cs
- ToolStripManager.cs