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
- IconHelper.cs
- ExceptionUtil.cs
- SecUtil.cs
- AnimationLayer.cs
- EntityDataSourceWrapper.cs
- LassoHelper.cs
- SoapBinding.cs
- XmlIterators.cs
- SQLUtility.cs
- Simplifier.cs
- ControlParameter.cs
- EntitySetBase.cs
- KeyBinding.cs
- TransactionManager.cs
- ColorContextHelper.cs
- ApplyTemplatesAction.cs
- SemaphoreFullException.cs
- BindingNavigator.cs
- DropShadowEffect.cs
- DataPager.cs
- TableProviderWrapper.cs
- SqlMethodAttribute.cs
- ValueOfAction.cs
- SubstitutionList.cs
- AttachedPropertyBrowsableWhenAttributePresentAttribute.cs
- Pts.cs
- Input.cs
- ListViewItem.cs
- SapiAttributeParser.cs
- SimpleTextLine.cs
- ScrollChrome.cs
- ExternalException.cs
- NativeMethods.cs
- Point3DConverter.cs
- WorkflowTerminatedException.cs
- PropertyChangedEventManager.cs
- DataSourceViewSchemaConverter.cs
- IpcServerChannel.cs
- SafeSecurityHandles.cs
- DocumentSequenceHighlightLayer.cs
- QueryContinueDragEvent.cs
- ValidatorCollection.cs
- ParameterRetriever.cs
- RichTextBox.cs
- DatatypeImplementation.cs
- Visual3D.cs
- UriParserTemplates.cs
- CategoryList.cs
- SplitterEvent.cs
- UnknownWrapper.cs
- HostProtectionException.cs
- OpenTypeCommon.cs
- PointLight.cs
- Pointer.cs
- ByteAnimationBase.cs
- Clause.cs
- TraceSection.cs
- OutputCacheProviderCollection.cs
- NotifyParentPropertyAttribute.cs
- TypeSystem.cs
- SqlCrossApplyToCrossJoin.cs
- SpeechAudioFormatInfo.cs
- HeaderPanel.cs
- RSAPKCS1KeyExchangeFormatter.cs
- NamespaceMapping.cs
- SystemColors.cs
- ConfigurationElementCollection.cs
- MobileTemplatedControlDesigner.cs
- ProjectedSlot.cs
- EndpointInfo.cs
- GridItem.cs
- ExpressionBindingCollection.cs
- RectAnimation.cs
- CodeParameterDeclarationExpressionCollection.cs
- DataKey.cs
- Color.cs
- TemplateLookupAction.cs
- MatrixCamera.cs
- RewritingSimplifier.cs
- PathFigureCollectionValueSerializer.cs
- C14NUtil.cs
- M3DUtil.cs
- PageSettings.cs
- PassportAuthentication.cs
- HostingEnvironmentWrapper.cs
- WeakRefEnumerator.cs
- ViewCellRelation.cs
- TypeUtils.cs
- DocumentPageView.cs
- ConfigurationSection.cs
- ClassHandlersStore.cs
- DbCommandTree.cs
- ScrollBarAutomationPeer.cs
- HuffmanTree.cs
- RulePatternOps.cs
- bindurihelper.cs
- SymbolPair.cs
- ReceiveMessageAndVerifySecurityAsyncResultBase.cs
- EntityWithKeyStrategy.cs
- RawTextInputReport.cs