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
- OdbcUtils.cs
- DataGridRelationshipRow.cs
- Timer.cs
- ControlType.cs
- OptimizedTemplateContentHelper.cs
- SupportingTokenProviderSpecification.cs
- DataGridViewColumnStateChangedEventArgs.cs
- KnownBoxes.cs
- BufferCache.cs
- SystemPens.cs
- Nodes.cs
- SqlDeflator.cs
- Win32.cs
- MexTcpBindingElement.cs
- FormViewInsertedEventArgs.cs
- ResXBuildProvider.cs
- ValidationException.cs
- EventEntry.cs
- ClosureBinding.cs
- TreeNodeSelectionProcessor.cs
- BrushProxy.cs
- ExternalFile.cs
- _ProxyChain.cs
- TextFormatterContext.cs
- SimpleBitVector32.cs
- FormsIdentity.cs
- MenuAdapter.cs
- HttpInputStream.cs
- RSAPKCS1KeyExchangeDeformatter.cs
- HtmlEmptyTagControlBuilder.cs
- Viewport3DVisual.cs
- WebConfigurationFileMap.cs
- TextServicesPropertyRanges.cs
- WrappingXamlSchemaContext.cs
- TextEditorTyping.cs
- HostDesigntimeLicenseContext.cs
- HttpCapabilitiesSectionHandler.cs
- SafeRightsManagementPubHandle.cs
- ShutDownListener.cs
- SimpleWebHandlerParser.cs
- OrderingQueryOperator.cs
- TextRangeAdaptor.cs
- TextHintingModeValidation.cs
- CacheAxisQuery.cs
- CompilerParameters.cs
- XsdDateTime.cs
- CodeBlockBuilder.cs
- DefaultValueMapping.cs
- ObjectDataProvider.cs
- DecimalAnimation.cs
- SerializationStore.cs
- WindowsSpinner.cs
- WebPartsSection.cs
- Light.cs
- ListSourceHelper.cs
- WebPartConnectionsConnectVerb.cs
- ConfigXmlComment.cs
- AddInStore.cs
- Version.cs
- WmpBitmapDecoder.cs
- SplayTreeNode.cs
- ToolStripOverflowButton.cs
- ViewSimplifier.cs
- MsmqOutputMessage.cs
- NameValuePermission.cs
- MessageLoggingFilterTraceRecord.cs
- DataColumnPropertyDescriptor.cs
- DataGridViewTopRowAccessibleObject.cs
- WCFServiceClientProxyGenerator.cs
- BidPrivateBase.cs
- SQLDouble.cs
- ImageField.cs
- TemplatedMailWebEventProvider.cs
- DataGridViewMethods.cs
- FontResourceCache.cs
- ArrayConverter.cs
- IndexedSelectQueryOperator.cs
- SoapElementAttribute.cs
- DecimalAnimationBase.cs
- KernelTypeValidation.cs
- DateTimeUtil.cs
- RequestDescription.cs
- TableLayoutPanelCellPosition.cs
- TextContainerChangeEventArgs.cs
- WindowsToolbar.cs
- SafeBitVector32.cs
- WebZone.cs
- RuntimeIdentifierPropertyAttribute.cs
- CodeThrowExceptionStatement.cs
- WebPartCatalogAddVerb.cs
- Model3DGroup.cs
- FixedDSBuilder.cs
- Latin1Encoding.cs
- State.cs
- ConfigXmlComment.cs
- UpWmlPageAdapter.cs
- ProfileManager.cs
- StructuralCache.cs
- RtfNavigator.cs
- StyleBamlTreeBuilder.cs