Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Data / System / Data / Common / DBAsyncResult.cs / 1305376 / 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
- BoundsDrawingContextWalker.cs
- RectValueSerializer.cs
- HttpApplication.cs
- ListControl.cs
- SecurityPolicySection.cs
- MessageVersionConverter.cs
- DataServiceConfiguration.cs
- ListItem.cs
- ToolStripCustomTypeDescriptor.cs
- PrivilegedConfigurationManager.cs
- Baml2006ReaderContext.cs
- SqlLiftIndependentRowExpressions.cs
- SafeFileHandle.cs
- QualifierSet.cs
- TagMapInfo.cs
- TextFormatterImp.cs
- PenContexts.cs
- ApplicationActivator.cs
- EntitySetDataBindingList.cs
- SetterBaseCollection.cs
- RevocationPoint.cs
- Evidence.cs
- OracleInternalConnection.cs
- TagMapInfo.cs
- RootBrowserWindow.cs
- WriteFileContext.cs
- MailDefinition.cs
- InputScopeConverter.cs
- UMPAttributes.cs
- FileDetails.cs
- SimpleWebHandlerParser.cs
- FloaterParaClient.cs
- Timer.cs
- SoapWriter.cs
- DefaultBinder.cs
- MouseButtonEventArgs.cs
- DataBindEngine.cs
- ControlCollection.cs
- NativeCompoundFileAPIs.cs
- XhtmlConformanceSection.cs
- Trace.cs
- FunctionQuery.cs
- SByte.cs
- StorageInfo.cs
- HyperLink.cs
- contentDescriptor.cs
- StrokeCollection2.cs
- SvcMapFileLoader.cs
- FileDialog.cs
- FlowDocumentScrollViewerAutomationPeer.cs
- PersonalizablePropertyEntry.cs
- DynamicValueConverter.cs
- SignatureDescription.cs
- KoreanCalendar.cs
- DocumentViewer.cs
- UnsafeNativeMethods.cs
- MdiWindowListStrip.cs
- CaseInsensitiveOrdinalStringComparer.cs
- HitTestParameters3D.cs
- EntityProviderServices.cs
- ErrorHandlingAcceptor.cs
- GlyphRunDrawing.cs
- cookiecollection.cs
- SafeRightsManagementPubHandle.cs
- ReadOnlyCollectionBase.cs
- DateTimeOffsetStorage.cs
- BaseConfigurationRecord.cs
- Quaternion.cs
- BuildProvider.cs
- BrowserCapabilitiesCompiler.cs
- GiveFeedbackEvent.cs
- QilTypeChecker.cs
- ColorConverter.cs
- Group.cs
- SymmetricAlgorithm.cs
- AssemblyBuilder.cs
- UriTemplateMatch.cs
- _HelperAsyncResults.cs
- CalculatedColumn.cs
- SharedPersonalizationStateInfo.cs
- LoginNameDesigner.cs
- ExponentialEase.cs
- TypeConverter.cs
- DataGridViewLayoutData.cs
- XmlDataSourceNodeDescriptor.cs
- WebMessageBodyStyleHelper.cs
- FactoryMaker.cs
- Classification.cs
- WindowsIPAddress.cs
- SchemaElement.cs
- RevocationPoint.cs
- HttpStaticObjectsCollectionWrapper.cs
- ProgressChangedEventArgs.cs
- ResourceDescriptionAttribute.cs
- HttpWebRequest.cs
- GeneralTransform3DTo2DTo3D.cs
- DBNull.cs
- NativeMethods.cs
- RecordBuilder.cs
- StickyNoteAnnotations.cs