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
- Typeface.cs
- AddInProcess.cs
- VirtualizingPanel.cs
- KeyConverter.cs
- DefaultValueTypeConverter.cs
- TaskDesigner.cs
- ComplexTypeEmitter.cs
- _NestedMultipleAsyncResult.cs
- ExpandableObjectConverter.cs
- DebuggerAttributes.cs
- CheckBox.cs
- IDQuery.cs
- SortFieldComparer.cs
- HashHelpers.cs
- Int64.cs
- DoubleAnimationBase.cs
- HttpProfileBase.cs
- ThreadSafeList.cs
- References.cs
- ValueTypeFixupInfo.cs
- ImageMapEventArgs.cs
- GuidelineCollection.cs
- SqlConnectionFactory.cs
- TextElementCollection.cs
- TypeLibConverter.cs
- NavigationCommands.cs
- PresentationSource.cs
- UpnEndpointIdentityExtension.cs
- webproxy.cs
- TemplatePropertyEntry.cs
- DependencyObjectCodeDomSerializer.cs
- HierarchicalDataTemplate.cs
- SafeFileMapViewHandle.cs
- Int16Converter.cs
- MediaEntryAttribute.cs
- ScriptControlManager.cs
- SystemDiagnosticsSection.cs
- RequestStatusBarUpdateEventArgs.cs
- PieceNameHelper.cs
- itemelement.cs
- FacetValues.cs
- DataTrigger.cs
- PositiveTimeSpanValidator.cs
- PackagePartCollection.cs
- XmlFormatExtensionPrefixAttribute.cs
- TextReader.cs
- TabItem.cs
- Function.cs
- DataGridDefaultColumnWidthTypeConverter.cs
- InternalResources.cs
- GeneralTransform3DGroup.cs
- HtmlMeta.cs
- UpdatePanelControlTrigger.cs
- DropDownButton.cs
- X509ThumbprintKeyIdentifierClause.cs
- RetrieveVirtualItemEventArgs.cs
- ListCommandEventArgs.cs
- TextEndOfSegment.cs
- DesignTimeVisibleAttribute.cs
- CoTaskMemHandle.cs
- HotSpot.cs
- HttpServerProtocol.cs
- Cursor.cs
- WriteableBitmap.cs
- TagPrefixCollection.cs
- RegisteredArrayDeclaration.cs
- RichTextBox.cs
- DbReferenceCollection.cs
- XmlSchemaValidationException.cs
- WebException.cs
- InternalTypeHelper.cs
- FileClassifier.cs
- Stylesheet.cs
- XmlNodeChangedEventArgs.cs
- QilFactory.cs
- OrderedHashRepartitionStream.cs
- PreviewPageInfo.cs
- ThicknessConverter.cs
- RegexStringValidator.cs
- UInt64Converter.cs
- CanonicalFontFamilyReference.cs
- RSAPKCS1SignatureDeformatter.cs
- XmlExpressionDumper.cs
- TableHeaderCell.cs
- FieldAccessException.cs
- CategoryNameCollection.cs
- IntranetCredentialPolicy.cs
- AttachedPropertyBrowsableWhenAttributePresentAttribute.cs
- Region.cs
- ObservableDictionary.cs
- Ports.cs
- LoadedOrUnloadedOperation.cs
- XmlToDatasetMap.cs
- WorkflowItemsPresenter.cs
- Wildcard.cs
- InternalConfirm.cs
- CodeStatementCollection.cs
- AssemblyFilter.cs
- XmlCodeExporter.cs
- ToolStripStatusLabel.cs