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
- SectionInput.cs
- LineInfo.cs
- SHA512Cng.cs
- ErrorRuntimeConfig.cs
- DropDownHolder.cs
- ColorConvertedBitmapExtension.cs
- DefaultWorkflowSchedulerService.cs
- InheritanceAttribute.cs
- ReferencedType.cs
- LateBoundBitmapDecoder.cs
- BulletChrome.cs
- Barrier.cs
- UserControlParser.cs
- PropertyPushdownHelper.cs
- DelegateHelpers.cs
- Attributes.cs
- NameValueFileSectionHandler.cs
- HandleScope.cs
- ValidationEventArgs.cs
- PropertyOverridesDialog.cs
- SystemFonts.cs
- EntityDataSourceDesignerHelper.cs
- TextParagraphProperties.cs
- SubqueryRules.cs
- CollectionsUtil.cs
- PseudoWebRequest.cs
- TempFiles.cs
- RegistryExceptionHelper.cs
- sqlcontext.cs
- DebugHandleTracker.cs
- JoinTreeNode.cs
- AdCreatedEventArgs.cs
- InternalReceiveMessage.cs
- ObjectConverter.cs
- XsltInput.cs
- RegionIterator.cs
- WorkflowFileItem.cs
- Separator.cs
- DataGridColumn.cs
- PersonalizationStateInfo.cs
- PerformanceCounterCategory.cs
- DefinitionBase.cs
- XmlSchema.cs
- ConfigXmlWhitespace.cs
- OdbcCommandBuilder.cs
- SmiGettersStream.cs
- ServiceProviders.cs
- HashCodeCombiner.cs
- BackgroundWorker.cs
- TextRunProperties.cs
- ReadOnlyMetadataCollection.cs
- DriveInfo.cs
- TemplateControl.cs
- WebPartEditorOkVerb.cs
- Environment.cs
- XPathNodeList.cs
- XmlSchemaObjectTable.cs
- XmlNamespaceManager.cs
- JumpItem.cs
- ClientWindowsAuthenticationMembershipProvider.cs
- TypeBuilder.cs
- ListCardsInFileRequest.cs
- PanelStyle.cs
- ErrorActivity.cs
- FormViewModeEventArgs.cs
- VisualBrush.cs
- UnmanagedBitmapWrapper.cs
- WebPartManagerInternals.cs
- PageRequestManager.cs
- ListParagraph.cs
- MatrixTransform.cs
- HashHelper.cs
- ResolvedKeyFrameEntry.cs
- HttpDictionary.cs
- BinaryWriter.cs
- ControlOperationBehavior.cs
- PolyBezierSegment.cs
- SystemPens.cs
- Win32SafeHandles.cs
- DocumentAutomationPeer.cs
- Pkcs7Signer.cs
- ListControlBoundActionList.cs
- PackageRelationshipSelector.cs
- PasswordRecoveryDesigner.cs
- sqlmetadatafactory.cs
- MediaPlayer.cs
- TypeElement.cs
- SafeRegistryHandle.cs
- ScrollItemProviderWrapper.cs
- WebPartConnectionsDisconnectVerb.cs
- ImageCodecInfoPrivate.cs
- DataGridViewImageCell.cs
- XmlNodeComparer.cs
- SourceLineInfo.cs
- SimpleType.cs
- Oci.cs
- XmlMapping.cs
- EncoderBestFitFallback.cs
- DtdParser.cs
- ActivityDesignerLayoutSerializers.cs