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
- InkCanvasFeedbackAdorner.cs
- XamlStyleSerializer.cs
- FileDialog_Vista.cs
- IpcPort.cs
- SizeAnimationUsingKeyFrames.cs
- __Filters.cs
- UnauthorizedWebPart.cs
- AliasedSlot.cs
- HasCopySemanticsAttribute.cs
- XmlSchemaDatatype.cs
- ToolStripItemRenderEventArgs.cs
- DetailsViewInsertEventArgs.cs
- EventRoute.cs
- AudioException.cs
- HttpRuntimeSection.cs
- IsolatedStoragePermission.cs
- SapiGrammar.cs
- SchemaTypeEmitter.cs
- ExpressionPrinter.cs
- DataObjectSettingDataEventArgs.cs
- XmlDataSourceView.cs
- xdrvalidator.cs
- DebugTraceHelper.cs
- CacheDependency.cs
- XPathNodeList.cs
- Compilation.cs
- MachineKeyConverter.cs
- NativeActivityAbortContext.cs
- OperationResponse.cs
- OLEDB_Util.cs
- TypeTypeConverter.cs
- MediaScriptCommandRoutedEventArgs.cs
- IsolatedStoragePermission.cs
- SqlDataSourceCustomCommandPanel.cs
- PaintValueEventArgs.cs
- AuthenticationModuleElement.cs
- SelectedDatesCollection.cs
- EncryptedData.cs
- AnnotationHelper.cs
- Triplet.cs
- Semaphore.cs
- ResourceSet.cs
- QilList.cs
- InitializerFacet.cs
- EnumerableCollectionView.cs
- ObjectParameter.cs
- Utility.cs
- EllipseGeometry.cs
- ConsumerConnectionPointCollection.cs
- WorkflowEventArgs.cs
- DataGridViewUtilities.cs
- RemoteHelper.cs
- CacheRequest.cs
- MemberAccessException.cs
- ClientOptions.cs
- WorkflowServiceHost.cs
- CompressEmulationStream.cs
- PipelineModuleStepContainer.cs
- ScriptManagerProxy.cs
- DispatcherTimer.cs
- StubHelpers.cs
- Point4D.cs
- LoginCancelEventArgs.cs
- TextServicesCompartment.cs
- ControlCollection.cs
- CodeTypeParameter.cs
- CodeRegionDirective.cs
- TextBoxView.cs
- PaintValueEventArgs.cs
- MenuAdapter.cs
- ShaderEffect.cs
- ScrollProperties.cs
- CreateParams.cs
- OrderByLifter.cs
- IntellisenseTextBox.designer.cs
- XsdBuilder.cs
- VirtualPath.cs
- Comparer.cs
- ColorTranslator.cs
- CreateParams.cs
- keycontainerpermission.cs
- WebPartHelpVerb.cs
- ActivityWithResultValueSerializer.cs
- TypefaceMetricsCache.cs
- SwitchLevelAttribute.cs
- SpellerError.cs
- ChtmlMobileTextWriter.cs
- MappingModelBuildProvider.cs
- EventRouteFactory.cs
- CompilerHelpers.cs
- TypeConverterHelper.cs
- CustomErrorsSectionWrapper.cs
- TrackingWorkflowEventArgs.cs
- GridViewEditEventArgs.cs
- HierarchicalDataBoundControl.cs
- XmlHierarchicalEnumerable.cs
- Brushes.cs
- followingquery.cs
- Brushes.cs
- ProcessThreadCollection.cs