Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / WasHosting / System / ServiceModel / WasHosting / BaseAppDomainProtocolHandler.cs / 1 / BaseAppDomainProtocolHandler.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.WasHosting { using System; using System.Diagnostics; using System.ServiceModel; using System.ServiceModel.Channels; using System.Web; using System.Web.Hosting; using System.ServiceModel.Activation; using System.ServiceModel.Diagnostics; using System.Runtime.InteropServices; abstract class BaseAppDomainProtocolHandler : AppDomainProtocolHandler { string protocolId; IListenerChannelCallback listenerChannelCallback; protected ListenerChannelContext listenerChannelContext; object syncRoot = new object(); protected BaseAppDomainProtocolHandler(string protocolId) : base() { this.protocolId = protocolId; } object ThisLock { get { return this.syncRoot; } } protected void OnMessageReceived() { try { IListenerChannelCallback callback = this.listenerChannelCallback; if (callback != null) { callback.ReportMessageReceived(); } } catch (COMException exception) { if (DiagnosticUtility.ShouldTraceWarning) { DiagnosticUtility.ExceptionUtility.TraceHandledException(exception, TraceEventType.Warning); } // The listener adapter might have gone away. Ignore the error. } } // Start per-process listening for messages public override void StartListenerChannel(IListenerChannelCallback listenerChannelCallback) { Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel()"); if (listenerChannelCallback == null) { DiagnosticUtility.DebugAssert("listenerChannelCallback is null"); throw DiagnosticUtility.ExceptionUtility.ThrowHelperInternal(false); } this.listenerChannelCallback = listenerChannelCallback; int listenerChannelDataLength = listenerChannelCallback.GetBlobLength(); byte[] listenerChannelData = new byte[listenerChannelDataLength]; listenerChannelCallback.GetBlob(listenerChannelData, ref listenerChannelDataLength); Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel() GetBlob() contains " + listenerChannelDataLength + " bytes"); listenerChannelContext = ListenerChannelContext.Hydrate(listenerChannelData); Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel() calling OnStart()"); #if DEBUG // Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel() waiting for you to attach the debugger to " + Process.GetCurrentProcess().ProcessName + " Pid: " + Process.GetCurrentProcess().Id); // for (int sleepCount = 0; sleepCount < 30 && !Debugger.IsAttached && !ListenerUnsafeNativeMethods.IsDebuggerPresent(); sleepCount++) { Thread.Sleep(500); } Debugger.Break(); #endif try { OnStart(); listenerChannelCallback.ReportStarted(); Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel() called ReportStarted()"); } catch (CommunicationException exception) { Debug.Print("BaseAppDomainProtocolHandler.StartListenerChannel() failed in OnStart():\r\n" + exception); DiagnosticUtility.EventLog.LogEvent(TraceEventType.Error, EventLogCategory.WebHost, EventLogEventId.WebHostFailedToListen, listenerChannelContext.AppKey, this.protocolId, DiagnosticTrace.CreateSourceString(this), exception.ToString()); throw; } } protected virtual void OnStart() { } protected virtual void OnStop() { } public override void StopProtocol(bool immediate) { Debug.Print("BaseAppDomainProtocolHandler.StopProtocol() immediate: " + immediate + " calling ReportStopped()"); Stop(); HostingEnvironment.UnregisterObject(this); } public override void StopListenerChannel(int listenerChannelId, bool immediate) { Debug.Print("BaseAppDomainProtocolHandler.StopListenerChannel() listenerChannelId: " + listenerChannelId + " immediate: " + immediate + " calling ReportStopped()"); if (listenerChannelId != listenerChannelContext.ListenerChannelId) { DiagnosticUtility.DebugAssert("Invalid ListenerChannel ID!"); throw DiagnosticUtility.ExceptionUtility.ThrowHelperInternal(false); } Stop(); } void Stop() { lock (ThisLock) { if (this.listenerChannelCallback != null) { OnStop(); this.listenerChannelCallback.ReportStopped(0); this.listenerChannelCallback = null; } } } } } // 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
- SpinWait.cs
- ItemsControlAutomationPeer.cs
- DataGridHelper.cs
- ReliableSession.cs
- Hex.cs
- SqlConnectionPoolProviderInfo.cs
- COAUTHINFO.cs
- DocumentCollection.cs
- SmiEventSink.cs
- ColorTranslator.cs
- Helpers.cs
- PageCatalogPart.cs
- AuthorizationContext.cs
- MatchingStyle.cs
- UserControlFileEditor.cs
- PropertyRecord.cs
- dataSvcMapFileLoader.cs
- TableLayoutSettingsTypeConverter.cs
- SingleConverter.cs
- oledbconnectionstring.cs
- DbParameterCollectionHelper.cs
- NetStream.cs
- HttpModuleCollection.cs
- NoClickablePointException.cs
- CheckBox.cs
- FontInfo.cs
- TraceUtility.cs
- RightsManagementEncryptedStream.cs
- DbSetClause.cs
- PasswordDeriveBytes.cs
- _NtlmClient.cs
- UpWmlPageAdapter.cs
- SQLResource.cs
- LineBreak.cs
- Binding.cs
- QilXmlWriter.cs
- ParameterBuilder.cs
- XmlName.cs
- FixedSOMSemanticBox.cs
- XmlSchemaAttribute.cs
- XmlCharCheckingReader.cs
- DataBindingHandlerAttribute.cs
- DbConvert.cs
- ProcessManager.cs
- ManagementException.cs
- AuthenticateEventArgs.cs
- GuidelineCollection.cs
- SafeLibraryHandle.cs
- SmtpMail.cs
- EntryPointNotFoundException.cs
- MultiSelector.cs
- SqlCacheDependency.cs
- ThemeDictionaryExtension.cs
- Transactions.cs
- Dispatcher.cs
- CommonDialog.cs
- Directory.cs
- GradientStop.cs
- Binding.cs
- AsyncCompletedEventArgs.cs
- PolyLineSegment.cs
- SemanticKeyElement.cs
- FrugalList.cs
- PopOutPanel.cs
- HandlerFactoryCache.cs
- StringSorter.cs
- ColumnCollectionEditor.cs
- StickyNoteHelper.cs
- ExcCanonicalXml.cs
- LayoutEngine.cs
- Size.cs
- ToggleButton.cs
- FrameworkContentElement.cs
- _UriSyntax.cs
- SQLBinaryStorage.cs
- FileUtil.cs
- QilPatternVisitor.cs
- DodSequenceMerge.cs
- SettingsContext.cs
- PropertyFilter.cs
- UpdatePanel.cs
- InstancePersistence.cs
- DataGridViewCellCollection.cs
- FilteredDataSetHelper.cs
- ArgumentNullException.cs
- DataServiceEntityAttribute.cs
- XPathAncestorIterator.cs
- PackageRelationship.cs
- TypeCodeDomSerializer.cs
- FileEnumerator.cs
- TreeBuilderBamlTranslator.cs
- Emitter.cs
- SafeCryptoHandles.cs
- AtomMaterializerLog.cs
- QilVisitor.cs
- ExtractorMetadata.cs
- AsymmetricSignatureDeformatter.cs
- MediaPlayerState.cs
- CustomWebEventKey.cs
- Compiler.cs