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
- IntSecurity.cs
- Matrix3DStack.cs
- ModelVisual3D.cs
- DeploymentExceptionMapper.cs
- PointUtil.cs
- HyperLinkStyle.cs
- Stylus.cs
- LoginUtil.cs
- ClientConfigurationHost.cs
- XPathMultyIterator.cs
- AutomationEvent.cs
- Rect.cs
- ShimAsPublicXamlType.cs
- xamlnodes.cs
- ControlParameter.cs
- NativeMethods.cs
- BookmarkUndoUnit.cs
- BookmarkCallbackWrapper.cs
- DrawingAttributesDefaultValueFactory.cs
- ImageField.cs
- SiteMapSection.cs
- ObjectPropertyMapping.cs
- FormCollection.cs
- LiteralControl.cs
- Tile.cs
- OrderedDictionary.cs
- SqlBulkCopyColumnMapping.cs
- BitmapFrameDecode.cs
- NetworkStream.cs
- RotationValidation.cs
- WindowsFormsSectionHandler.cs
- StyleXamlTreeBuilder.cs
- Blend.cs
- JsonCollectionDataContract.cs
- ByteConverter.cs
- DateTimeParse.cs
- TimeSpanMinutesOrInfiniteConverter.cs
- RootProjectionNode.cs
- DynamicQueryableWrapper.cs
- ScaleTransform3D.cs
- ThemeDirectoryCompiler.cs
- XamlInt32CollectionSerializer.cs
- ListViewCancelEventArgs.cs
- DummyDataSource.cs
- DefaultPropertyAttribute.cs
- GeometryConverter.cs
- NameValueFileSectionHandler.cs
- XsltFunctions.cs
- CounterSampleCalculator.cs
- SectionVisual.cs
- SqlVisitor.cs
- PriorityBinding.cs
- WebDescriptionAttribute.cs
- SubtreeProcessor.cs
- XmlILModule.cs
- ButtonAutomationPeer.cs
- TripleDES.cs
- SspiSecurityTokenProvider.cs
- IntegerCollectionEditor.cs
- JapaneseLunisolarCalendar.cs
- ElasticEase.cs
- DataGridItem.cs
- RuleProcessor.cs
- StringExpressionSet.cs
- XmlAutoDetectWriter.cs
- SignatureGenerator.cs
- CodeChecksumPragma.cs
- WorkflowViewElement.cs
- LinkTarget.cs
- FilterException.cs
- OdbcUtils.cs
- WebPartPersonalization.cs
- NotFiniteNumberException.cs
- GroupBox.cs
- _HTTPDateParse.cs
- GC.cs
- SettingsSavedEventArgs.cs
- SessionStateModule.cs
- WebErrorHandler.cs
- Int16Converter.cs
- VisualBasicHelper.cs
- LicenseContext.cs
- SafeFileMappingHandle.cs
- Timeline.cs
- TextBoxLine.cs
- TextElementEnumerator.cs
- PeerNameRecordCollection.cs
- RowSpanVector.cs
- UiaCoreApi.cs
- ListenerConfig.cs
- BaseParaClient.cs
- OptimizedTemplateContent.cs
- SystemResources.cs
- Int32RectConverter.cs
- ObjectToIdCache.cs
- ControlCachePolicy.cs
- CodeAttributeArgumentCollection.cs
- BackStopAuthenticationModule.cs
- SchemaLookupTable.cs
- XsltException.cs