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
- RoleServiceManager.cs
- WebPartActionVerb.cs
- CodeRemoveEventStatement.cs
- LayoutEngine.cs
- RestClientProxyHandler.cs
- KeyboardNavigation.cs
- PolicyException.cs
- CSharpCodeProvider.cs
- MembershipSection.cs
- ColumnCollection.cs
- SatelliteContractVersionAttribute.cs
- ActivityXRefPropertyEditor.cs
- SessionEndedEventArgs.cs
- TextElementCollectionHelper.cs
- TextProperties.cs
- MatrixTransform3D.cs
- StringResourceManager.cs
- JpegBitmapEncoder.cs
- DbSetClause.cs
- Clause.cs
- LogReserveAndAppendState.cs
- VectorValueSerializer.cs
- DataGridViewElement.cs
- ReliableDuplexSessionChannel.cs
- XmlExtensionFunction.cs
- ShapingWorkspace.cs
- PolyLineSegmentFigureLogic.cs
- _NtlmClient.cs
- ListBoxItemWrapperAutomationPeer.cs
- AutoResetEvent.cs
- ToolStripRendererSwitcher.cs
- Annotation.cs
- PagesChangedEventArgs.cs
- Quaternion.cs
- NameSpaceExtractor.cs
- PresentationAppDomainManager.cs
- SafeFileHandle.cs
- InnerItemCollectionView.cs
- FilterableAttribute.cs
- TypeSystem.cs
- NonClientArea.cs
- ViewBase.cs
- ParenthesizePropertyNameAttribute.cs
- ExpressionEditor.cs
- SerTrace.cs
- SQLBinary.cs
- VerticalAlignConverter.cs
- ComplexTypeEmitter.cs
- PolicyImporterElement.cs
- Enum.cs
- Timeline.cs
- GacUtil.cs
- ResizingMessageFilter.cs
- PlatformNotSupportedException.cs
- AssociationSetEnd.cs
- InputLangChangeRequestEvent.cs
- AnonymousIdentificationSection.cs
- BCLDebug.cs
- MetadataItemSerializer.cs
- HtmlInputButton.cs
- MouseActionConverter.cs
- Util.cs
- ToolboxItemCollection.cs
- Executor.cs
- DesignerTransactionCloseEvent.cs
- Debug.cs
- AbsoluteQuery.cs
- JpegBitmapDecoder.cs
- ConfigurationStrings.cs
- PartialArray.cs
- _NestedMultipleAsyncResult.cs
- WindowAutomationPeer.cs
- OutputCacheProviderCollection.cs
- IisTraceWebEventProvider.cs
- WebPartMovingEventArgs.cs
- TransactionException.cs
- CompressionTracing.cs
- ResourcePart.cs
- SortedSetDebugView.cs
- CodeGenerationManager.cs
- ProcessModelSection.cs
- WebPartTransformerCollection.cs
- SQLInt32Storage.cs
- DataServiceOperationContext.cs
- CollectionEditor.cs
- Int16KeyFrameCollection.cs
- ByteStorage.cs
- ClientOperationFormatterProvider.cs
- ProxyDataContractResolver.cs
- XPathNodePointer.cs
- SystemWebExtensionsSectionGroup.cs
- Color.cs
- LightweightCodeGenerator.cs
- SafeBitVector32.cs
- ReturnValue.cs
- PingReply.cs
- CryptoProvider.cs
- DashStyle.cs
- PageClientProxyGenerator.cs
- XmlBinaryReader.cs