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
- XPathQueryGenerator.cs
- ImageAnimator.cs
- FlowDocumentScrollViewer.cs
- UnSafeCharBuffer.cs
- EFTableProvider.cs
- IdentityHolder.cs
- ZipIOZip64EndOfCentralDirectoryBlock.cs
- ICollection.cs
- TrackingServices.cs
- SqlNode.cs
- RemoveStoryboard.cs
- PaintValueEventArgs.cs
- TrackBarRenderer.cs
- ListViewInsertedEventArgs.cs
- DataControlField.cs
- Hash.cs
- DivideByZeroException.cs
- ServiceObjectContainer.cs
- ButtonRenderer.cs
- UnsafeNativeMethods.cs
- PreDigestedSignedInfo.cs
- WebBrowserPermission.cs
- XmlAnyElementAttribute.cs
- IERequestCache.cs
- NetDataContractSerializer.cs
- AsyncParams.cs
- DiscoveryDocument.cs
- BindingListCollectionView.cs
- Light.cs
- ProvidersHelper.cs
- FrugalMap.cs
- SqlConnectionManager.cs
- LocalServiceSecuritySettingsElement.cs
- QuaternionConverter.cs
- DispatcherFrame.cs
- CookieProtection.cs
- BitmapEffectDrawingContextState.cs
- GridView.cs
- CompiledAction.cs
- IBuiltInEvidence.cs
- ReturnValue.cs
- DataGridViewLayoutData.cs
- ISessionStateStore.cs
- ColumnHeader.cs
- BamlCollectionHolder.cs
- SelectionProviderWrapper.cs
- WorkflowMarkupSerializerMapping.cs
- ResourceProperty.cs
- Convert.cs
- HttpHandlerAction.cs
- handlecollector.cs
- EditorPartChrome.cs
- WebServiceHandlerFactory.cs
- UnsafeCollabNativeMethods.cs
- DataControlFieldCell.cs
- WindowsIdentity.cs
- _NestedMultipleAsyncResult.cs
- CompilerInfo.cs
- PointAnimationUsingPath.cs
- AbsoluteQuery.cs
- RemotingConfigParser.cs
- HttpDictionary.cs
- SymLanguageType.cs
- TemplateXamlParser.cs
- CharacterMetrics.cs
- CodePrimitiveExpression.cs
- SiteMapNodeItem.cs
- StrongNameKeyPair.cs
- ToolStripSettings.cs
- CommandHelper.cs
- DeviceOverridableAttribute.cs
- AlignmentXValidation.cs
- GenericTypeParameterConverter.cs
- DesignerActionItem.cs
- WmfPlaceableFileHeader.cs
- ServiceManagerHandle.cs
- VectorAnimationUsingKeyFrames.cs
- XmlValueConverter.cs
- SequentialUshortCollection.cs
- CellQuery.cs
- RunInstallerAttribute.cs
- SiteMapPathDesigner.cs
- elementinformation.cs
- PageParser.cs
- Encoding.cs
- HtmlInputText.cs
- WinFormsUtils.cs
- StrokeNodeData.cs
- ConfigurationSection.cs
- SessionEndedEventArgs.cs
- TemplateXamlParser.cs
- VisualTreeUtils.cs
- TransactionChannelFaultConverter.cs
- ImageListDesigner.cs
- RotateTransform3D.cs
- TypeUtil.cs
- UdpDiscoveryMessageFilter.cs
- XpsSerializationException.cs
- UserUseLicenseDictionaryLoader.cs
- AlternationConverter.cs