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
- TextSerializer.cs
- ToolStripRenderer.cs
- FusionWrap.cs
- ComMethodElement.cs
- ListViewDeleteEventArgs.cs
- PagePropertiesChangingEventArgs.cs
- OdbcConnectionString.cs
- Thread.cs
- MinMaxParagraphWidth.cs
- Pen.cs
- ControlAdapter.cs
- QueryTask.cs
- ChangeProcessor.cs
- DataListItemCollection.cs
- FileNotFoundException.cs
- SHA384.cs
- DtdParser.cs
- DataBoundControlHelper.cs
- XmlSerializableReader.cs
- SafeCryptoKeyHandle.cs
- ProfilePropertySettings.cs
- ComPlusInstanceProvider.cs
- OdbcDataReader.cs
- ConstantSlot.cs
- WebResponse.cs
- DotAtomReader.cs
- RbTree.cs
- DataGridViewDesigner.cs
- SafeNativeMethods.cs
- ToolStripItemClickedEventArgs.cs
- XmlSchemaRedefine.cs
- XmlReturnWriter.cs
- Baml2006KeyRecord.cs
- ConnectionStringsExpressionBuilder.cs
- XmlDocumentFragment.cs
- ISessionStateStore.cs
- XmlAttributes.cs
- MemberMemberBinding.cs
- BmpBitmapDecoder.cs
- X509Utils.cs
- PhysicalAddress.cs
- SqlDependencyUtils.cs
- BamlStream.cs
- ArithmeticException.cs
- LicenseException.cs
- StateMachineHelpers.cs
- SatelliteContractVersionAttribute.cs
- GlyphInfoList.cs
- COM2TypeInfoProcessor.cs
- TraceHwndHost.cs
- JsonReader.cs
- RtfToXamlLexer.cs
- Int64KeyFrameCollection.cs
- DataGridViewColumnDesigner.cs
- ClientConfigurationSystem.cs
- OperationAbortedException.cs
- TemplateAction.cs
- EventProxy.cs
- KeySpline.cs
- ExceptionHelpers.cs
- ParserHooks.cs
- EventProviderWriter.cs
- XmlSchemaGroup.cs
- Int32.cs
- IndentedWriter.cs
- CompilationAssemblyInstallComponent.cs
- AddInContractAttribute.cs
- ClientSettingsStore.cs
- ListView.cs
- SqlUserDefinedAggregateAttribute.cs
- BehaviorEditorPart.cs
- OleDbWrapper.cs
- ViewGenerator.cs
- XmlChildEnumerator.cs
- XmlBinaryWriterSession.cs
- DateTimeFormat.cs
- Util.cs
- TextPenaltyModule.cs
- VisualStyleInformation.cs
- ParallelRangeManager.cs
- GZipDecoder.cs
- EpmContentDeSerializer.cs
- ProxyWebPart.cs
- BamlLocalizer.cs
- TreeIterator.cs
- WorkflowApplicationCompletedException.cs
- CodeCompileUnit.cs
- OdbcFactory.cs
- SQLBinaryStorage.cs
- MsmqHostedTransportConfiguration.cs
- HTTPNotFoundHandler.cs
- DataGridViewHeaderCell.cs
- DashStyles.cs
- BigIntegerStorage.cs
- TableCellCollection.cs
- Restrictions.cs
- SqlInternalConnectionTds.cs
- Timer.cs
- XmlMapping.cs
- AppendHelper.cs