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
- Highlights.cs
- ValueTable.cs
- AttributeUsageAttribute.cs
- DataContractJsonSerializer.cs
- CategoryAttribute.cs
- XmlAttributeCollection.cs
- TableParaClient.cs
- _AcceptOverlappedAsyncResult.cs
- CodeGotoStatement.cs
- BmpBitmapDecoder.cs
- FlowDocumentReaderAutomationPeer.cs
- EmptyEnumerator.cs
- PassportPrincipal.cs
- SqlMethodCallConverter.cs
- SortAction.cs
- XmlSchemaDatatype.cs
- TransformedBitmap.cs
- objectquery_tresulttype.cs
- ConnectionPoolManager.cs
- TreeViewHitTestInfo.cs
- EpmCustomContentSerializer.cs
- ParameterToken.cs
- UriSectionData.cs
- HttpCacheVary.cs
- TypeDelegator.cs
- RenderDataDrawingContext.cs
- PropertyMetadata.cs
- X509CertificateCollection.cs
- CommandSet.cs
- DynamicDiscoSearcher.cs
- DelegateSerializationHolder.cs
- StringConverter.cs
- printdlgexmarshaler.cs
- DataControlImageButton.cs
- HyperlinkAutomationPeer.cs
- LinkedResourceCollection.cs
- Metafile.cs
- GridItemPattern.cs
- CommandArguments.cs
- DataTableCollection.cs
- GridViewRow.cs
- BaseParaClient.cs
- RequestNavigateEventArgs.cs
- KeyTimeConverter.cs
- XPathScanner.cs
- CommandManager.cs
- CacheSection.cs
- DoubleAnimation.cs
- HostingEnvironmentSection.cs
- DashStyle.cs
- MenuItemStyleCollection.cs
- PtsHost.cs
- WindowsEditBox.cs
- VoiceChangeEventArgs.cs
- TraversalRequest.cs
- RoleManagerSection.cs
- ValidationErrorEventArgs.cs
- _Connection.cs
- ChtmlPageAdapter.cs
- UriScheme.cs
- AsyncInvokeOperation.cs
- Zone.cs
- IdentityNotMappedException.cs
- Int64Converter.cs
- DrawingBrush.cs
- ConditionalAttribute.cs
- XmlDocumentType.cs
- EventLogger.cs
- DockingAttribute.cs
- RoleManagerSection.cs
- BridgeDataRecord.cs
- CallSiteHelpers.cs
- BaseProcessor.cs
- ImportFileRequest.cs
- ListCollectionView.cs
- LocatorBase.cs
- UnionExpr.cs
- MethodImplAttribute.cs
- Parameter.cs
- EventManager.cs
- ToolBarOverflowPanel.cs
- ErrorStyle.cs
- NodeInfo.cs
- DbUpdateCommandTree.cs
- WpfPayload.cs
- CanonicalXml.cs
- SqlLiftWhereClauses.cs
- Maps.cs
- HierarchicalDataTemplate.cs
- WindowsScrollBarBits.cs
- SizeF.cs
- QilReplaceVisitor.cs
- CharAnimationBase.cs
- XmlEnumAttribute.cs
- DbUpdateCommandTree.cs
- InheritanceAttribute.cs
- UTF8Encoding.cs
- DrawTreeNodeEventArgs.cs
- CfgRule.cs
- ReaderWriterLock.cs