Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / WasHosting / System / ServiceModel / WasHosting / BaseProcessProtocolHandler.cs / 1 / BaseProcessProtocolHandler.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.WasHosting { using System; using System.Collections.Generic; using System.Diagnostics; using System.ServiceModel; using System.Web; using System.Web.Hosting; using System.ServiceModel.Channels; using System.ServiceModel.Activation; abstract class BaseProcessProtocolHandler : ProcessProtocolHandler { string protocolId; IAdphManager adphManager; // Mapping from listenerChannelId->listenerChannelContext (i.e. IAdphManager, appId) DictionarylistenerChannelIdMapping = new Dictionary (); 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 (DiagnosticUtility.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. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- AcceptorSessionSymmetricTransportSecurityProtocol.cs
- _CacheStreams.cs
- LocalBuilder.cs
- FieldBuilder.cs
- Trace.cs
- CryptoHandle.cs
- COM2Enum.cs
- UndirectedGraph.cs
- BinaryNegotiation.cs
- TextElementEnumerator.cs
- MessageSmuggler.cs
- Point3DIndependentAnimationStorage.cs
- SerializationSectionGroup.cs
- DataGridViewCellCancelEventArgs.cs
- Trace.cs
- Visual3D.cs
- HttpCachePolicy.cs
- ArrayHelper.cs
- ObjectTag.cs
- InvokeHandlers.cs
- Cloud.cs
- InvalidPropValue.cs
- BinaryUtilClasses.cs
- PageContentAsyncResult.cs
- StateMachineAction.cs
- util.cs
- PrePostDescendentsWalker.cs
- WindowsScroll.cs
- DBBindings.cs
- ValidationErrorCollection.cs
- AuthenticationModulesSection.cs
- CatalogPart.cs
- PageContentAsyncResult.cs
- Visual.cs
- WebCodeGenerator.cs
- DataGridViewTextBoxColumn.cs
- TransformedBitmap.cs
- XmlCDATASection.cs
- TableRow.cs
- TemplateKey.cs
- WindowsTooltip.cs
- TextSelectionProcessor.cs
- LinkArea.cs
- ReferenceService.cs
- ToolStripContainerActionList.cs
- LabelLiteral.cs
- PasswordBoxAutomationPeer.cs
- TimeManager.cs
- Int16Animation.cs
- DataControlFieldCollection.cs
- HttpRawResponse.cs
- ProcessInputEventArgs.cs
- DecimalAnimationBase.cs
- ReaderContextStackData.cs
- ListSourceHelper.cs
- DLinqColumnProvider.cs
- ActivityIdHeader.cs
- WebPartDescription.cs
- FormsAuthenticationUser.cs
- LogicalMethodInfo.cs
- PerformanceCounterNameAttribute.cs
- DataGridViewAutoSizeModeEventArgs.cs
- BlockUIContainer.cs
- IdnMapping.cs
- ValidationException.cs
- XmlSchemas.cs
- CodeDesigner.cs
- TickBar.cs
- XmlLoader.cs
- InheritanceContextHelper.cs
- SubpageParaClient.cs
- Utils.cs
- VisualBasicHelper.cs
- CodeLinePragma.cs
- NumberSubstitution.cs
- DesignTimeValidationFeature.cs
- SystemColorTracker.cs
- GreenMethods.cs
- LeaseManager.cs
- EmptyEnumerator.cs
- SynchronousChannel.cs
- SqlSelectClauseBuilder.cs
- CustomValidator.cs
- NetworkInterface.cs
- TabletCollection.cs
- Annotation.cs
- DataControlField.cs
- DataGridViewCell.cs
- IMembershipProvider.cs
- AccessibleObject.cs
- ReflectionServiceProvider.cs
- GridViewSelectEventArgs.cs
- InputMethodStateChangeEventArgs.cs
- Model3D.cs
- HttpEncoder.cs
- ipaddressinformationcollection.cs
- NativeMethods.cs
- Int32RectValueSerializer.cs
- SynchronousReceiveBehavior.cs
- DrawingVisual.cs