Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / AsyncResult.cs / 1 / AsyncResult.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel { using System.Threading; using System.ServiceModel.Diagnostics; using System.Diagnostics; abstract class AsyncResult : IAsyncResult { #if DEBUG_EXPENSIVE StackTrace endStack; StackTrace completeStack; #endif AsyncCallback callback; object state; bool completedSynchronously; bool endCalled; Exception exception; bool isCompleted; ManualResetEvent manualResetEvent; object thisLock; ServiceModelActivity callbackActivity = null; protected AsyncResult(AsyncCallback callback, object state) { this.callback = callback; this.state = state; this.thisLock = new object(); } public object AsyncState { get { return state; } } public WaitHandle AsyncWaitHandle { get { if (manualResetEvent != null) { return manualResetEvent; } lock (ThisLock) { if (manualResetEvent == null) { manualResetEvent = new ManualResetEvent(isCompleted); } } return manualResetEvent; } } public ServiceModelActivity CallbackActivity { get { return this.callbackActivity; } set { this.callbackActivity = value; } } public bool CompletedSynchronously { get { return completedSynchronously; } } public bool HasCallback { get { return this.callback != null; } } public bool IsCompleted { get { return isCompleted; } } object ThisLock { get { return this.thisLock; } } ////// Call this version of complete when your asynchronous operation is complete. This will update the state /// of the operation and notify the callback. /// /// protected void Complete(bool completedSynchronously) { if (isCompleted) { // It's a bug to call Complete twice. DiagnosticUtility.DebugAssert("AsyncResult complete called twice for the same operation."); throw DiagnosticUtility.ExceptionUtility.ThrowHelperInternal(false); } #if DEBUG_EXPENSIVE if (completeStack == null) completeStack = new StackTrace(); #endif this.completedSynchronously = completedSynchronously; if (completedSynchronously) { // If we completedSynchronously, then there's no chance that the manualResetEvent was created so // we don't need to worry about a race DiagnosticUtility.DebugAssert(this.manualResetEvent == null, "No ManualResetEvent should be created for a synchronous AsyncResult."); this.isCompleted = true; } else { lock (ThisLock) { this.isCompleted = true; if (this.manualResetEvent != null) { this.manualResetEvent.Set(); } } } if (callback != null) { try { using (this.CallbackActivity == null ? null : ServiceModelActivity.BoundOperation(this.CallbackActivity)) { callback(this); } } #pragma warning suppress 56500 // [....], transferring exception to another thread catch (Exception e) { if (DiagnosticUtility.ShouldTraceWarning) { System.ServiceModel.Diagnostics.TraceUtility.TraceEvent(TraceEventType.Warning, System.ServiceModel.Diagnostics.TraceCode.AsyncCallbackThrewException, e, null); } if (DiagnosticUtility.IsFatal(e)) throw; throw DiagnosticUtility.ExceptionUtility.ThrowHelperCallback(SR.GetString(SR.AsyncCallbackException), e); } } } ////// Call this version of complete if you raise an exception during processing. In addition to notifying /// the callback, it will capture the exception and store it to be thrown during AsyncResult.End. /// /// protected void Complete(bool completedSynchronously, Exception exception) { this.exception = exception; Complete(completedSynchronously); } ////// End should be called when the End function for the asynchronous operation is complete. It /// ensures the asynchronous operation is complete, and does some common validation. /// /// protected static TAsyncResult End(IAsyncResult result) where TAsyncResult : AsyncResult { if (result == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("result"); } TAsyncResult asyncResult = result as TAsyncResult; if (asyncResult == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("result", SR.GetString(SR.InvalidAsyncResult)); } if (asyncResult.endCalled) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.AsyncObjectAlreadyEnded))); } #if DEBUG_EXPENSIVE if (asyncResult.endStack == null) asyncResult.endStack = new StackTrace(); #endif asyncResult.endCalled = true; if (!asyncResult.isCompleted) { asyncResult.AsyncWaitHandle.WaitOne(); } if (asyncResult.manualResetEvent != null) { asyncResult.manualResetEvent.Close(); } if (asyncResult.exception != null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(asyncResult.exception); } return asyncResult; } } } // 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
- ButtonBaseAdapter.cs
- WebControl.cs
- DialogWindow.cs
- FileDialogCustomPlace.cs
- FolderLevelBuildProvider.cs
- KeyMatchBuilder.cs
- OrthographicCamera.cs
- IntSecurity.cs
- InputLangChangeRequestEvent.cs
- ACL.cs
- ToolStripPanelCell.cs
- PlaceHolder.cs
- TextEditorContextMenu.cs
- CodeNamespaceImport.cs
- Int64AnimationBase.cs
- OleDbPermission.cs
- DataControlButton.cs
- DataGridViewMethods.cs
- InternalBufferOverflowException.cs
- ParserContext.cs
- XmlEncodedRawTextWriter.cs
- SQLBinaryStorage.cs
- WindowAutomationPeer.cs
- PagedDataSource.cs
- WebPartUtil.cs
- CharAnimationUsingKeyFrames.cs
- TargetConverter.cs
- StrokeCollectionDefaultValueFactory.cs
- PropertyValueEditor.cs
- PropertyCondition.cs
- RolePrincipal.cs
- ThemeConfigurationDialog.cs
- SqlDataReaderSmi.cs
- SecurityDescriptor.cs
- DataServiceStreamProviderWrapper.cs
- PropertyInformationCollection.cs
- EntityClientCacheKey.cs
- PathParser.cs
- Point3DAnimationUsingKeyFrames.cs
- DocumentOutline.cs
- ExceptionRoutedEventArgs.cs
- DataMemberFieldEditor.cs
- SecureUICommand.cs
- IgnoreSection.cs
- WindowsUpDown.cs
- MDIClient.cs
- IndependentAnimationStorage.cs
- SafeCryptContextHandle.cs
- StringFormat.cs
- IndicCharClassifier.cs
- GatewayDefinition.cs
- Empty.cs
- XmlUTF8TextWriter.cs
- PassportAuthenticationEventArgs.cs
- BooleanKeyFrameCollection.cs
- ThreadInterruptedException.cs
- IdleTimeoutMonitor.cs
- GraphicsContainer.cs
- TemplatePartAttribute.cs
- WebRequest.cs
- ADMembershipProvider.cs
- SqlDataSourceFilteringEventArgs.cs
- SettingsProperty.cs
- ControlsConfig.cs
- SqlXml.cs
- ListViewDeleteEventArgs.cs
- ErrorView.xaml.cs
- Item.cs
- TextBox.cs
- LicFileLicenseProvider.cs
- KeyNotFoundException.cs
- EntityDesignerUtils.cs
- DbProviderFactory.cs
- BamlRecordReader.cs
- EntityContainer.cs
- HttpStreams.cs
- Adorner.cs
- ConnectionsZone.cs
- TdsParserSafeHandles.cs
- SimpleWebHandlerParser.cs
- FormViewInsertedEventArgs.cs
- HttpHeaderCollection.cs
- QuaternionConverter.cs
- QilInvokeEarlyBound.cs
- OpCodes.cs
- SerializationHelper.cs
- ProviderConnectionPoint.cs
- CodeStatementCollection.cs
- GeneralTransform3D.cs
- WebServiceClientProxyGenerator.cs
- COM2EnumConverter.cs
- CrossContextChannel.cs
- TemplateNameScope.cs
- TemplatedMailWebEventProvider.cs
- BaseAutoFormat.cs
- FrameworkRichTextComposition.cs
- HtmlAnchor.cs
- RelationshipSet.cs
- InputMethod.cs
- QuadraticEase.cs