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
- SelectedCellsCollection.cs
- HttpValueCollection.cs
- IntSecurity.cs
- ColumnPropertiesGroup.cs
- DataChangedEventManager.cs
- PolicyStatement.cs
- Win32MouseDevice.cs
- ADRoleFactoryConfiguration.cs
- ListControlConvertEventArgs.cs
- ConvertEvent.cs
- ObjectDataSourceMethodEditor.cs
- SafeNativeMethods.cs
- GlyphingCache.cs
- MediaContext.cs
- SlotInfo.cs
- ConvertersCollection.cs
- TextViewBase.cs
- ISAPIApplicationHost.cs
- WorkflowApplicationCompletedException.cs
- WebPartDisplayModeEventArgs.cs
- Base64Stream.cs
- Point4D.cs
- HttpDictionary.cs
- ActivityCodeGenerator.cs
- SafePointer.cs
- ProtocolViolationException.cs
- OpCopier.cs
- RelOps.cs
- PropertyEmitter.cs
- XpsS0ValidatingLoader.cs
- BaseTemplateCodeDomTreeGenerator.cs
- ExceptionCollection.cs
- GeneralTransform3DTo2DTo3D.cs
- DrawingContextDrawingContextWalker.cs
- SqlDataSourceFilteringEventArgs.cs
- InputScopeNameConverter.cs
- DetailsViewUpdateEventArgs.cs
- OdbcEnvironmentHandle.cs
- DiscoveryClientChannelBase.cs
- SqlDataSourceSelectingEventArgs.cs
- X509Utils.cs
- Types.cs
- DBNull.cs
- WebHttpSecurityModeHelper.cs
- DataGridColumnCollection.cs
- UndoEngine.cs
- ImageBrush.cs
- EventlogProvider.cs
- JoinGraph.cs
- ResourceWriter.cs
- Currency.cs
- NullableIntSumAggregationOperator.cs
- SamlAuthenticationStatement.cs
- WrapPanel.cs
- CanonicalFormWriter.cs
- HostingEnvironmentWrapper.cs
- SqlDataSourceCache.cs
- X509InitiatorCertificateServiceElement.cs
- ImageAttributes.cs
- ToolStripSeparator.cs
- TextLineResult.cs
- UrlPropertyAttribute.cs
- MimeMultiPart.cs
- IntegerFacetDescriptionElement.cs
- HtmlUtf8RawTextWriter.cs
- SafeTokenHandle.cs
- PenLineJoinValidation.cs
- GridViewRow.cs
- VisualStateChangedEventArgs.cs
- TreeNodeMouseHoverEvent.cs
- XmlWrappingReader.cs
- ConstraintEnumerator.cs
- HtmlContainerControl.cs
- Comparer.cs
- PeerObject.cs
- CookielessData.cs
- XmlSerializerSection.cs
- AuthorizationSection.cs
- ConfigUtil.cs
- Visitor.cs
- __FastResourceComparer.cs
- WinFormsUtils.cs
- HtmlShim.cs
- TemplateField.cs
- DefaultAsyncDataDispatcher.cs
- XmlWhitespace.cs
- TabControl.cs
- EntityDataSourceWrapperPropertyDescriptor.cs
- IDReferencePropertyAttribute.cs
- HttpCapabilitiesEvaluator.cs
- XPathEmptyIterator.cs
- FileDialogCustomPlace.cs
- DbConvert.cs
- DbReferenceCollection.cs
- DataGridViewAccessibleObject.cs
- WebConfigurationHost.cs
- WebServiceData.cs
- StorageAssociationSetMapping.cs
- LinqDataSourceValidationException.cs
- _ListenerResponseStream.cs