Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / ChannelTracker.cs / 1 / ChannelTracker.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.ServiceModel; using System.Diagnostics; using System.IO; using System.Runtime.Serialization; using System.ServiceModel.Diagnostics; using System.Text; using System.Threading; using System.ServiceModel.Description; using System.Xml; ////// Track channels and (optionally) associated state /// class ChannelTracker: CommunicationObject where TChannel : IChannel where TState : class { Dictionary receivers; EventHandler onInnerChannelClosed; EventHandler onInnerChannelFaulted; public ChannelTracker() { this.receivers = new Dictionary (); this.onInnerChannelClosed = new EventHandler(OnInnerChannelClosed); this.onInnerChannelFaulted = new EventHandler(OnInnerChannelFaulted); } public void Add(TChannel channel, TState channelReceiver) { bool abortChannel = false; lock (this.receivers) { if (this.State != CommunicationState.Opened) { abortChannel = true; } else { this.receivers.Add(channel, channelReceiver); } } if (abortChannel) { channel.Abort(); } } public void PrepareChannel(TChannel channel) { channel.Faulted += this.onInnerChannelFaulted; channel.Closed += this.onInnerChannelClosed; } void OnInnerChannelFaulted(object sender, EventArgs e) { ((TChannel)sender).Abort(); } void OnInnerChannelClosed(object sender, EventArgs e) { // remove the channel from our tracking dictionary TChannel channel = (TChannel)sender; this.Remove(channel); channel.Faulted -= this.onInnerChannelFaulted; channel.Closed -= this.onInnerChannelClosed; } public bool Remove(TChannel channel) { lock (this.receivers) { return this.receivers.Remove(channel); } } TChannel[] GetChannels() { lock (this.receivers) { TChannel[] channels = new TChannel[this.receivers.Keys.Count]; this.receivers.Keys.CopyTo(channels, 0); this.receivers.Clear(); return channels; } } protected override void OnAbort() { TChannel[] channels = GetChannels(); for (int i = 0; i < channels.Length; i++) { channels[i].Abort(); } } protected override void OnClose(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); TChannel[] channels = GetChannels(); for (int i = 0; i < channels.Length; i++) { bool success = false; try { channels[i].Close(timeoutHelper.RemainingTime()); success = true; } catch (CommunicationException e) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } catch (TimeoutException e) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } finally { if (!success) { channels[i].Abort(); } } } } protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state) { TChannel[] channels = GetChannels(); List collection = new List (); for (int i = 0; i < channels.Length; i++) { collection.Add(channels[i]); } return new CloseCollectionAsyncResult(timeout, callback, state, collection); } protected override void OnEndClose(IAsyncResult result) { CloseCollectionAsyncResult.End(result); } protected override TimeSpan DefaultCloseTimeout { get { return ServiceDefaults.CloseTimeout; } } protected override TimeSpan DefaultOpenTimeout { get { return ServiceDefaults.OpenTimeout; } } protected override void OnOpen(TimeSpan timeout) { } protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state) { return new CompletedAsyncResult(callback, state); } protected override void OnEndOpen(IAsyncResult result) { CompletedAsyncResult.End(result); } } } // 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
- KnowledgeBase.cs
- CustomWebEventKey.cs
- TransformValueSerializer.cs
- EdmProviderManifest.cs
- MinimizableAttributeTypeConverter.cs
- GridViewRow.cs
- ConnectionProviderAttribute.cs
- webclient.cs
- XmlSchemaDatatype.cs
- TextTreeUndoUnit.cs
- CommandSet.cs
- ConstantSlot.cs
- EdmItemCollection.cs
- List.cs
- ManagementObjectSearcher.cs
- DrawingGroup.cs
- TextParagraph.cs
- CheckBoxStandardAdapter.cs
- AsnEncodedData.cs
- MarkupExtensionReturnTypeAttribute.cs
- DisposableCollectionWrapper.cs
- JsonFaultDetail.cs
- DescendantOverDescendantQuery.cs
- PatternMatcher.cs
- TypefaceMetricsCache.cs
- NativeRecognizer.cs
- DesignTimeTemplateParser.cs
- DebuggerAttributes.cs
- FixUpCollection.cs
- AppDomainInstanceProvider.cs
- EntitySqlQueryState.cs
- DesignSurfaceServiceContainer.cs
- TransformDescriptor.cs
- AuthenticationServiceManager.cs
- LinqDataSource.cs
- ReferencedCollectionType.cs
- HandlerMappingMemo.cs
- SplineQuaternionKeyFrame.cs
- IDQuery.cs
- MarshalByRefObject.cs
- FloaterBaseParaClient.cs
- InfoCardSymmetricCrypto.cs
- SqlGatherProducedAliases.cs
- BatchServiceHost.cs
- TickBar.cs
- DeviceContext.cs
- DoubleUtil.cs
- SyndicationElementExtensionCollection.cs
- ExclusiveTcpTransportManager.cs
- BoundsDrawingContextWalker.cs
- CustomValidator.cs
- EventMappingSettingsCollection.cs
- WrapperEqualityComparer.cs
- VisualStateChangedEventArgs.cs
- DataBinding.cs
- SqlDeflator.cs
- Configuration.cs
- DESCryptoServiceProvider.cs
- WebPageTraceListener.cs
- CreateParams.cs
- TextViewDesigner.cs
- ParameterElementCollection.cs
- SourceChangedEventArgs.cs
- TimersDescriptionAttribute.cs
- WindowsListViewSubItem.cs
- EntityClassGenerator.cs
- DataDocumentXPathNavigator.cs
- TextDecorations.cs
- SessionStateContainer.cs
- CriticalHandle.cs
- HttpCookiesSection.cs
- DataGridRowsPresenter.cs
- WebConfigurationHost.cs
- Int16AnimationBase.cs
- ThreadNeutralSemaphore.cs
- UIElement.cs
- FieldAccessException.cs
- DropDownButton.cs
- GridView.cs
- GAC.cs
- DataGridViewCellParsingEventArgs.cs
- RequestQueue.cs
- ValueConversionAttribute.cs
- CacheAxisQuery.cs
- FusionWrap.cs
- Matrix.cs
- HttpCookie.cs
- ButtonStandardAdapter.cs
- ContentOperations.cs
- EncodingDataItem.cs
- PtsCache.cs
- EqualityComparer.cs
- TextBoxBase.cs
- Zone.cs
- VersionedStreamOwner.cs
- TypeExtensions.cs
- Misc.cs
- StateValidator.cs
- DataAdapter.cs
- DataServiceHost.cs