Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Security / NegotiationTokenProvider.cs / 1 / NegotiationTokenProvider.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Security { using System.IdentityModel.Claims; using System.ServiceModel; using System.ServiceModel.Description; using System.ServiceModel.Dispatcher; using System.IdentityModel.Policy; using System.ServiceModel.Security.Tokens; using System.Security.Principal; using System.Security.Cryptography.X509Certificates; using System.Collections.Generic; using System.ServiceModel.Channels; using System.Net; using System.Globalization; using System.Diagnostics; using System.Runtime.InteropServices; using System.Runtime.Serialization; using System.ServiceModel.Diagnostics; using System.Xml; /* * This is the base class for all token providers that negotiate an SCT from * the target service. */ abstract class NegotiationTokenProvider: IssuanceTokenProviderBase where T : IssuanceTokenProviderState { IChannelFactory rstChannelFactory; bool requiresManualReplyAddressing; BindingContext issuanceBindingContext; MessageVersion messageVersion; protected NegotiationTokenProvider() : base() { } public BindingContext IssuerBindingContext { get { return this.issuanceBindingContext; } set { this.CommunicationObject.ThrowIfDisposedOrImmutable(); if (value == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("value"); } this.issuanceBindingContext = value.Clone(); } } public override XmlDictionaryString RequestSecurityTokenAction { get { return this.StandardsManager.TrustDriver.RequestSecurityTokenAction; } } public override XmlDictionaryString RequestSecurityTokenResponseAction { get { return this.StandardsManager.TrustDriver.RequestSecurityTokenResponseAction; } } protected override MessageVersion MessageVersion { get { return this.messageVersion; } } protected override bool RequiresManualReplyAddressing { get { ThrowIfCreated(); return this.requiresManualReplyAddressing; } } public override void OnClose(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); if (this.rstChannelFactory != null) { this.rstChannelFactory.Close(timeout); this.rstChannelFactory = null; } base.OnClose(timeoutHelper.RemainingTime()); } public override void OnAbort() { if (this.rstChannelFactory != null) { this.rstChannelFactory.Abort(); this.rstChannelFactory = null; } base.OnAbort(); } public override void OnOpen(TimeSpan timeout) { if (this.IssuerBindingContext == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.IssuerBuildContextNotSet, this.GetType()))); } TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); this.SetupRstChannelFactory(); this.rstChannelFactory.Open(timeout); base.OnOpen(timeoutHelper.RemainingTime()); } protected abstract IChannelFactory GetNegotiationChannelFactory(IChannelFactory transportChannelFactory, ChannelBuilder channelBuilder); void SetupRstChannelFactory() { IChannelFactory innerChannelFactory = null; ChannelBuilder channelBuilder = new ChannelBuilder(this.IssuerBindingContext.Clone(), true); // if the underlying transport does not support request/reply, wrap it inside // a service channel factory. if (channelBuilder.CanBuildChannelFactory ()) { innerChannelFactory = channelBuilder.BuildChannelFactory (); this.requiresManualReplyAddressing = true; } else { ClientRuntime clientRuntime = new ClientRuntime("RequestSecurityTokenContract", NamingHelper.DefaultNamespace); clientRuntime.ValidateMustUnderstand = false; ServiceChannelFactory serviceChannelFactory = ServiceChannelFactory.BuildChannelFactory(channelBuilder, clientRuntime); serviceChannelFactory.ClientRuntime.UseSynchronizationContext = false; serviceChannelFactory.ClientRuntime.AddTransactionFlowProperties = false; ClientOperation rstOperation = new ClientOperation(serviceChannelFactory.ClientRuntime, "RequestSecurityToken", this.RequestSecurityTokenAction.Value); rstOperation.Formatter = MessageOperationFormatter.Instance; serviceChannelFactory.ClientRuntime.Operations.Add(rstOperation); if (this.IsMultiLegNegotiation) { ClientOperation rstrOperation = new ClientOperation(serviceChannelFactory.ClientRuntime, "RequestSecurityTokenResponse", this.RequestSecurityTokenResponseAction.Value); rstrOperation.Formatter = MessageOperationFormatter.Instance; serviceChannelFactory.ClientRuntime.Operations.Add(rstrOperation); } // service channel automatically adds reply headers this.requiresManualReplyAddressing = false; innerChannelFactory = new SecuritySessionSecurityTokenProvider.RequestChannelFactory(serviceChannelFactory); } this.rstChannelFactory = GetNegotiationChannelFactory(innerChannelFactory, channelBuilder); this.messageVersion = channelBuilder.Binding.MessageVersion; } // negotiation message processing overrides protected override bool WillInitializeChannelFactoriesCompleteSynchronously(EndpointAddress target) { return true; } protected override void InitializeChannelFactories(EndpointAddress target, TimeSpan timeout) { } protected override IAsyncResult BeginInitializeChannelFactories(EndpointAddress target, TimeSpan timeout, AsyncCallback callback, object state) { return new CompletedAsyncResult(callback, state); } protected override void EndInitializeChannelFactories(IAsyncResult result) { CompletedAsyncResult.End(result); } protected override IRequestChannel CreateClientChannel(EndpointAddress target, Uri via) { if (via != null) { return this.rstChannelFactory.CreateChannel(target, via); } else { return this.rstChannelFactory.CreateChannel(target); } } } } // 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
- PKCS1MaskGenerationMethod.cs
- IntranetCredentialPolicy.cs
- KnownTypesProvider.cs
- BatchServiceHost.cs
- FileUtil.cs
- Rule.cs
- ListBindingHelper.cs
- SizeChangedEventArgs.cs
- WebBrowserProgressChangedEventHandler.cs
- LinqDataSourceContextData.cs
- PKCS1MaskGenerationMethod.cs
- _NestedMultipleAsyncResult.cs
- querybuilder.cs
- MbpInfo.cs
- XmlEventCache.cs
- SuppressIldasmAttribute.cs
- MsmqIntegrationSecurityMode.cs
- CompatibleIComparer.cs
- InputScopeConverter.cs
- DefaultBinder.cs
- TextEditor.cs
- BindingValueChangedEventArgs.cs
- __TransparentProxy.cs
- FtpWebRequest.cs
- WebPartConnectionsEventArgs.cs
- ParallelTimeline.cs
- BlurBitmapEffect.cs
- UnsafeNativeMethods.cs
- CultureInfoConverter.cs
- OleCmdHelper.cs
- XPathSingletonIterator.cs
- CodeIndexerExpression.cs
- Base64Stream.cs
- LeftCellWrapper.cs
- TransactionContext.cs
- OrderByExpression.cs
- ContentElement.cs
- UniqueConstraint.cs
- SqlBulkCopy.cs
- HttpClientChannel.cs
- WebPartConnectionsCloseVerb.cs
- AsyncResult.cs
- TextParaLineResult.cs
- TreeWalker.cs
- CollectionViewSource.cs
- DataColumn.cs
- CodeDOMProvider.cs
- WindowsFormsHelpers.cs
- DataSetUtil.cs
- Aggregates.cs
- FixedTextPointer.cs
- GradientSpreadMethodValidation.cs
- BuildManagerHost.cs
- XPathAxisIterator.cs
- SQLInt32.cs
- CheckoutException.cs
- DataGridViewCellStyleBuilderDialog.cs
- _DigestClient.cs
- SyndicationDeserializer.cs
- DataGridViewTopLeftHeaderCell.cs
- Ticks.cs
- RtType.cs
- QilReplaceVisitor.cs
- CodeTypeMemberCollection.cs
- NullableLongMinMaxAggregationOperator.cs
- BreakRecordTable.cs
- MenuScrollingVisibilityConverter.cs
- precedingquery.cs
- sqlstateclientmanager.cs
- _BasicClient.cs
- TextEditorCopyPaste.cs
- HttpRuntime.cs
- CaseInsensitiveOrdinalStringComparer.cs
- PackageRelationshipSelector.cs
- JournalNavigationScope.cs
- ListBindableAttribute.cs
- EmptyEnumerable.cs
- LinkTarget.cs
- StreamWithDictionary.cs
- HybridObjectCache.cs
- SmiContext.cs
- PassportPrincipal.cs
- SyntaxCheck.cs
- TreeWalkHelper.cs
- RewritingProcessor.cs
- ToolStripSystemRenderer.cs
- ContentType.cs
- XslTransform.cs
- TextAdaptor.cs
- FocusTracker.cs
- TimeManager.cs
- GradientStop.cs
- MDIWindowDialog.cs
- TableCellsCollectionEditor.cs
- MethodRental.cs
- ProtocolException.cs
- WebEvents.cs
- InvalidTimeZoneException.cs
- SerialPort.cs
- ReferenceConverter.cs