Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Activation / HostedNamedPipeTransportManager.cs / 1 / HostedNamedPipeTransportManager.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Activation { using System.Collections.Generic; using System.Diagnostics; using System.ServiceModel; using System.ServiceModel.Channels; using System.ServiceModel.Diagnostics; class HostedNamedPipeTransportManager : NamedPipeTransportManager { bool settingsApplied; OnViaDelegate onViaCallback; SharedConnectionListener listener; ConnectionDemuxer connectionDemuxer; int queueId; Guid token; OnDuplicatedViaDelegate onDuplicatedViaCallback; bool demuxerCreated; public HostedNamedPipeTransportManager(BaseUriWithWildcard baseAddress) : base(baseAddress.BaseAddress) { this.HostNameComparisonMode = baseAddress.HostNameComparisonMode; this.onViaCallback = new OnViaDelegate(OnVia); this.onDuplicatedViaCallback = new OnDuplicatedViaDelegate(OnDuplicatedVia); } protected override bool IsCompatible(NamedPipeChannelListener channelListener) { if (channelListener.HostedVirtualPath == null) { return false; } return base.IsCompatible(channelListener); } internal void Start(int queueId, Guid token, MessageReceivedCallback messageReceivedCallback) { SetMessageReceivedCallback(messageReceivedCallback); OnOpenInternal(queueId, token); } internal override void OnOpen() { // This is intentionally empty. } internal void Stop() { lock (ThisLock) { if (listener != null) { listener.Stop(); // The listener will be closed by the demuxer. listener = null; } if (connectionDemuxer != null) { connectionDemuxer.Dispose(); } demuxerCreated = false; settingsApplied = false; } } void CreateConnectionDemuxer() { IConnectionListener connectionListener = new BufferedConnectionListener(listener, MaxOutputDelay, ConnectionBufferSize); if (DiagnosticUtility.ShouldUseActivity) { connectionListener = new TracingConnectionListener(connectionListener, this.ListenUri); } connectionDemuxer = new ConnectionDemuxer(connectionListener, MaxPendingAccepts, MaxPendingConnections, ChannelInitializationTimeout, IdleTimeout, MaxPooledConnections, OnGetTransportFactorySettings, OnGetSingletonMessageHandler, OnHandleServerSessionPreamble, OnDemuxerError); connectionDemuxer.StartDemuxing(onViaCallback); } void OnOpenInternal(int queueId, Guid token) { lock (ThisLock) { this.queueId = queueId; this.token = token; BaseUriWithWildcard path = new BaseUriWithWildcard(this.ListenUri, this.HostNameComparisonMode); listener = new SharedConnectionListener(path, queueId, token, this.onDuplicatedViaCallback); } } internal override void OnClose() { Stop(); base.OnClose(); } void OnVia(Uri address) { Debug.Print("HostedNamedPipeTransportManager.OnVia() address: " + address + " calling EnsureServiceAvailable()"); ServiceHostingEnvironment.EnsureServiceAvailable(address.LocalPath); } protected override void OnSelecting(NamedPipeChannelListener channelListener) { if (settingsApplied) { return; } lock (ThisLock) { if (settingsApplied) { // Use the setting for the first one. return; } this.ApplyListenerSettings(channelListener); settingsApplied = true; } } // This method is called only for the first via of the current proxy. void OnDuplicatedVia(Uri via, out int connectionBufferSize) { OnVia(via); if (!demuxerCreated) { lock (ThisLock) { if (listener == null) { // The listener has been stopped. throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationObjectAbortedException( SR.GetString(SR.Sharing_ListenerProxyStopped))); } if (!demuxerCreated) { CreateConnectionDemuxer(); demuxerCreated = true; } } } connectionBufferSize = this.ConnectionBufferSize; } } } // 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
- NonBatchDirectoryCompiler.cs
- QilParameter.cs
- DbConnectionPoolGroup.cs
- AtomEntry.cs
- QueryAccessibilityHelpEvent.cs
- ErrorHandlerModule.cs
- SQLDateTimeStorage.cs
- FontClient.cs
- ErrorInfoXmlDocument.cs
- OleDbConnectionFactory.cs
- ReadWriteObjectLock.cs
- Ref.cs
- xmlfixedPageInfo.cs
- SqlCacheDependencyDatabaseCollection.cs
- BulletedList.cs
- CheckBoxStandardAdapter.cs
- NamespaceQuery.cs
- AssemblyName.cs
- InsufficientMemoryException.cs
- AutoResizedEvent.cs
- SourceFileBuildProvider.cs
- ContextMenu.cs
- CompositeActivityTypeDescriptor.cs
- TextEditorParagraphs.cs
- Transform.cs
- RecognizerInfo.cs
- SamlAttribute.cs
- Currency.cs
- UnmanagedMemoryStreamWrapper.cs
- WindowsRichEditRange.cs
- TextSimpleMarkerProperties.cs
- FormViewModeEventArgs.cs
- FamilyCollection.cs
- TextProviderWrapper.cs
- CodeDomDesignerLoader.cs
- GroupQuery.cs
- mediaeventshelper.cs
- DataIdProcessor.cs
- ScriptReferenceBase.cs
- EmbossBitmapEffect.cs
- PersonalizationProvider.cs
- ListBindingConverter.cs
- ThreadAttributes.cs
- RelationshipEndCollection.cs
- FontStyle.cs
- XPathBuilder.cs
- StringPropertyBuilder.cs
- SvcMapFile.cs
- FileDialog.cs
- Models.cs
- controlskin.cs
- RestrictedTransactionalPackage.cs
- SystemIPInterfaceProperties.cs
- BuildProvidersCompiler.cs
- CqlIdentifiers.cs
- OdbcStatementHandle.cs
- OdbcCommandBuilder.cs
- TdsParameterSetter.cs
- InputElement.cs
- Preprocessor.cs
- ExpressionVisitor.cs
- SessionState.cs
- ObservableCollection.cs
- GregorianCalendarHelper.cs
- ImageListUtils.cs
- SelectionEditor.cs
- ListControlDataBindingHandler.cs
- HTMLTagNameToTypeMapper.cs
- ViewPort3D.cs
- ClientApiGenerator.cs
- DrawListViewColumnHeaderEventArgs.cs
- TcpStreams.cs
- ApplicationContext.cs
- CookieProtection.cs
- CustomErrorsSectionWrapper.cs
- SqlVisitor.cs
- DataGridViewEditingControlShowingEventArgs.cs
- ListViewGroupCollectionEditor.cs
- GeometryGroup.cs
- WebRequestModuleElement.cs
- KeyPullup.cs
- NullableIntSumAggregationOperator.cs
- DefaultObjectSerializer.cs
- DoWorkEventArgs.cs
- RangeValuePattern.cs
- CharEntityEncoderFallback.cs
- WebPartVerb.cs
- OleDbReferenceCollection.cs
- BaseTemplateBuildProvider.cs
- DeclarativeCatalogPart.cs
- IERequestCache.cs
- ListSortDescriptionCollection.cs
- AuthenticationSchemesHelper.cs
- ObjectDataSourceMethodEventArgs.cs
- XmlSerializerOperationBehavior.cs
- PrintDialogException.cs
- ParameterExpression.cs
- EntityDataSourceSelectingEventArgs.cs
- GorillaCodec.cs
- BuildProvidersCompiler.cs