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
- StringPropertyBuilder.cs
- ExtentCqlBlock.cs
- InstanceCreationEditor.cs
- DesignerCategoryAttribute.cs
- DefaultHttpHandler.cs
- BaseTemplateBuildProvider.cs
- ContainerParagraph.cs
- WebBrowserEvent.cs
- log.cs
- Attributes.cs
- ViewStateModeByIdAttribute.cs
- WindowInteractionStateTracker.cs
- SerializerDescriptor.cs
- ValidationHelper.cs
- CompilerGeneratedAttribute.cs
- ClientRoleProvider.cs
- RootDesignerSerializerAttribute.cs
- TokenCreationException.cs
- TextEditorParagraphs.cs
- BooleanStorage.cs
- UTF8Encoding.cs
- BitmapFrameDecode.cs
- MetadataArtifactLoader.cs
- MergeExecutor.cs
- ErrorTableItemStyle.cs
- RadioButton.cs
- ContractCodeDomInfo.cs
- DateTime.cs
- ListViewItemEventArgs.cs
- Lock.cs
- Char.cs
- XmlWellformedWriter.cs
- TypeLoadException.cs
- XmlSchemaValidator.cs
- ListBindingHelper.cs
- ContainsRowNumberChecker.cs
- WorkflowNamespace.cs
- PartBasedPackageProperties.cs
- NameValuePair.cs
- TextMetrics.cs
- RawContentTypeMapper.cs
- Transform3DCollection.cs
- WsatTransactionHeader.cs
- DelegatingConfigHost.cs
- DiagnosticsConfiguration.cs
- _SecureChannel.cs
- LinkConverter.cs
- XPathNode.cs
- BinaryNode.cs
- TreeNodeStyleCollection.cs
- ButtonAutomationPeer.cs
- IdentityNotMappedException.cs
- ImageMapEventArgs.cs
- DataBindingHandlerAttribute.cs
- WebResourceAttribute.cs
- EdmRelationshipRoleAttribute.cs
- PointCollectionValueSerializer.cs
- XmlEnumAttribute.cs
- ChtmlTextWriter.cs
- HtmlLink.cs
- NTAccount.cs
- XamlPathDataSerializer.cs
- AttachedProperty.cs
- CodeSnippetStatement.cs
- SqlCommand.cs
- HMAC.cs
- SelectionRange.cs
- Queue.cs
- HwndTarget.cs
- LinkLabel.cs
- MessageQueueConverter.cs
- MemberMaps.cs
- _SSPISessionCache.cs
- ConnectionPoint.cs
- ReadWriteObjectLock.cs
- ServiceManager.cs
- HttpModuleAction.cs
- ProxyManager.cs
- AutomationProperty.cs
- FrameworkElement.cs
- FileDialog_Vista.cs
- XmlSchemas.cs
- BridgeDataReader.cs
- HiddenField.cs
- ImageClickEventArgs.cs
- SectionVisual.cs
- ParamArrayAttribute.cs
- WeakRefEnumerator.cs
- VirtualDirectoryMappingCollection.cs
- InkCanvas.cs
- WebSysDefaultValueAttribute.cs
- ContainerVisual.cs
- DuplicateContext.cs
- ProtocolViolationException.cs
- DbConnectionPoolIdentity.cs
- TypeTypeConverter.cs
- ElementAtQueryOperator.cs
- ProcessHostFactoryHelper.cs
- SoapFormatExtensions.cs
- PeerCollaborationPermission.cs