Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- Config.cs
- ValueTypeFixupInfo.cs
- RegionIterator.cs
- TextRangeEdit.cs
- CommandManager.cs
- MULTI_QI.cs
- ZipIOModeEnforcingStream.cs
- KeyTime.cs
- HttpInputStream.cs
- EdmTypeAttribute.cs
- BitHelper.cs
- SingleStorage.cs
- AsyncStreamReader.cs
- GroupPartitionExpr.cs
- WorkflowServiceHostFactory.cs
- StreamReader.cs
- TraceSection.cs
- MaskedTextBox.cs
- SqlServices.cs
- ButtonChrome.cs
- ExpanderAutomationPeer.cs
- SoapAttributeAttribute.cs
- SQLInt64Storage.cs
- GPPOINTF.cs
- AsyncInvokeOperation.cs
- DesignerActionVerbList.cs
- TransactionScope.cs
- SqlTransaction.cs
- ExtendedTransformFactory.cs
- CommonXSendMessage.cs
- SecurityElement.cs
- FrameSecurityDescriptor.cs
- SizeFConverter.cs
- ReverseComparer.cs
- SqlReferenceCollection.cs
- FrameworkElement.cs
- designeractionlistschangedeventargs.cs
- DetailsViewPagerRow.cs
- manifestimages.cs
- WSTrust.cs
- OneWayChannelFactory.cs
- WpfKnownMemberInvoker.cs
- remotingproxy.cs
- DataGridColumnHeaderAutomationPeer.cs
- NetSectionGroup.cs
- DesignUtil.cs
- MachineKeyConverter.cs
- HttpListenerPrefixCollection.cs
- CompilationPass2TaskInternal.cs
- SafeThemeHandle.cs
- UnsafeNativeMethods.cs
- DataBoundLiteralControl.cs
- GridLength.cs
- ComponentResourceManager.cs
- ViewGenerator.cs
- TextBox.cs
- ProfileSettingsCollection.cs
- ScriptingJsonSerializationSection.cs
- RegexReplacement.cs
- WebSysDescriptionAttribute.cs
- NetMsmqBinding.cs
- IPAddress.cs
- TextServicesContext.cs
- RemoteWebConfigurationHost.cs
- UnsafeNativeMethodsTablet.cs
- Exceptions.cs
- PageThemeParser.cs
- DataRowComparer.cs
- XmlCharCheckingReader.cs
- CheckBoxAutomationPeer.cs
- XmlSchemaObjectTable.cs
- SQLString.cs
- MSAAEventDispatcher.cs
- SessionPageStatePersister.cs
- AttachedPropertyBrowsableForChildrenAttribute.cs
- DataSourceCache.cs
- SettingsProperty.cs
- WorkflowServiceNamespace.cs
- AbsoluteQuery.cs
- _SslStream.cs
- ButtonColumn.cs
- HttpCookie.cs
- CollectionContainer.cs
- XmlExtensionFunction.cs
- InternalsVisibleToAttribute.cs
- SimpleRecyclingCache.cs
- OptimizedTemplateContent.cs
- SendMailErrorEventArgs.cs
- xdrvalidator.cs
- CloudCollection.cs
- ArrayWithOffset.cs
- EnumerableValidator.cs
- MetadataCollection.cs
- XmlSiteMapProvider.cs
- UserNameSecurityToken.cs
- CharAnimationUsingKeyFrames.cs
- Exception.cs
- MenuCommand.cs
- WebPartDisplayModeEventArgs.cs
- AnnotationDocumentPaginator.cs