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
- ServiceDiscoveryElement.cs
- CustomSignedXml.cs
- EdmError.cs
- C14NUtil.cs
- FontUnit.cs
- DiscoveryDocumentLinksPattern.cs
- SerializationSectionGroup.cs
- InsufficientExecutionStackException.cs
- sortedlist.cs
- SignatureToken.cs
- XmlCodeExporter.cs
- altserialization.cs
- EntityContainerRelationshipSet.cs
- NamespaceInfo.cs
- ZipIOCentralDirectoryDigitalSignature.cs
- PropertyPushdownHelper.cs
- IndicFontClient.cs
- EmbeddedMailObject.cs
- RequestCache.cs
- ZipIOExtraField.cs
- SqlIdentifier.cs
- WebPartPersonalization.cs
- ChtmlFormAdapter.cs
- XPathNodeInfoAtom.cs
- TripleDESCryptoServiceProvider.cs
- TemplateLookupAction.cs
- ServicePoint.cs
- BindingContext.cs
- SqlOuterApplyReducer.cs
- PositiveTimeSpanValidatorAttribute.cs
- ConfigXmlComment.cs
- TabRenderer.cs
- AspCompat.cs
- MsmqInputChannel.cs
- CombinedGeometry.cs
- CommunicationException.cs
- ToolBar.cs
- CodeSubDirectoriesCollection.cs
- VisualStyleRenderer.cs
- UnsafeNetInfoNativeMethods.cs
- MDIControlStrip.cs
- MenuBase.cs
- DATA_BLOB.cs
- StringAnimationUsingKeyFrames.cs
- DependencyStoreSurrogate.cs
- FragmentQueryProcessor.cs
- ArrayWithOffset.cs
- WpfPayload.cs
- DataGridViewCell.cs
- SystemIcmpV4Statistics.cs
- ProjectionAnalyzer.cs
- DescendantQuery.cs
- TableRowCollection.cs
- NeutralResourcesLanguageAttribute.cs
- ControlBuilderAttribute.cs
- Assert.cs
- TextSelectionProcessor.cs
- BuildProviderCollection.cs
- SemanticBasicElement.cs
- EmulateRecognizeCompletedEventArgs.cs
- CodeDOMProvider.cs
- Speller.cs
- FixedStringLookup.cs
- HttpPostedFileWrapper.cs
- DocumentPageView.cs
- GorillaCodec.cs
- Roles.cs
- HttpDebugHandler.cs
- MimeBasePart.cs
- SqlLiftWhereClauses.cs
- StateChangeEvent.cs
- EventHandlerService.cs
- Decoder.cs
- TextBox.cs
- SqlParameter.cs
- BamlTreeNode.cs
- Sentence.cs
- ReadWriteSpinLock.cs
- ListViewContainer.cs
- SHA384Managed.cs
- NamespaceExpr.cs
- Properties.cs
- InternalControlCollection.cs
- ReaderWriterLock.cs
- XmlDocumentType.cs
- ImportedNamespaceContextItem.cs
- ArrayHelper.cs
- IndexOutOfRangeException.cs
- EasingKeyFrames.cs
- MonthCalendar.cs
- TaskHelper.cs
- ContainsRowNumberChecker.cs
- ItemsControl.cs
- ContainerControl.cs
- SqlDataReader.cs
- _UriTypeConverter.cs
- ImageCollectionCodeDomSerializer.cs
- XmlSchemaImporter.cs
- HtmlInputFile.cs
- SqlProcedureAttribute.cs