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
- ResourceIDHelper.cs
- shaperfactory.cs
- EraserBehavior.cs
- SafeNativeMethodsMilCoreApi.cs
- dbenumerator.cs
- TextBox.cs
- ScaleTransform3D.cs
- SkipStoryboardToFill.cs
- KnownBoxes.cs
- AxHost.cs
- BufferedGraphicsManager.cs
- ChildrenQuery.cs
- ListViewEditEventArgs.cs
- StringArrayConverter.cs
- MaxSessionCountExceededException.cs
- IndicCharClassifier.cs
- MediaTimeline.cs
- TextPointer.cs
- ToolStripComboBox.cs
- UInt32Storage.cs
- DispatcherFrame.cs
- SimpleWebHandlerParser.cs
- LinkConverter.cs
- HttpsTransportBindingElement.cs
- DataGridViewMethods.cs
- GetWinFXPath.cs
- XomlCompiler.cs
- VisualBrush.cs
- RunInstallerAttribute.cs
- RelatedEnd.cs
- BufferModesCollection.cs
- URLAttribute.cs
- ToolStripArrowRenderEventArgs.cs
- DesignTimeTemplateParser.cs
- ProtocolsConfigurationEntry.cs
- MediaContextNotificationWindow.cs
- BitStream.cs
- InternalBufferOverflowException.cs
- SafeFileHandle.cs
- SQLResource.cs
- formatter.cs
- MenuItemCollection.cs
- MessageSmuggler.cs
- DataGridViewColumnDesignTimeVisibleAttribute.cs
- MembershipSection.cs
- Adorner.cs
- HitTestWithGeometryDrawingContextWalker.cs
- SettingsProviderCollection.cs
- FontNameEditor.cs
- ObjectDataProvider.cs
- SmiEventSink_Default.cs
- ProgramPublisher.cs
- DragEvent.cs
- DataServiceResponse.cs
- MonitoringDescriptionAttribute.cs
- Rotation3D.cs
- CatalogZoneBase.cs
- AnimationLayer.cs
- GradientStop.cs
- AccessText.cs
- DataGridTemplateColumn.cs
- FragmentQueryProcessor.cs
- RichTextBoxDesigner.cs
- DataGridAutoGeneratingColumnEventArgs.cs
- SpecialNameAttribute.cs
- PipelineModuleStepContainer.cs
- AlignmentYValidation.cs
- HtmlInputPassword.cs
- MonthCalendar.cs
- PhysicalOps.cs
- CodeArrayCreateExpression.cs
- TripleDES.cs
- PartitionResolver.cs
- ConfigurationPropertyAttribute.cs
- ItemList.cs
- ListDictionaryInternal.cs
- FormsAuthenticationUser.cs
- ObjectDataSourceView.cs
- ProgressBarHighlightConverter.cs
- WindowsFormsHostPropertyMap.cs
- Rect3D.cs
- SafeProcessHandle.cs
- EdmSchemaError.cs
- Component.cs
- WeakReference.cs
- EntityException.cs
- XPathAxisIterator.cs
- MissingManifestResourceException.cs
- WindowsEditBox.cs
- BindingList.cs
- WebPartMovingEventArgs.cs
- SecurityVerifiedMessage.cs
- SynchronizedDispatch.cs
- ViewBase.cs
- EventRouteFactory.cs
- AmbiguousMatchException.cs
- ValuePattern.cs
- GeneralTransform3DGroup.cs
- SmiRecordBuffer.cs
- CompositeCollectionView.cs