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
- HttpListenerContext.cs
- ColorBuilder.cs
- StructuredProperty.cs
- SafeHandles.cs
- Type.cs
- TextEncodedRawTextWriter.cs
- ProjectionCamera.cs
- MergeFilterQuery.cs
- COM2PropertyPageUITypeConverter.cs
- TransformCryptoHandle.cs
- MarkupObject.cs
- NameTable.cs
- VScrollProperties.cs
- AnnotationHighlightLayer.cs
- UInt64Storage.cs
- ContentElement.cs
- DataServiceBuildProvider.cs
- SQLDateTime.cs
- PopOutPanel.cs
- List.cs
- XmlSchemaComplexContent.cs
- SmtpLoginAuthenticationModule.cs
- TypeGeneratedEventArgs.cs
- EmptyEnumerable.cs
- SqlAggregateChecker.cs
- InvalidPipelineStoreException.cs
- Int64.cs
- QueryAccessibilityHelpEvent.cs
- RoleService.cs
- ListViewItem.cs
- GradientStop.cs
- ListItemCollection.cs
- SqlDataReaderSmi.cs
- FixedSOMPageConstructor.cs
- BaseCAMarshaler.cs
- FontSizeConverter.cs
- ParenthesizePropertyNameAttribute.cs
- LabelInfo.cs
- HttpException.cs
- DataGridPageChangedEventArgs.cs
- FileFormatException.cs
- Command.cs
- NonBatchDirectoryCompiler.cs
- MediaTimeline.cs
- ImportCatalogPart.cs
- IndexedSelectQueryOperator.cs
- FileLevelControlBuilderAttribute.cs
- SafeViewOfFileHandle.cs
- BoundPropertyEntry.cs
- SSmlParser.cs
- ColumnTypeConverter.cs
- SettingsPropertyValue.cs
- GacUtil.cs
- ReadOnlyTernaryTree.cs
- CompletionProxy.cs
- Matrix3D.cs
- ClientSideQueueItem.cs
- AlternateViewCollection.cs
- CompiledQuery.cs
- CqlLexerHelpers.cs
- MultipartContentParser.cs
- WindowsAltTab.cs
- RegexFCD.cs
- HttpRawResponse.cs
- FontUnitConverter.cs
- QueryParameter.cs
- Effect.cs
- Currency.cs
- HideDisabledControlAdapter.cs
- CssStyleCollection.cs
- SourceFileBuildProvider.cs
- WorkflowClientDeliverMessageWrapper.cs
- formatter.cs
- MessageBox.cs
- TrackingProfileCache.cs
- JsonObjectDataContract.cs
- ConstraintManager.cs
- ApplicationHost.cs
- XNodeValidator.cs
- WorkflowServiceHost.cs
- SearchExpression.cs
- HashStream.cs
- IndexerNameAttribute.cs
- Sql8ExpressionRewriter.cs
- MatrixKeyFrameCollection.cs
- ModelPerspective.cs
- ArrayItemValue.cs
- PolyLineSegmentFigureLogic.cs
- WebPartMenu.cs
- DocumentApplicationJournalEntry.cs
- RandomNumberGenerator.cs
- DataServiceKeyAttribute.cs
- XmlQueryCardinality.cs
- TextParagraphProperties.cs
- Closure.cs
- SystemIPv4InterfaceProperties.cs
- UniqueEventHelper.cs
- VarRefManager.cs
- ClientTargetSection.cs
- ApplicationDirectory.cs