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
- TimeManager.cs
- ProtectedProviderSettings.cs
- PathFigureCollectionConverter.cs
- RawContentTypeMapper.cs
- MenuItemBindingCollection.cs
- SafeNativeMethods.cs
- SymDocumentType.cs
- FileLogRecordStream.cs
- ParseNumbers.cs
- FormViewPagerRow.cs
- ParagraphVisual.cs
- InkCanvasFeedbackAdorner.cs
- NotImplementedException.cs
- LineSegment.cs
- FontStretch.cs
- TextEditorTables.cs
- SingleSelectRootGridEntry.cs
- QueryTaskGroupState.cs
- RadioButtonList.cs
- ConfigXmlCDataSection.cs
- RadioButton.cs
- PackageProperties.cs
- SkewTransform.cs
- BulletedListEventArgs.cs
- InfoCardListRequest.cs
- AsymmetricKeyExchangeFormatter.cs
- DbConvert.cs
- OleDbPropertySetGuid.cs
- EntityCommandCompilationException.cs
- PageAsyncTask.cs
- FixedStringLookup.cs
- DoubleAnimationUsingPath.cs
- X509Extension.cs
- LogicalMethodInfo.cs
- BoolExpr.cs
- CroppedBitmap.cs
- DiscoveryMessageSequence.cs
- BooleanSwitch.cs
- EventPropertyMap.cs
- CompensationTokenData.cs
- SafeCryptContextHandle.cs
- InvalidOleVariantTypeException.cs
- SynchronizedInputAdaptor.cs
- NetCodeGroup.cs
- TableItemStyle.cs
- RijndaelManaged.cs
- ResourceDescriptionAttribute.cs
- XamlWriter.cs
- Rule.cs
- FilterEventArgs.cs
- CustomLineCap.cs
- RangeValueProviderWrapper.cs
- OrderedDictionary.cs
- XmlTextReaderImplHelpers.cs
- EndOfStreamException.cs
- Convert.cs
- GestureRecognizer.cs
- WmlPanelAdapter.cs
- XamlPathDataSerializer.cs
- CodeDesigner.cs
- BinaryVersion.cs
- SystemNetHelpers.cs
- CodeTypeMemberCollection.cs
- DispatcherExceptionEventArgs.cs
- MarkupExtensionSerializer.cs
- Msmq4PoisonHandler.cs
- RegexFCD.cs
- DriveInfo.cs
- BitmapEffectInput.cs
- InternalControlCollection.cs
- DbParameterCollectionHelper.cs
- HitTestDrawingContextWalker.cs
- SubpageParagraph.cs
- CodeDomConfigurationHandler.cs
- NoneExcludedImageIndexConverter.cs
- PasswordBox.cs
- PersonalizableTypeEntry.cs
- StrokeCollectionDefaultValueFactory.cs
- ExpressionWriter.cs
- UInt16.cs
- ObjectListFieldCollection.cs
- SerializerProvider.cs
- IntSecurity.cs
- TypeFieldSchema.cs
- FileDataSourceCache.cs
- WebPartManager.cs
- ListenerChannelContext.cs
- OrderedDictionaryStateHelper.cs
- WsdlBuildProvider.cs
- SqlCachedBuffer.cs
- IndentedWriter.cs
- KnownTypesHelper.cs
- RegistryKey.cs
- EmbeddedObject.cs
- MessageBox.cs
- CalloutQueueItem.cs
- MouseGestureConverter.cs
- SubMenuStyleCollection.cs
- ProxyGenerator.cs
- HttpStaticObjectsCollectionWrapper.cs