Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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
- SapiRecoInterop.cs
- ProcessModelInfo.cs
- Base64Decoder.cs
- SqlColumnizer.cs
- Converter.cs
- URLString.cs
- FontWeightConverter.cs
- FamilyCollection.cs
- BuilderInfo.cs
- FaultDescription.cs
- NamespaceQuery.cs
- DeferrableContentConverter.cs
- ServicePerformanceCounters.cs
- OnOperation.cs
- AutoResizedEvent.cs
- MultilineStringConverter.cs
- SudsWriter.cs
- DataFormats.cs
- GridViewColumnCollectionChangedEventArgs.cs
- ActivityInterfaces.cs
- namescope.cs
- ChangesetResponse.cs
- DataService.cs
- BasicViewGenerator.cs
- XPathItem.cs
- LocalClientSecuritySettingsElement.cs
- NumberFormatter.cs
- Compress.cs
- AsymmetricKeyExchangeFormatter.cs
- SingleAnimation.cs
- Point3DCollection.cs
- XmlSchemaExternal.cs
- SystemNetHelpers.cs
- VirtualizingPanel.cs
- TypeReference.cs
- DataGridViewTopRowAccessibleObject.cs
- Transform3DGroup.cs
- Socket.cs
- NavigatorInput.cs
- UnsafeNativeMethodsPenimc.cs
- XmlSchemaAppInfo.cs
- OperationContractGenerationContext.cs
- CornerRadius.cs
- RunClient.cs
- EmptyElement.cs
- EventListenerClientSide.cs
- SoapHeaders.cs
- SystemWebExtensionsSectionGroup.cs
- OracleColumn.cs
- PageWrapper.cs
- HeaderElement.cs
- Utils.cs
- MarginsConverter.cs
- Grid.cs
- GACIdentityPermission.cs
- SafeFileMapViewHandle.cs
- XmlEncodedRawTextWriter.cs
- SoapSchemaImporter.cs
- ListViewItemEventArgs.cs
- RelativeSource.cs
- MimeReflector.cs
- ContractHandle.cs
- XmlExpressionDumper.cs
- EventLevel.cs
- Msec.cs
- SqlDataSourceView.cs
- CodeNamespaceImportCollection.cs
- TextProperties.cs
- ColorTransformHelper.cs
- JsonDataContract.cs
- ObjectQuery.cs
- updateconfighost.cs
- ImpersonateTokenRef.cs
- HwndTarget.cs
- ContainerParaClient.cs
- DashStyles.cs
- FrameworkElement.cs
- SimpleType.cs
- SmtpFailedRecipientsException.cs
- PinnedBufferMemoryStream.cs
- ContentPosition.cs
- DatasetMethodGenerator.cs
- GCHandleCookieTable.cs
- recordstatefactory.cs
- ConfigurationManager.cs
- ApplicationInfo.cs
- ContextCorrelationInitializer.cs
- CodeDirectiveCollection.cs
- GeneralTransform3DTo2D.cs
- SafeThreadHandle.cs
- EtwTrace.cs
- PersonalizationStateQuery.cs
- DataGridViewDataErrorEventArgs.cs
- PeerApplication.cs
- DataBindingValueUIHandler.cs
- ThreadAttributes.cs
- ClientScriptManagerWrapper.cs
- CommandBinding.cs
- StandardToolWindows.cs
- CompilerParameters.cs