Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / 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
- NumericUpDownAcceleration.cs
- Pointer.cs
- SafeNativeMemoryHandle.cs
- FtpWebRequest.cs
- QueryableDataSourceEditData.cs
- TimeSpan.cs
- WindowsListBox.cs
- StagingAreaInputItem.cs
- Decoder.cs
- HttpPostServerProtocol.cs
- FullTextState.cs
- ExpressionPrefixAttribute.cs
- RoleService.cs
- XmlSchemaExporter.cs
- DocumentEventArgs.cs
- EntityDataSourceValidationException.cs
- IPEndPointCollection.cs
- MethodSignatureGenerator.cs
- StatusBar.cs
- IndexingContentUnit.cs
- ContentType.cs
- Int32Converter.cs
- UpdatePanelControlTrigger.cs
- ArcSegment.cs
- XPathCompileException.cs
- XmlDeclaration.cs
- ModuleConfigurationInfo.cs
- FragmentNavigationEventArgs.cs
- RealProxy.cs
- DecoderFallback.cs
- TextEndOfParagraph.cs
- SharedStream.cs
- SmiGettersStream.cs
- XmlAttributeCollection.cs
- MouseDevice.cs
- NextPreviousPagerField.cs
- CmsUtils.cs
- AsyncOperation.cs
- RegisteredScript.cs
- CellPartitioner.cs
- ExpanderAutomationPeer.cs
- SessionParameter.cs
- odbcmetadatacolumnnames.cs
- EventHandlingScope.cs
- ContentOperations.cs
- Win32SafeHandles.cs
- SourceFileInfo.cs
- HtmlTable.cs
- SpecialTypeDataContract.cs
- DragEvent.cs
- DoWorkEventArgs.cs
- XmlObjectSerializerReadContextComplex.cs
- ProtocolException.cs
- MostlySingletonList.cs
- IssuedTokenClientBehaviorsElement.cs
- xmlformatgeneratorstatics.cs
- TransformerInfo.cs
- FocusManager.cs
- SqlServer2KCompatibilityCheck.cs
- IgnoreSection.cs
- CompilerGeneratedAttribute.cs
- Effect.cs
- XmlSchemaAnnotated.cs
- PointHitTestParameters.cs
- Label.cs
- TagPrefixAttribute.cs
- RepeaterItem.cs
- UInt32Converter.cs
- GlyphTypeface.cs
- SqlVersion.cs
- DataGridHeaderBorder.cs
- DoubleAnimation.cs
- WindowVisualStateTracker.cs
- FloaterBaseParagraph.cs
- BinaryFormatterWriter.cs
- SystemIPv6InterfaceProperties.cs
- InputScopeNameConverter.cs
- MetadataArtifactLoaderCompositeResource.cs
- HttpConfigurationContext.cs
- _SslSessionsCache.cs
- InkCanvasFeedbackAdorner.cs
- BehaviorEditorPart.cs
- WebControlsSection.cs
- DescendantOverDescendantQuery.cs
- SHA256.cs
- FontWeightConverter.cs
- InputReportEventArgs.cs
- DataBindEngine.cs
- TransportContext.cs
- CursorConverter.cs
- OuterGlowBitmapEffect.cs
- HierarchicalDataBoundControl.cs
- TextEmbeddedObject.cs
- HtmlMeta.cs
- LogEntry.cs
- BindingElement.cs
- OdbcConnectionOpen.cs
- ActivityCodeGenerator.cs
- XmlBinaryReaderSession.cs
- ReliableDuplexSessionChannel.cs