Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / fx / src / Data / System / Data / Common / DBAsyncResult.cs / 1 / DBAsyncResult.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace System.Data.Common { using System; using System.Data.ProviderBase; using System.Diagnostics; using System.Threading; internal sealed class DbAsyncResult : IAsyncResult { private readonly AsyncCallback _callback = null; private bool _fCompleted = false; private bool _fCompletedSynchronously = false; private readonly ManualResetEvent _manualResetEvent = null; private object _owner = null; private readonly object _stateObject = null; private readonly string _endMethodName; private ExecutionContext _execContext = null; static private ContextCallback _contextCallback = new ContextCallback(AsyncCallback_Context); // Used for SqlClient Open async private DbConnectionInternal _connectionInternal = null; internal DbAsyncResult(object owner, string endMethodName, AsyncCallback callback, object stateObject, ExecutionContext execContext) { _owner = owner; _endMethodName = endMethodName; _callback = callback; _stateObject = stateObject; _manualResetEvent = new ManualResetEvent(false); _execContext = execContext; } object IAsyncResult.AsyncState { get { return _stateObject; } } WaitHandle IAsyncResult.AsyncWaitHandle { get { return _manualResetEvent; } } bool IAsyncResult.CompletedSynchronously { get { return _fCompletedSynchronously; } } internal DbConnectionInternal ConnectionInternal { get { return _connectionInternal; } set { _connectionInternal = value; } } bool IAsyncResult.IsCompleted { get { return _fCompleted; } } internal string EndMethodName { get { return _endMethodName; } } internal void CompareExchangeOwner(object owner, string method) { object prior = Interlocked.CompareExchange(ref _owner, null, owner); if (prior != owner) { if (null != prior) { throw ADP.IncorrectAsyncResult(); } throw ADP.MethodCalledTwice(method); } } internal void Reset() { _fCompleted = false; _fCompletedSynchronously = false; _manualResetEvent.Reset(); } internal void SetCompleted() { _fCompleted = true; _manualResetEvent.Set(); if (_callback != null) { // QueueUserWorkItem only accepts WaitCallback - which requires a signature of Foo(object state). // Must call function on this object with that signature - and then call user AsyncCallback. // AsyncCallback signature is Foo(IAsyncResult result). ThreadPool.QueueUserWorkItem(new WaitCallback(ExecuteCallback), this); } } internal void SetCompletedSynchronously() { _fCompletedSynchronously = true; } static private void AsyncCallback_Context(Object state) { DbAsyncResult result = (DbAsyncResult) state; if (result._callback != null) { result._callback(result); } } private void ExecuteCallback(object asyncResult) { DbAsyncResult result = (DbAsyncResult) asyncResult; if (null != result._callback) { if (result._execContext != null) { ExecutionContext.Run(result._execContext, DbAsyncResult._contextCallback, result); } else { result._callback(this); } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace System.Data.Common { using System; using System.Data.ProviderBase; using System.Diagnostics; using System.Threading; internal sealed class DbAsyncResult : IAsyncResult { private readonly AsyncCallback _callback = null; private bool _fCompleted = false; private bool _fCompletedSynchronously = false; private readonly ManualResetEvent _manualResetEvent = null; private object _owner = null; private readonly object _stateObject = null; private readonly string _endMethodName; private ExecutionContext _execContext = null; static private ContextCallback _contextCallback = new ContextCallback(AsyncCallback_Context); // Used for SqlClient Open async private DbConnectionInternal _connectionInternal = null; internal DbAsyncResult(object owner, string endMethodName, AsyncCallback callback, object stateObject, ExecutionContext execContext) { _owner = owner; _endMethodName = endMethodName; _callback = callback; _stateObject = stateObject; _manualResetEvent = new ManualResetEvent(false); _execContext = execContext; } object IAsyncResult.AsyncState { get { return _stateObject; } } WaitHandle IAsyncResult.AsyncWaitHandle { get { return _manualResetEvent; } } bool IAsyncResult.CompletedSynchronously { get { return _fCompletedSynchronously; } } internal DbConnectionInternal ConnectionInternal { get { return _connectionInternal; } set { _connectionInternal = value; } } bool IAsyncResult.IsCompleted { get { return _fCompleted; } } internal string EndMethodName { get { return _endMethodName; } } internal void CompareExchangeOwner(object owner, string method) { object prior = Interlocked.CompareExchange(ref _owner, null, owner); if (prior != owner) { if (null != prior) { throw ADP.IncorrectAsyncResult(); } throw ADP.MethodCalledTwice(method); } } internal void Reset() { _fCompleted = false; _fCompletedSynchronously = false; _manualResetEvent.Reset(); } internal void SetCompleted() { _fCompleted = true; _manualResetEvent.Set(); if (_callback != null) { // QueueUserWorkItem only accepts WaitCallback - which requires a signature of Foo(object state). // Must call function on this object with that signature - and then call user AsyncCallback. // AsyncCallback signature is Foo(IAsyncResult result). ThreadPool.QueueUserWorkItem(new WaitCallback(ExecuteCallback), this); } } internal void SetCompletedSynchronously() { _fCompletedSynchronously = true; } static private void AsyncCallback_Context(Object state) { DbAsyncResult result = (DbAsyncResult) state; if (result._callback != null) { result._callback(result); } } private void ExecuteCallback(object asyncResult) { DbAsyncResult result = (DbAsyncResult) asyncResult; if (null != result._callback) { if (result._execContext != null) { ExecutionContext.Run(result._execContext, DbAsyncResult._contextCallback, result); } else { result._callback(this); } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- SoapDocumentServiceAttribute.cs
- XmlSchemaComplexType.cs
- UIElementHelper.cs
- StateMachine.cs
- Tile.cs
- CustomErrorsSectionWrapper.cs
- DrawToolTipEventArgs.cs
- XPathScanner.cs
- DropDownHolder.cs
- Helpers.cs
- MenuItemStyleCollection.cs
- NumberFormatInfo.cs
- DrawListViewItemEventArgs.cs
- UnmanagedMemoryStream.cs
- ListenerUnsafeNativeMethods.cs
- PhoneCall.cs
- StringFreezingAttribute.cs
- ZoneMembershipCondition.cs
- NavigatorOutput.cs
- Rect3D.cs
- WebPartEditVerb.cs
- SqlDataSourceCommandEventArgs.cs
- FormViewRow.cs
- StringSource.cs
- XPathParser.cs
- ServicePoint.cs
- SocketConnection.cs
- EpmCustomContentSerializer.cs
- AncestorChangedEventArgs.cs
- TraceProvider.cs
- ViewPort3D.cs
- BoundPropertyEntry.cs
- AdRotatorDesigner.cs
- XPathNodeInfoAtom.cs
- NetworkCredential.cs
- MissingSatelliteAssemblyException.cs
- DataGridViewRowHeaderCell.cs
- WebPartPersonalization.cs
- TransactionScopeDesigner.cs
- AttributeAction.cs
- ConnectionManagementElementCollection.cs
- FunctionCommandText.cs
- StreamGeometry.cs
- LayoutDump.cs
- SqlCacheDependencyDatabase.cs
- XmlSerializationGeneratedCode.cs
- DataMember.cs
- ObjectDataSource.cs
- ExclusiveCanonicalizationTransform.cs
- ScalarConstant.cs
- XamlBuildProvider.cs
- AtomicFile.cs
- WebPartZoneBaseDesigner.cs
- GridViewRow.cs
- HScrollProperties.cs
- SelectionService.cs
- ICspAsymmetricAlgorithm.cs
- NavigationFailedEventArgs.cs
- TabletCollection.cs
- ByteStreamMessageEncodingElement.cs
- ExpressionList.cs
- IInstanceContextProvider.cs
- SendActivityValidator.cs
- TimeSpanOrInfiniteValidator.cs
- WindowsUpDown.cs
- ProcessStartInfo.cs
- CollectionsUtil.cs
- ConditionCollection.cs
- DataObjectFieldAttribute.cs
- PowerModeChangedEventArgs.cs
- NamedPermissionSet.cs
- UnhandledExceptionEventArgs.cs
- QuotedPrintableStream.cs
- WebControlAdapter.cs
- InfiniteTimeSpanConverter.cs
- LocationSectionRecord.cs
- SemaphoreSecurity.cs
- _AutoWebProxyScriptHelper.cs
- IISMapPath.cs
- DoubleLinkListEnumerator.cs
- TaskFormBase.cs
- CommandConverter.cs
- StructuredTypeEmitter.cs
- XPathDocumentIterator.cs
- HuffModule.cs
- AliasExpr.cs
- NodeFunctions.cs
- Mouse.cs
- MeasureItemEvent.cs
- BufferedMessageWriter.cs
- XamlClipboardData.cs
- ConfigXmlSignificantWhitespace.cs
- MouseActionValueSerializer.cs
- FileUpload.cs
- FormsAuthenticationModule.cs
- SafeArrayTypeMismatchException.cs
- AdornedElementPlaceholder.cs
- SiteMapDataSource.cs
- Debug.cs
- Selection.cs