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
- GroupBoxRenderer.cs
- cookiecontainer.cs
- ReadingWritingEntityEventArgs.cs
- BidOverLoads.cs
- Subset.cs
- ObjectSet.cs
- HTMLTagNameToTypeMapper.cs
- FtpWebResponse.cs
- EntityException.cs
- StaticExtensionConverter.cs
- RoleExceptions.cs
- QuaternionValueSerializer.cs
- DataListGeneralPage.cs
- ProxyManager.cs
- Application.cs
- SuspendDesigner.cs
- WebServiceErrorEvent.cs
- GroupStyle.cs
- WebHttpBinding.cs
- NoneExcludedImageIndexConverter.cs
- PartManifestEntry.cs
- StreamReader.cs
- FixedTextBuilder.cs
- DefaultPrintController.cs
- ConnectionStringsSection.cs
- TemplateControlParser.cs
- GridViewSelectEventArgs.cs
- DataTableClearEvent.cs
- MethodBody.cs
- VirtualPathUtility.cs
- CommonGetThemePartSize.cs
- PropertyPathWorker.cs
- AnonymousIdentificationModule.cs
- RemotingSurrogateSelector.cs
- DependencyPropertyDescriptor.cs
- TaskResultSetter.cs
- ControlAdapter.cs
- PriorityBinding.cs
- TypeConverter.cs
- SerializationSectionGroup.cs
- BaseCodeDomTreeGenerator.cs
- ViewStateChangedEventArgs.cs
- CodeParameterDeclarationExpression.cs
- SoapReflectionImporter.cs
- StateElement.cs
- ThrowHelper.cs
- DocumentOrderQuery.cs
- WriteableBitmap.cs
- XmlCharType.cs
- ExtenderProvidedPropertyAttribute.cs
- SqlAggregateChecker.cs
- TextTreeUndoUnit.cs
- CreateUserWizard.cs
- oledbconnectionstring.cs
- SamlAdvice.cs
- CallbackWrapper.cs
- CodeTypeReference.cs
- UnmanagedMarshal.cs
- ErrorWrapper.cs
- MailAddress.cs
- StackSpiller.Generated.cs
- MethodSignatureGenerator.cs
- DataGridViewHitTestInfo.cs
- EntityContainerRelationshipSetEnd.cs
- DateTimeAutomationPeer.cs
- WindowsAuthenticationModule.cs
- CharacterBufferReference.cs
- MessageFilterTable.cs
- BackoffTimeoutHelper.cs
- RotateTransform3D.cs
- UrlAuthorizationModule.cs
- OleDbException.cs
- Size3DValueSerializer.cs
- XmlIgnoreAttribute.cs
- _NestedSingleAsyncResult.cs
- SafeIUnknown.cs
- HttpResponse.cs
- DiscardableAttribute.cs
- ComponentResourceKey.cs
- MonthCalendar.cs
- WriteTimeStream.cs
- Transform.cs
- CodeDesigner.cs
- HuffCodec.cs
- DateTimeValueSerializerContext.cs
- ProcessManager.cs
- OrderedDictionaryStateHelper.cs
- ObjectDataProvider.cs
- ByteAnimationUsingKeyFrames.cs
- DbDataAdapter.cs
- RegexCompiler.cs
- TreeBuilder.cs
- RegularExpressionValidator.cs
- NetworkAddressChange.cs
- IPPacketInformation.cs
- ExpandoClass.cs
- TreeChangeInfo.cs
- MachineSettingsSection.cs
- CustomLineCap.cs
- HuffModule.cs