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
- RelatedView.cs
- CultureInfoConverter.cs
- loginstatus.cs
- Mapping.cs
- TextBox.cs
- ParamArrayAttribute.cs
- PublisherIdentityPermission.cs
- CancelEventArgs.cs
- GraphicsState.cs
- PartialList.cs
- _OverlappedAsyncResult.cs
- printdlgexmarshaler.cs
- FontStretch.cs
- LoginName.cs
- NestPullup.cs
- dataprotectionpermission.cs
- DCSafeHandle.cs
- MediaElement.cs
- XPathNodeList.cs
- ErrorReporting.cs
- ApplicationServicesHostFactory.cs
- DbConnectionPoolGroup.cs
- TimestampInformation.cs
- HttpResponse.cs
- HWStack.cs
- assertwrapper.cs
- DataViewListener.cs
- Root.cs
- DeobfuscatingStream.cs
- HttpRuntime.cs
- SqlStatistics.cs
- DataSourceGeneratorException.cs
- SharedPerformanceCounter.cs
- ColumnHeader.cs
- TransformerConfigurationWizardBase.cs
- ImpersonateTokenRef.cs
- DataGridTableStyleMappingNameEditor.cs
- DataServiceConfiguration.cs
- DecimalAnimationUsingKeyFrames.cs
- TransformedBitmap.cs
- RuntimeIdentifierPropertyAttribute.cs
- _UriTypeConverter.cs
- AttributeCollection.cs
- _NativeSSPI.cs
- SchemaUtility.cs
- ForwardPositionQuery.cs
- Privilege.cs
- LayoutDump.cs
- AssemblyName.cs
- DesignTimeType.cs
- SchemaImporterExtension.cs
- ActivationWorker.cs
- Image.cs
- DataViewListener.cs
- Internal.cs
- MarkedHighlightComponent.cs
- CookielessHelper.cs
- HttpWebRequestElement.cs
- DataBoundControlAdapter.cs
- HttpPostedFile.cs
- MediaEntryAttribute.cs
- SpoolingTaskBase.cs
- ObjectListField.cs
- MultiView.cs
- UserControlDocumentDesigner.cs
- DocumentPageHost.cs
- RootDesignerSerializerAttribute.cs
- ResourceManager.cs
- VectorAnimation.cs
- Block.cs
- SystemWebCachingSectionGroup.cs
- StatusBarItem.cs
- OleDbErrorCollection.cs
- HandlerBase.cs
- RoleService.cs
- TaiwanCalendar.cs
- StylusCollection.cs
- NopReturnReader.cs
- HiddenFieldPageStatePersister.cs
- IUnknownConstantAttribute.cs
- sortedlist.cs
- SqlNotificationEventArgs.cs
- IMembershipProvider.cs
- EventProviderBase.cs
- SchemaNames.cs
- ListViewDataItem.cs
- ProfileGroupSettingsCollection.cs
- EdmItemError.cs
- Int64AnimationBase.cs
- AssemblyBuilder.cs
- SiteMapNodeItemEventArgs.cs
- DbSetClause.cs
- ExpanderAutomationPeer.cs
- AutomationElementCollection.cs
- IntegerValidator.cs
- TagMapCollection.cs
- FixedPageAutomationPeer.cs
- GridViewDeletedEventArgs.cs
- NativeMethods.cs
- ServiceModelConfiguration.cs