Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WCF / WasHosting / System / ServiceModel / WasHosting / BaseProcessProtocolHandler.cs / 1305376 / BaseProcessProtocolHandler.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.WasHosting { using System; using System.Collections.Generic; using System.Diagnostics; using System.Diagnostics.CodeAnalysis; using System.ServiceModel; using System.Web; using System.Web.Hosting; using System.ServiceModel.Channels; using System.ServiceModel.Activation; using System.Runtime; abstract class BaseProcessProtocolHandler : ProcessProtocolHandler { string protocolId; IAdphManager adphManager; // Mapping from listenerChannelId->listenerChannelContext (i.e. IAdphManager, appId) DictionarylistenerChannelIdMapping = new Dictionary (); [SuppressMessage(FxCop.Category.Performance, FxCop.Rule.AvoidUncalledPrivateCode, Justification = "Instantiated by ASP.NET")] protected BaseProcessProtocolHandler(string protocolId) : base() { this.protocolId = protocolId; } internal virtual void HandleStartListenerChannelError(IListenerChannelCallback listenerChannelCallback, Exception ex) { // This is the workaround to let WAS know that the LC is started and then gracefully stopped. listenerChannelCallback.ReportStarted(); listenerChannelCallback.ReportStopped(0); } // Start per-process listening for messages public override void StartListenerChannel(IListenerChannelCallback listenerChannelCallback, IAdphManager adphManager) { DiagnosticUtility.DebugAssert(listenerChannelCallback != null, "The listenerChannelCallback parameter must not be null"); DiagnosticUtility.DebugAssert(adphManager != null, "The adphManager parameter must not be null"); int channelId = listenerChannelCallback.GetId(); ListenerChannelContext listenerChannelContext; lock (this.listenerChannelIdMapping) { if (!listenerChannelIdMapping.TryGetValue(channelId, out listenerChannelContext)) { int listenerChannelDataLength = listenerChannelCallback.GetBlobLength(); byte[] listenerChannelData = new byte[listenerChannelDataLength]; listenerChannelCallback.GetBlob(listenerChannelData, ref listenerChannelDataLength); Debug.Print("BaseProcessProtocolHandler.StartListenerChannel() GetBlob() contains " + listenerChannelDataLength + " bytes"); listenerChannelContext = ListenerChannelContext.Hydrate(listenerChannelData); this.listenerChannelIdMapping.Add(channelId, listenerChannelContext); Debug.Print("BaseProcessProtocolHandler.StartListenerChannel() listenerChannelContext.ListenerChannelId: " + listenerChannelContext.ListenerChannelId); } } if (this.adphManager == null) { this.adphManager = adphManager; } try { // wether or not a previous AppDomain was running, we're going to start a new one now: Debug.Print("BaseProcessProtocolHandler.StartListenerChannel() calling StartAppDomainProtocolListenerChannel(appKey:" + listenerChannelContext.AppKey + " protocolId:" + protocolId + ")"); adphManager.StartAppDomainProtocolListenerChannel(listenerChannelContext.AppKey, protocolId, listenerChannelCallback); } catch (Exception ex) { if (Fx.IsFatal(ex)) { throw; } if (DiagnosticUtility.ShouldTraceError) { DiagnosticUtility.ExceptionUtility.TraceHandledException(ex, TraceEventType.Error); } HandleStartListenerChannelError(listenerChannelCallback, ex); } } public override void StopProtocol(bool immediate) { Debug.Print("BaseProcessProtocolHandler.StopProtocol(protocolId:" + protocolId + ", immediate:" + immediate + ")"); } public override void StopListenerChannel(int listenerChannelId, bool immediate) { Debug.Print("BaseProcessProtocolHandler.StopListenerChannel(protocolId:" + protocolId + ", listenerChannelId:" + listenerChannelId + ", immediate:" + immediate + ")"); ListenerChannelContext listenerChannelContext = this.listenerChannelIdMapping[listenerChannelId]; adphManager.StopAppDomainProtocolListenerChannel(listenerChannelContext.AppKey, protocolId, listenerChannelId, immediate); lock (this.listenerChannelIdMapping) { // Remove the channel id. this.listenerChannelIdMapping.Remove(listenerChannelId); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- TypeUnloadedException.cs
- HierarchicalDataBoundControl.cs
- StringSource.cs
- NonParentingControl.cs
- FileLevelControlBuilderAttribute.cs
- ProcessInputEventArgs.cs
- CompilerScope.cs
- RefType.cs
- PeerCollaboration.cs
- CredentialCache.cs
- safelinkcollection.cs
- Listener.cs
- Package.cs
- PathGradientBrush.cs
- ReliableChannelListener.cs
- ZipPackage.cs
- SetIterators.cs
- RtfFormatStack.cs
- GroupStyle.cs
- DesignerActionItemCollection.cs
- NavigatorOutput.cs
- XamlVector3DCollectionSerializer.cs
- SpeakProgressEventArgs.cs
- StaticExtension.cs
- OleDbRowUpdatedEvent.cs
- DefaultProxySection.cs
- TextTreeInsertElementUndoUnit.cs
- ContourSegment.cs
- PriorityQueue.cs
- XmlNamedNodeMap.cs
- ConcurrencyMode.cs
- DesignerVerbCollection.cs
- MailDefinitionBodyFileNameEditor.cs
- ValueSerializerAttribute.cs
- tooltip.cs
- MemoryFailPoint.cs
- EditableTreeList.cs
- NullableBoolConverter.cs
- XPathBinder.cs
- Internal.cs
- IisTraceListener.cs
- SystemParameters.cs
- DataBoundLiteralControl.cs
- Triplet.cs
- SpecularMaterial.cs
- SafeNativeMemoryHandle.cs
- PieceNameHelper.cs
- ExtensionQuery.cs
- DateTimeSerializationSection.cs
- XPathDocumentNavigator.cs
- SecondaryViewProvider.cs
- BezierSegment.cs
- LinqDataSourceContextData.cs
- CodeDirectiveCollection.cs
- mansign.cs
- ColorTransformHelper.cs
- SelectionHighlightInfo.cs
- AuthenticatingEventArgs.cs
- PropertyDescriptor.cs
- CodeLinePragma.cs
- DBCommandBuilder.cs
- TextDecorationCollection.cs
- ConfigurationManagerInternal.cs
- WebPartHelpVerb.cs
- FontFamily.cs
- PerformanceCounterScope.cs
- DataSourceView.cs
- OdbcPermission.cs
- InvalidComObjectException.cs
- SiteMapDataSourceView.cs
- EditorPartDesigner.cs
- PolicyException.cs
- DesignerHelpers.cs
- LocalizationComments.cs
- WebRequestModulesSection.cs
- WebPartZoneBaseDesigner.cs
- UrlMappingsSection.cs
- SchemaImporter.cs
- ChangePassword.cs
- HttpHandlerActionCollection.cs
- ManagementObjectSearcher.cs
- UnionCqlBlock.cs
- InfoCardRSAPKCS1SignatureFormatter.cs
- AnonymousIdentificationSection.cs
- XpsSerializationManager.cs
- UIElementParagraph.cs
- CopyCodeAction.cs
- UidManager.cs
- UnsafeNativeMethods.cs
- WebHostedComPlusServiceHost.cs
- SizeLimitedCache.cs
- Menu.cs
- SoapTransportImporter.cs
- ClientProtocol.cs
- GlyphManager.cs
- SiteOfOriginPart.cs
- SecurityElement.cs
- Color.cs
- ViewBox.cs
- BehaviorEditorPart.cs