Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / RequestContextBase.cs / 2 / RequestContextBase.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.ServiceModel; using System.IO; using System.Net; using System.IdentityModel.Claims; using System.IdentityModel.Policy; using System.Threading; using System.Web; using System.Diagnostics; using System.ServiceModel.Diagnostics; abstract class RequestContextBase : RequestContext { TimeSpan defaultSendTimeout; TimeSpan defaultCloseTimeout; CommunicationState state = CommunicationState.Opened; Message requestMessage; Exception requestMessageException; bool replySent; bool replyInitiated; bool aborted; object thisLock = new object(); protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout) { this.defaultSendTimeout = defaultSendTimeout; this.defaultCloseTimeout = defaultCloseTimeout; this.requestMessage = requestMessage; } public override Message RequestMessage { get { if (this.requestMessageException != null) { #pragma warning suppress 56503 // [....], see outcome of DCR 50092 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(this.requestMessageException); } return requestMessage; } } protected void SetRequestMessage(Message requestMessage) { DiagnosticUtility.DebugAssert(this.requestMessageException == null, "Cannot have both a requestMessage and a requestException."); this.requestMessage = requestMessage; } protected void SetRequestMessage(Exception requestMessageException) { DiagnosticUtility.DebugAssert(this.requestMessage == null, "Cannot have both a requestMessage and a requestException."); this.requestMessageException = requestMessageException; } protected bool ReplyInitiated { get { return this.replyInitiated; } } protected object ThisLock { get { return thisLock; } } public bool Aborted { get { return this.aborted; } } public TimeSpan DefaultCloseTimeout { get { return this.defaultCloseTimeout; } } public TimeSpan DefaultSendTimeout { get { return this.defaultSendTimeout; } } public override void Abort() { lock (ThisLock) { if (state == CommunicationState.Closed) return; state = CommunicationState.Closing; this.aborted = true; } if (DiagnosticUtility.ShouldTraceWarning) { TraceUtility.TraceEvent(TraceEventType.Warning, TraceCode.RequestContextAbort, this); } try { this.OnAbort(); } finally { state = CommunicationState.Closed; } } public override void Close() { this.Close(this.defaultCloseTimeout); } public override void Close(TimeSpan timeout) { if (timeout < TimeSpan.Zero) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.ValueMustBeNonNegative))); } bool sendAck = false; lock (ThisLock) { if (state != CommunicationState.Opened) return; state = CommunicationState.Closing; if (!this.replyInitiated) { this.replyInitiated = true; sendAck = true; } } TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); bool throwing = true; try { if (sendAck) { OnReply(null, timeoutHelper.RemainingTime()); } OnClose(timeoutHelper.RemainingTime()); state = CommunicationState.Closed; throwing = false; } finally { if (throwing) this.Abort(); } } protected override void Dispose(bool disposing) { base.Dispose(disposing); if (!disposing) return; if (this.replySent) { this.Close(); } else { this.Abort(); } } protected abstract void OnAbort(); protected abstract void OnClose(TimeSpan timeout); protected abstract void OnReply(Message message, TimeSpan timeout); protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state); protected abstract void OnEndReply(IAsyncResult result); protected void ThrowIfInvalidReply() { if (state == CommunicationState.Closed || state == CommunicationState.Closing) { if (aborted) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationObjectAbortedException(SR.GetString(SR.RequestContextAborted))); else throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ObjectDisposedException(this.GetType().FullName)); } if (this.replyInitiated) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.ReplyAlreadySent))); } public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) { return this.BeginReply(message, this.defaultSendTimeout, callback, state); } public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) { // "null" is a valid reply (signals a 202-style "ack"), so we don't have a null-check here lock (this.thisLock) { this.ThrowIfInvalidReply(); this.replyInitiated = true; } return OnBeginReply(message, timeout, callback, state); } public override void EndReply(IAsyncResult result) { OnEndReply(result); this.replySent = true; } public override void Reply(Message message) { this.Reply(message, this.defaultSendTimeout); } public override void Reply(Message message, TimeSpan timeout) { // "null" is a valid reply (signals a 202-style "ack"), so we don't have a null-check here lock (this.thisLock) { this.ThrowIfInvalidReply(); this.replyInitiated = true; } this.OnReply(message, timeout); this.replySent = true; } internal Message InternalRequestMessage { get { return requestMessage; } } } class RequestContextMessageProperty : IDisposable { RequestContext context; object thisLock = new object(); public RequestContextMessageProperty(RequestContext context) { this.context = context; } public static string Name { get { return "requestContext"; } } void IDisposable.Dispose() { bool success = false; RequestContext thisContext; lock (this.thisLock) { if (this.context == null) return; thisContext = this.context; this.context = null; } try { thisContext.Close(); success = true; } catch (CommunicationException e) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } catch (TimeoutException e) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } finally { if (!success) { thisContext.Abort(); } } } } } // 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
- PenContext.cs
- MethodBuilder.cs
- BackgroundWorker.cs
- LoginViewDesigner.cs
- InputLanguageCollection.cs
- MobileErrorInfo.cs
- QuaternionKeyFrameCollection.cs
- ApplicationSettingsBase.cs
- PriorityBinding.cs
- ConfigurationSchemaErrors.cs
- TitleStyle.cs
- NativeMethods.cs
- PerformanceCounterManager.cs
- ProfileGroupSettings.cs
- UICuesEvent.cs
- InteropBitmapSource.cs
- ReferencedCollectionType.cs
- MetadataItemEmitter.cs
- StringUtil.cs
- PathSegment.cs
- BitmapCodecInfoInternal.cs
- DependencyObjectProvider.cs
- ProcessMessagesAsyncResult.cs
- SupportsPreviewControlAttribute.cs
- MergeFailedEvent.cs
- DbTransaction.cs
- EntityDataSourceWizardForm.cs
- BaseValidatorDesigner.cs
- ImageMetadata.cs
- TraceHandlerErrorFormatter.cs
- TableNameAttribute.cs
- TriState.cs
- LingerOption.cs
- DbException.cs
- OleDbEnumerator.cs
- SourceInterpreter.cs
- QilExpression.cs
- RelationshipEndMember.cs
- ProcessInputEventArgs.cs
- XamlWriter.cs
- EntityProviderServices.cs
- EncryptedKey.cs
- ConfigurationManagerInternal.cs
- ScrollProviderWrapper.cs
- SafeRegistryKey.cs
- MenuItem.cs
- SourceItem.cs
- SchemaCollectionCompiler.cs
- HwndProxyElementProvider.cs
- Regex.cs
- TreeViewItemAutomationPeer.cs
- EastAsianLunisolarCalendar.cs
- X509ChainPolicy.cs
- DependencyProperty.cs
- EntityContainer.cs
- UInt32Converter.cs
- SourceInterpreter.cs
- Codec.cs
- HtmlControlPersistable.cs
- AtomServiceDocumentSerializer.cs
- DeferredElementTreeState.cs
- WebPartZoneCollection.cs
- WindowsFormsHost.cs
- Char.cs
- ObsoleteAttribute.cs
- ReadOnlyDictionary.cs
- Wildcard.cs
- ListViewUpdateEventArgs.cs
- PopupRoot.cs
- X509SecurityToken.cs
- X509ThumbprintKeyIdentifierClause.cs
- Set.cs
- XmlObjectSerializerReadContextComplexJson.cs
- WorkflowCreationContext.cs
- NodeInfo.cs
- WebPermission.cs
- ImageAutomationPeer.cs
- CustomActivityDesigner.cs
- CompilationUtil.cs
- ProcessManager.cs
- XmlNodeList.cs
- WindowsScroll.cs
- ConsoleEntryPoint.cs
- Encoding.cs
- XPathMultyIterator.cs
- TargetException.cs
- Group.cs
- ResourcesBuildProvider.cs
- SchemaImporterExtension.cs
- ProcessHostFactoryHelper.cs
- DbParameterHelper.cs
- HtmlControl.cs
- ADRoleFactory.cs
- DataRowView.cs
- UserNamePasswordServiceCredential.cs
- GlobalizationAssembly.cs
- BufferManager.cs
- ServiceModelTimeSpanValidator.cs
- Intellisense.cs
- HtmlInputText.cs