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
- DataGridViewRowDividerDoubleClickEventArgs.cs
- _IPv6Address.cs
- SuppressIldasmAttribute.cs
- PlainXmlSerializer.cs
- ToolStripOverflow.cs
- MenuItemStyleCollection.cs
- SqlDataSource.cs
- TabControlCancelEvent.cs
- HtmlProps.cs
- DisplayMemberTemplateSelector.cs
- SID.cs
- XmlQualifiedNameTest.cs
- ResumeStoryboard.cs
- DataRowView.cs
- MultiView.cs
- Range.cs
- CollectionViewGroupInternal.cs
- SocketPermission.cs
- RenderDataDrawingContext.cs
- CapabilitiesAssignment.cs
- Grammar.cs
- WorkflowDataContext.cs
- __Filters.cs
- GZipDecoder.cs
- PropertyConverter.cs
- MachineKeyValidationConverter.cs
- PkcsUtils.cs
- HttpContextWrapper.cs
- XPathDocumentBuilder.cs
- PeerContact.cs
- ListBoxItemWrapperAutomationPeer.cs
- FormViewInsertEventArgs.cs
- RootBrowserWindow.cs
- TypeDescriptor.cs
- _SslState.cs
- ObjectPropertyMapping.cs
- DbProviderSpecificTypePropertyAttribute.cs
- XsltArgumentList.cs
- TextTreeText.cs
- DefaultValueTypeConverter.cs
- Geometry3D.cs
- PropertyValue.cs
- FixUpCollection.cs
- XmlSchemaSimpleContentRestriction.cs
- SchemaElementLookUpTable.cs
- KeyboardNavigation.cs
- AssemblyCache.cs
- MenuScrollingVisibilityConverter.cs
- ClientConvert.cs
- InputLangChangeEvent.cs
- MailDefinition.cs
- ControlParameter.cs
- MobileRedirect.cs
- QuadTree.cs
- FragmentQueryProcessor.cs
- SecurityTokenProvider.cs
- FileDialogPermission.cs
- MarshalByRefObject.cs
- OrthographicCamera.cs
- Point.cs
- CallbackHandler.cs
- LicFileLicenseProvider.cs
- DataGridViewAutoSizeColumnModeEventArgs.cs
- StorageComplexPropertyMapping.cs
- DataRecordInternal.cs
- OperandQuery.cs
- Pen.cs
- DataGridViewCellStyle.cs
- ResXFileRef.cs
- KeyTimeConverter.cs
- RijndaelManaged.cs
- VirtualizedCellInfoCollection.cs
- ClaimTypes.cs
- OptionalMessageQuery.cs
- NativeMethods.cs
- AuthenticatedStream.cs
- HttpServerUtilityWrapper.cs
- SerialPinChanges.cs
- SecurityVersion.cs
- ZoneButton.cs
- SourceSwitch.cs
- WebPartCatalogAddVerb.cs
- WebDisplayNameAttribute.cs
- SQLMoneyStorage.cs
- VisualStyleInformation.cs
- StrongName.cs
- SqlDuplicator.cs
- IntegerFacetDescriptionElement.cs
- ColorInterpolationModeValidation.cs
- WindowsAuthenticationEventArgs.cs
- TemplateInstanceAttribute.cs
- IgnoreFileBuildProvider.cs
- StringUtil.cs
- ResourceType.cs
- AnchoredBlock.cs
- GraphicsPath.cs
- AnimationLayer.cs
- CredentialCache.cs
- DataGridItemEventArgs.cs
- OdbcHandle.cs