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
- ToggleButton.cs
- LicenseException.cs
- QueryInterceptorAttribute.cs
- WsdlServiceChannelBuilder.cs
- InputMethodStateTypeInfo.cs
- InternalBufferOverflowException.cs
- NameSpaceEvent.cs
- AdjustableArrowCap.cs
- SqlLiftWhereClauses.cs
- Array.cs
- DataControlFieldCollection.cs
- DbConnectionPoolOptions.cs
- InfoCardSymmetricCrypto.cs
- MailMessage.cs
- ObjectPropertyMapping.cs
- updateconfighost.cs
- ReceiveMessageRecord.cs
- ClientFormsAuthenticationCredentials.cs
- GridViewColumnHeader.cs
- SecurityProtocol.cs
- DataFormats.cs
- FixUpCollection.cs
- XmlSchemas.cs
- ConfigurationManagerHelper.cs
- _HeaderInfo.cs
- XmlSchemaDatatype.cs
- ReliableSessionBindingElement.cs
- WebPartExportVerb.cs
- TraceHandler.cs
- SafeHandles.cs
- SpecialFolderEnumConverter.cs
- KeyedCollection.cs
- PropertyAccessVisitor.cs
- MatrixTransform.cs
- WindowsTokenRoleProvider.cs
- DataReceivedEventArgs.cs
- PagedDataSource.cs
- DbProviderFactory.cs
- GradientStop.cs
- EdmRelationshipRoleAttribute.cs
- shaperfactoryquerycachekey.cs
- XsltLoader.cs
- Comparer.cs
- ControlCollection.cs
- DoubleConverter.cs
- DockPanel.cs
- SimpleHandlerFactory.cs
- RequestResizeEvent.cs
- RelationalExpressions.cs
- CompModHelpers.cs
- CodeBinaryOperatorExpression.cs
- SoapCodeExporter.cs
- OracleParameter.cs
- GlyphElement.cs
- TreeWalkHelper.cs
- StateManager.cs
- FormClosingEvent.cs
- XsltContext.cs
- DataGridViewCellMouseEventArgs.cs
- MessageQueueEnumerator.cs
- Descriptor.cs
- Util.cs
- ReadOnlyDataSource.cs
- ContentType.cs
- SharedPersonalizationStateInfo.cs
- ReflectionUtil.cs
- BuildResult.cs
- WindowsListViewItemStartMenu.cs
- TraceSwitch.cs
- ParameterCollection.cs
- SeekableReadStream.cs
- CodeArrayCreateExpression.cs
- Rect3D.cs
- HttpCapabilitiesSectionHandler.cs
- ColorTranslator.cs
- MetadataUtilsSmi.cs
- TraversalRequest.cs
- Journaling.cs
- TypeConverterValueSerializer.cs
- HtmlValidationSummaryAdapter.cs
- CompositeDataBoundControl.cs
- InfoCardRSACryptoProvider.cs
- SectionInput.cs
- CodeArgumentReferenceExpression.cs
- CuspData.cs
- FormView.cs
- Int32Rect.cs
- ListViewInsertEventArgs.cs
- HttpCapabilitiesEvaluator.cs
- SqlCacheDependency.cs
- Binding.cs
- SubstitutionList.cs
- unsafeIndexingFilterStream.cs
- AppModelKnownContentFactory.cs
- DbMetaDataCollectionNames.cs
- CroppedBitmap.cs
- CipherData.cs
- EnumType.cs
- TraceContextRecord.cs
- RequestResizeEvent.cs