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
- HttpException.cs
- DefaultValueTypeConverter.cs
- ParameterCollection.cs
- IEnumerable.cs
- KeyManager.cs
- StoreAnnotationsMap.cs
- URIFormatException.cs
- InvalidPrinterException.cs
- NegotiateStream.cs
- Style.cs
- WindowsIdentity.cs
- Dispatcher.cs
- DragDrop.cs
- ObjRef.cs
- HierarchicalDataBoundControl.cs
- OptimizerPatterns.cs
- NameTable.cs
- DataGridViewDesigner.cs
- XmlAnyAttributeAttribute.cs
- PtsPage.cs
- StylusPointPropertyInfoDefaults.cs
- SqlNotificationEventArgs.cs
- ClientBuildManagerCallback.cs
- cookiecontainer.cs
- TraceContextEventArgs.cs
- TreeViewItem.cs
- XmlArrayAttribute.cs
- FrameAutomationPeer.cs
- UserControlDocumentDesigner.cs
- SchemaExporter.cs
- SystemInfo.cs
- LicenseException.cs
- WorkflowServiceHostFactory.cs
- FileUtil.cs
- Context.cs
- Avt.cs
- ConsumerConnectionPoint.cs
- NonClientArea.cs
- TrustLevel.cs
- MULTI_QI.cs
- BaseProcessProtocolHandler.cs
- XmlNodeChangedEventArgs.cs
- DSASignatureFormatter.cs
- RootBrowserWindow.cs
- SymbolEqualComparer.cs
- TimeEnumHelper.cs
- MenuAdapter.cs
- BamlRecordReader.cs
- Attributes.cs
- X509UI.cs
- RelationshipManager.cs
- CanExecuteRoutedEventArgs.cs
- ConnectionsZone.cs
- CodeAttributeArgument.cs
- SingleTagSectionHandler.cs
- NameValueSectionHandler.cs
- updateconfighost.cs
- CachedRequestParams.cs
- DataBindingCollection.cs
- EmptyEnumerator.cs
- log.cs
- CryptoStream.cs
- EdmScalarPropertyAttribute.cs
- UrlPath.cs
- HashMembershipCondition.cs
- MethodBuilderInstantiation.cs
- DnsPermission.cs
- SharedStatics.cs
- OleDbWrapper.cs
- ToolStripPanelRenderEventArgs.cs
- StrongNameUtility.cs
- SafeProcessHandle.cs
- RTLAwareMessageBox.cs
- RequiredAttributeAttribute.cs
- ObjectQueryProvider.cs
- ErrorReporting.cs
- LeftCellWrapper.cs
- SqlBooleanMismatchVisitor.cs
- sqlmetadatafactory.cs
- CustomErrorCollection.cs
- DataKey.cs
- CreateDataSourceDialog.cs
- SocketAddress.cs
- Timeline.cs
- SerializerProvider.cs
- DataContractSerializer.cs
- StorageMappingItemCollection.cs
- ToolStripLabel.cs
- Pen.cs
- WindowsTooltip.cs
- ServiceX509SecurityTokenProvider.cs
- HttpHandlersSection.cs
- FileCodeGroup.cs
- SqlWorkflowInstanceStoreLock.cs
- Interop.cs
- StorageTypeMapping.cs
- DictionaryEditChange.cs
- SchemaObjectWriter.cs
- typedescriptorpermissionattribute.cs
- XmlValidatingReaderImpl.cs