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
- SimpleWorkerRequest.cs
- DesignerEditorPartChrome.cs
- RemoteCryptoSignHashRequest.cs
- XhtmlBasicImageAdapter.cs
- FileLoadException.cs
- Run.cs
- NotEqual.cs
- Maps.cs
- ApplicationServicesHostFactory.cs
- CultureInfo.cs
- HttpCookieCollection.cs
- SortKey.cs
- Matrix3D.cs
- DescendentsWalker.cs
- TransformCollection.cs
- XmlUtil.cs
- GridViewUpdateEventArgs.cs
- OuterGlowBitmapEffect.cs
- SqlPersonalizationProvider.cs
- MenuItemStyleCollection.cs
- DelimitedListTraceListener.cs
- TreeNodeEventArgs.cs
- ReachDocumentSequenceSerializerAsync.cs
- SafeBitVector32.cs
- ChameleonKey.cs
- PermissionSetTriple.cs
- WebPartEventArgs.cs
- PenContexts.cs
- CatalogZone.cs
- InputQueue.cs
- BinaryWriter.cs
- SchemaImporterExtension.cs
- NamespaceList.cs
- HwndHost.cs
- SqlFacetAttribute.cs
- MapPathBasedVirtualPathProvider.cs
- FormViewRow.cs
- SequentialActivityDesigner.cs
- PackWebRequest.cs
- GrammarBuilderWildcard.cs
- DesignerView.cs
- ActivityIdHeader.cs
- StylusDownEventArgs.cs
- FunctionUpdateCommand.cs
- TextBounds.cs
- GenericsInstances.cs
- PackagePartCollection.cs
- BehaviorEditorPart.cs
- FilteredAttributeCollection.cs
- SubstitutionList.cs
- ProcessManager.cs
- Content.cs
- Base64Decoder.cs
- GPPOINT.cs
- DataGridViewUtilities.cs
- RangeValueProviderWrapper.cs
- ResizeGrip.cs
- PlatformCulture.cs
- StrokeCollectionDefaultValueFactory.cs
- Int16Animation.cs
- SrgsRule.cs
- XmlSchemaSimpleContentRestriction.cs
- VerticalAlignConverter.cs
- ItemsChangedEventArgs.cs
- DataServiceRequest.cs
- TextServicesProperty.cs
- DetailsViewModeEventArgs.cs
- ToolStripPanelCell.cs
- Misc.cs
- MemberInfoSerializationHolder.cs
- HtmlInputText.cs
- DocumentEventArgs.cs
- PageVisual.cs
- BlockCollection.cs
- DetailsViewModeEventArgs.cs
- TrackPointCollection.cs
- _Events.cs
- LOSFormatter.cs
- TrustLevelCollection.cs
- autovalidator.cs
- GridViewRowCollection.cs
- ActivityBindForm.Designer.cs
- LocalServiceSecuritySettingsElement.cs
- SocketConnection.cs
- EntityDataSourceDesignerHelper.cs
- DecoderReplacementFallback.cs
- XMLDiffLoader.cs
- BitmapFrameEncode.cs
- MarkupWriter.cs
- MaterializeFromAtom.cs
- SqlConnectionString.cs
- FigureParaClient.cs
- Automation.cs
- MenuItem.cs
- WebPartChrome.cs
- TextElementCollectionHelper.cs
- EntityContainerAssociationSet.cs
- EndEvent.cs
- StrokeCollection2.cs
- Atom10FormatterFactory.cs