Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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
- DataServiceBehavior.cs
- PropertyPath.cs
- COAUTHINFO.cs
- EditorZoneBase.cs
- BitmapImage.cs
- SignerInfo.cs
- sqlstateclientmanager.cs
- DataGridCheckBoxColumn.cs
- RootBrowserWindow.cs
- FutureFactory.cs
- ObjectQueryExecutionPlan.cs
- WebPartCollection.cs
- DirtyTextRange.cs
- ScalarType.cs
- LineBreak.cs
- TableRow.cs
- PageAsyncTaskManager.cs
- RPIdentityRequirement.cs
- UnsafeMethods.cs
- SharedConnectionListener.cs
- SafeRegistryKey.cs
- DbConnectionOptions.cs
- EditorServiceContext.cs
- CodeMemberMethod.cs
- UpdateManifestForBrowserApplication.cs
- wmiutil.cs
- SqlTypeConverter.cs
- _LazyAsyncResult.cs
- TempFiles.cs
- TextSelectionProcessor.cs
- DependencyStoreSurrogate.cs
- Message.cs
- ResolveResponse.cs
- WindowsListViewItemStartMenu.cs
- MenuCommand.cs
- listitem.cs
- ServiceModelConfiguration.cs
- Descriptor.cs
- Compiler.cs
- DbgUtil.cs
- SchemaContext.cs
- MethodCallConverter.cs
- DecimalConstantAttribute.cs
- MergeLocalizationDirectives.cs
- Attributes.cs
- embossbitmapeffect.cs
- SafeIUnknown.cs
- Html32TextWriter.cs
- PlaceHolder.cs
- Classification.cs
- VisualBasicSettings.cs
- CryptoStream.cs
- CurrentChangingEventManager.cs
- PeerPresenceInfo.cs
- WorkflowElementDialogWindow.xaml.cs
- ProfilePropertySettingsCollection.cs
- Encoder.cs
- PriorityChain.cs
- DbQueryCommandTree.cs
- SqlConnectionPoolGroupProviderInfo.cs
- DNS.cs
- ChannelServices.cs
- ProfileGroupSettings.cs
- AutoGeneratedField.cs
- PeerFlooder.cs
- MimeFormReflector.cs
- RegionIterator.cs
- Rect.cs
- safesecurityhelperavalon.cs
- WorkflowDesigner.cs
- NativeCompoundFileAPIs.cs
- SqlDataSourceEnumerator.cs
- PinnedBufferMemoryStream.cs
- EventDescriptor.cs
- XmlNavigatorFilter.cs
- TypeToken.cs
- CommunicationException.cs
- OutputScopeManager.cs
- RtfToken.cs
- BindableTemplateBuilder.cs
- Int64KeyFrameCollection.cs
- HtmlValidationSummaryAdapter.cs
- CodePrimitiveExpression.cs
- SqlRowUpdatingEvent.cs
- Unit.cs
- BindStream.cs
- ResourceIDHelper.cs
- MemberDomainMap.cs
- SourceFileInfo.cs
- PropertyStore.cs
- UnSafeCharBuffer.cs
- XmlSortKeyAccumulator.cs
- BinaryNode.cs
- ActiveXHelper.cs
- StringUtil.cs
- RelationshipDetailsRow.cs
- SspiSecurityTokenProvider.cs
- HttpPostLocalhostServerProtocol.cs
- ObjectContext.cs
- securestring.cs