Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / TransactionChannelFactory.cs / 1 / TransactionChannelFactory.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System.ServiceModel; using System.ServiceModel.Description; using System.Collections.Generic; using System.Transactions; using System.ServiceModel.Transactions; using System.ServiceModel.Security; using SR=System.ServiceModel.SR; sealed class TransactionChannelFactory: LayeredChannelFactory , ITransactionChannelManager { TransactionFlowOption flowIssuedTokens; SecurityStandardsManager standardsManager; Dictionary dictionary; TransactionProtocol transactionProtocol; public TransactionChannelFactory( TransactionProtocol transactionProtocol, BindingContext context, Dictionary dictionary) : base(context.Binding, context.BuildInnerChannelFactory ()) { this.dictionary = dictionary; this.TransactionProtocol = transactionProtocol; this.standardsManager = SecurityStandardsHelper.CreateStandardsManager(this.TransactionProtocol); } public TransactionProtocol TransactionProtocol { get { return this.transactionProtocol; } set { if (!TransactionProtocol.IsDefined(value)) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentException(SR.GetString(SR.SFxBadTransactionProtocols))); this.transactionProtocol = value; } } public TransactionFlowOption FlowIssuedTokens { get { return this.flowIssuedTokens; } set { this.flowIssuedTokens = value; } } public SecurityStandardsManager StandardsManager { get { return this.standardsManager; } set { this.standardsManager = (value != null ? value : SecurityStandardsHelper.CreateStandardsManager(this.transactionProtocol)); } } public IDictionary Dictionary { get { return this.dictionary; } } public TransactionFlowOption GetTransaction(MessageDirection direction, string action) { TransactionFlowOption txOption; if (!dictionary.TryGetValue(new DirectionalAction(direction, action), out txOption)) return TransactionFlowOption.NotAllowed; else return txOption; } protected override TChannel OnCreateChannel(EndpointAddress remoteAddress, Uri via) { TChannel innerChannel = ((IChannelFactory )InnerChannelFactory).CreateChannel(remoteAddress, via); return CreateTransactionChannel(innerChannel); } TChannel CreateTransactionChannel(TChannel innerChannel) { if (typeof(TChannel) == typeof(IDuplexSessionChannel)) { return (TChannel)(object) new TransactionDuplexSessionChannel(this, (IDuplexSessionChannel)(object)innerChannel); } else if (typeof(TChannel) == typeof(IRequestSessionChannel)) { return (TChannel)(object) new TransactionRequestSessionChannel(this, (IRequestSessionChannel)(object)innerChannel); } else if (typeof(TChannel) == typeof(IOutputSessionChannel)) { return (TChannel)(object) new TransactionOutputSessionChannel(this, (IOutputSessionChannel)(object)innerChannel); } else if (typeof(TChannel) == typeof(IOutputChannel)) { return (TChannel)(object) new TransactionOutputChannel(this, (IOutputChannel)(object)innerChannel); } else if (typeof(TChannel) == typeof(IRequestChannel)) { return (TChannel)(object) new TransactionRequestChannel(this, (IRequestChannel)(object)innerChannel); } else if (typeof(TChannel) == typeof(IDuplexChannel)) { return (TChannel)(object) new TransactionDuplexChannel(this, (IDuplexChannel)(object)innerChannel); } else { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateChannelTypeNotSupportedException(typeof(TChannel))); } } //=========================================================== // Transaction Output Channel classes //=========================================================== sealed class TransactionOutputChannel : TransactionOutputChannelGeneric { public TransactionOutputChannel(ChannelManagerBase channelManager, IOutputChannel innerChannel) : base(channelManager, innerChannel) { } } sealed class TransactionRequestChannel : TransactionRequestChannelGeneric { public TransactionRequestChannel(ChannelManagerBase channelManager, IRequestChannel innerChannel) : base(channelManager, innerChannel) { } } sealed class TransactionDuplexChannel : TransactionOutputDuplexChannelGeneric { public TransactionDuplexChannel(ChannelManagerBase channelManager, IDuplexChannel innerChannel) : base(channelManager, innerChannel) { } } sealed class TransactionOutputSessionChannel : TransactionOutputChannelGeneric , IOutputSessionChannel { public TransactionOutputSessionChannel(ChannelManagerBase channelManager, IOutputSessionChannel innerChannel) : base(channelManager, innerChannel) { } public IOutputSession Session { get { return InnerChannel.Session; } } } sealed class TransactionRequestSessionChannel : TransactionRequestChannelGeneric , IRequestSessionChannel { public TransactionRequestSessionChannel(ChannelManagerBase channelManager, IRequestSessionChannel innerChannel) : base(channelManager, innerChannel) { } public IOutputSession Session { get { return InnerChannel.Session; } } } sealed class TransactionDuplexSessionChannel : TransactionOutputDuplexChannelGeneric , IDuplexSessionChannel { public TransactionDuplexSessionChannel(ChannelManagerBase channelManager, IDuplexSessionChannel innerChannel) : base(channelManager, innerChannel) { } public IDuplexSession Session { get { return InnerChannel.Session; } } } } static class SecurityStandardsHelper { static SecurityStandardsManager SecurityStandardsManager2007 = CreateStandardsManager(MessageSecurityVersion.WSSecurity11WSTrust13WSSecureConversation13WSSecurityPolicy12); static SecurityStandardsManager CreateStandardsManager(MessageSecurityVersion securityVersion) { return new SecurityStandardsManager( securityVersion, new WSSecurityTokenSerializer(securityVersion.SecurityVersion, securityVersion.TrustVersion, securityVersion.SecureConversationVersion, false, null, null, null)); } public static SecurityStandardsManager CreateStandardsManager(TransactionProtocol transactionProtocol) { if (transactionProtocol == TransactionProtocol.WSAtomicTransactionOctober2004 || transactionProtocol == TransactionProtocol.OleTransactions) { return SecurityStandardsManager.DefaultInstance; } else { return SecurityStandardsHelper.SecurityStandardsManager2007; } } } //============================================================== // Transaction channel base generic classes //============================================================= class TransactionOutputChannelGeneric : TransactionChannel , IOutputChannel where TChannel : class, IOutputChannel { public TransactionOutputChannelGeneric(ChannelManagerBase channelManager, TChannel innerChannel) : base(channelManager, innerChannel) { } public EndpointAddress RemoteAddress { get { return InnerChannel.RemoteAddress; } } public Uri Via { get { return InnerChannel.Via; } } public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) { return this.BeginSend(message, this.DefaultSendTimeout, callback, state); } public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); WriteTransactionDataToMessage(message, MessageDirection.Input); return InnerChannel.BeginSend(message, timeoutHelper.RemainingTime(), asyncCallback, state); } public void EndSend(IAsyncResult result) { InnerChannel.EndSend(result); } public void Send(Message message) { this.Send(message, this.DefaultSendTimeout); } public void Send(Message message, TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); WriteTransactionDataToMessage(message, MessageDirection.Input); InnerChannel.Send(message, timeoutHelper.RemainingTime()); } } class TransactionRequestChannelGeneric : TransactionChannel , IRequestChannel where TChannel : class, IRequestChannel { public TransactionRequestChannelGeneric(ChannelManagerBase channelManager, TChannel innerChannel) : base(channelManager, innerChannel) { } public EndpointAddress RemoteAddress { get { return InnerChannel.RemoteAddress; } } public Uri Via { get { return InnerChannel.Via; } } public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) { return this.BeginRequest(message, this.DefaultSendTimeout, callback, state); } public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); WriteTransactionDataToMessage(message, MessageDirection.Input); return InnerChannel.BeginRequest(message, timeoutHelper.RemainingTime(), asyncCallback, state); } public Message EndRequest(IAsyncResult result) { Message reply = InnerChannel.EndRequest(result); if (reply != null) this.ReadIssuedTokens(reply, MessageDirection.Output); return reply; } public Message Request(Message message) { return this.Request(message, this.DefaultSendTimeout); } public Message Request(Message message, TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); WriteTransactionDataToMessage(message, MessageDirection.Input); Message reply = InnerChannel.Request(message, timeoutHelper.RemainingTime()); if (reply != null) this.ReadIssuedTokens(reply, MessageDirection.Output); return reply; } } class TransactionOutputDuplexChannelGeneric : TransactionDuplexChannelGeneric where TChannel : class, IDuplexChannel { public TransactionOutputDuplexChannelGeneric(ChannelManagerBase channelManager, TChannel innerChannel) : base(channelManager, innerChannel, MessageDirection.Output) { } } } // 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
- RepeaterCommandEventArgs.cs
- TimeStampChecker.cs
- FieldBuilder.cs
- HitTestParameters3D.cs
- ProxyAttribute.cs
- LinkedResourceCollection.cs
- CompilationLock.cs
- _ListenerRequestStream.cs
- LowerCaseStringConverter.cs
- HelpInfo.cs
- DataObjectEventArgs.cs
- EventListener.cs
- InternalEnumValidatorAttribute.cs
- HGlobalSafeHandle.cs
- SystemResourceKey.cs
- LinkedResource.cs
- PassportAuthenticationModule.cs
- EntitySetBaseCollection.cs
- DataSetViewSchema.cs
- ProfileSettingsCollection.cs
- _LoggingObject.cs
- WebBrowserDocumentCompletedEventHandler.cs
- _ConnectStream.cs
- EditorAttributeInfo.cs
- _CookieModule.cs
- CodeDirectoryCompiler.cs
- XmlSchemaComplexContentExtension.cs
- CreateRefExpr.cs
- AnyAllSearchOperator.cs
- ErrorStyle.cs
- QuestionEventArgs.cs
- StorageModelBuildProvider.cs
- ContextDataSource.cs
- RectConverter.cs
- MouseGesture.cs
- OleDbInfoMessageEvent.cs
- BitmapImage.cs
- RightsManagementInformation.cs
- LocationUpdates.cs
- log.cs
- TaskExceptionHolder.cs
- ViewBox.cs
- Pen.cs
- CounterSetInstance.cs
- LinqDataSourceDisposeEventArgs.cs
- ProfilePropertySettings.cs
- DataGridViewElement.cs
- Stopwatch.cs
- MarkupProperty.cs
- FileAuthorizationModule.cs
- MarkupObject.cs
- AsyncPostBackTrigger.cs
- Accessible.cs
- OutputScopeManager.cs
- _LocalDataStoreMgr.cs
- QueryableDataSourceEditData.cs
- StylusPointPropertyUnit.cs
- AttachedAnnotation.cs
- PtsPage.cs
- MembershipSection.cs
- ConsoleTraceListener.cs
- StartUpEventArgs.cs
- ContainerFilterService.cs
- SiteIdentityPermission.cs
- DataGridViewRowHeaderCell.cs
- FirstQueryOperator.cs
- FacetDescriptionElement.cs
- TextEmbeddedObject.cs
- BitmapPalettes.cs
- SizeAnimationUsingKeyFrames.cs
- MenuAutomationPeer.cs
- UserUseLicenseDictionaryLoader.cs
- ProfileServiceManager.cs
- UnhandledExceptionEventArgs.cs
- CommandValueSerializer.cs
- CodeEventReferenceExpression.cs
- Query.cs
- WindowsGraphics2.cs
- SafeNativeMethods.cs
- GeometryCombineModeValidation.cs
- TextRenderer.cs
- QilFunction.cs
- CacheAxisQuery.cs
- HttpInputStream.cs
- BulletChrome.cs
- COAUTHIDENTITY.cs
- SerializationStore.cs
- RowToParametersTransformer.cs
- ConfigurationLocationCollection.cs
- RegisteredExpandoAttribute.cs
- webproxy.cs
- RankException.cs
- loginstatus.cs
- DataGridViewTextBoxEditingControl.cs
- DataGridViewEditingControlShowingEventArgs.cs
- CodeDomLoader.cs
- validation.cs
- BamlStream.cs
- EditBehavior.cs
- StandardOleMarshalObject.cs