Code:
/ DotNET / DotNET / 8.0 / untmp / whidbey / REDBITS / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- AutoCompleteStringCollection.cs
- ErrorProvider.cs
- DataViewManager.cs
- CaseInsensitiveOrdinalStringComparer.cs
- FileStream.cs
- BlurBitmapEffect.cs
- DispatcherSynchronizationContext.cs
- SHA256.cs
- SchemaNames.cs
- HtmlInputHidden.cs
- UniqueIdentifierService.cs
- HtmlControl.cs
- DataGridViewRowHeaderCell.cs
- BinaryFormatterWriter.cs
- JapaneseCalendar.cs
- TypeContext.cs
- DeclaredTypeElementCollection.cs
- SslStream.cs
- AccessControlList.cs
- EntityDataSourceDesigner.cs
- OdbcUtils.cs
- DataGridTablesFactory.cs
- Process.cs
- Speller.cs
- UniqueIdentifierService.cs
- CLSCompliantAttribute.cs
- ClientOptions.cs
- HMACMD5.cs
- SqlCommand.cs
- XamlBuildProvider.cs
- httpserverutility.cs
- ObjectDataSourceView.cs
- EventMap.cs
- PeerService.cs
- HtmlInputReset.cs
- ObjectTag.cs
- HtmlElementErrorEventArgs.cs
- XmlSerializerSection.cs
- EntityModelSchemaGenerator.cs
- AssemblyNameUtility.cs
- mediaeventshelper.cs
- columnmapfactory.cs
- DataSysAttribute.cs
- AssemblyCollection.cs
- LinqDataSourceDeleteEventArgs.cs
- XPathNodeList.cs
- LoadedOrUnloadedOperation.cs
- BuilderPropertyEntry.cs
- RectangleGeometry.cs
- MiniLockedBorderGlyph.cs
- RecognitionEventArgs.cs
- basevalidator.cs
- LazyLoadBehavior.cs
- FileDialog_Vista.cs
- AVElementHelper.cs
- BindUriHelper.cs
- DescendentsWalker.cs
- KeyProperty.cs
- MappingModelBuildProvider.cs
- DataListItem.cs
- WhereQueryOperator.cs
- TdsParserStaticMethods.cs
- _FtpDataStream.cs
- SHA256.cs
- PropertyDescriptorComparer.cs
- ClickablePoint.cs
- UnauthorizedAccessException.cs
- DataTableNewRowEvent.cs
- WsatServiceAddress.cs
- EncoderBestFitFallback.cs
- RowUpdatedEventArgs.cs
- SemanticResolver.cs
- RegionIterator.cs
- AuthenticationSection.cs
- DependencyObject.cs
- HttpDictionary.cs
- PenContexts.cs
- XPathDescendantIterator.cs
- clipboard.cs
- RSAProtectedConfigurationProvider.cs
- MappingSource.cs
- Span.cs
- TypeConverterBase.cs
- safex509handles.cs
- OracleDataAdapter.cs
- BitStack.cs
- OwnerDrawPropertyBag.cs
- SspiSafeHandles.cs
- PieceDirectory.cs
- GeneralTransform2DTo3DTo2D.cs
- ChangePassword.cs
- OneOfTypeConst.cs
- XpsResourceDictionary.cs
- RichTextBox.cs
- StateInitialization.cs
- DefaultPrintController.cs
- _TransmitFileOverlappedAsyncResult.cs
- ConnectionModeReader.cs
- WebPartDisplayModeCollection.cs
- HtmlInputImage.cs