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
- CrossAppDomainChannel.cs
- EventLogPermissionAttribute.cs
- MemberDescriptor.cs
- DateTimePicker.cs
- XmlSchemaAny.cs
- PasswordPropertyTextAttribute.cs
- SystemIPv4InterfaceProperties.cs
- NetworkInformationPermission.cs
- SByte.cs
- StoreAnnotationsMap.cs
- UserNameSecurityToken.cs
- Thickness.cs
- ListSortDescription.cs
- EntityException.cs
- CountAggregationOperator.cs
- DragDropHelper.cs
- HtmlFormWrapper.cs
- Component.cs
- CqlLexer.cs
- OdbcConnectionPoolProviderInfo.cs
- PeerResolver.cs
- ProfileManager.cs
- DataGridViewCheckBoxColumn.cs
- StringCollectionMarkupSerializer.cs
- ExportException.cs
- _NetRes.cs
- TypeUsage.cs
- SelectionRangeConverter.cs
- JsonFormatWriterGenerator.cs
- ModelItemCollectionImpl.cs
- DataControlHelper.cs
- InstanceDescriptor.cs
- GridViewUpdateEventArgs.cs
- DesignerForm.cs
- DifferencingCollection.cs
- UnionExpr.cs
- SpellCheck.cs
- ByteStack.cs
- PackWebRequestFactory.cs
- Listbox.cs
- XmlByteStreamWriter.cs
- StsCommunicationException.cs
- TemplateBindingExpression.cs
- PiiTraceSource.cs
- ViewBox.cs
- MissingSatelliteAssemblyException.cs
- AppDomainUnloadedException.cs
- Model3DGroup.cs
- RankException.cs
- XPathSelectionIterator.cs
- HtmlGenericControl.cs
- HwndAppCommandInputProvider.cs
- HeaderedContentControl.cs
- MulticastNotSupportedException.cs
- QueryActivatableWorkflowsCommand.cs
- MetafileHeaderWmf.cs
- CurrencyManager.cs
- TextStore.cs
- RegexCharClass.cs
- EndpointDesigner.cs
- FontConverter.cs
- Matrix.cs
- SafeNativeMethodsCLR.cs
- BitmapSourceSafeMILHandle.cs
- SqlTriggerContext.cs
- HierarchicalDataBoundControlAdapter.cs
- WebPartMenuStyle.cs
- WebPartConnectionsConfigureVerb.cs
- CqlLexerHelpers.cs
- BatchServiceHost.cs
- Path.cs
- Point4D.cs
- RowBinding.cs
- SequentialActivityDesigner.cs
- LocalBuilder.cs
- SplitterEvent.cs
- DependencyPropertyAttribute.cs
- BCryptSafeHandles.cs
- InvalidCastException.cs
- ApplicationManager.cs
- LineSegment.cs
- RectangleHotSpot.cs
- PrivilegedConfigurationManager.cs
- RijndaelManagedTransform.cs
- XmlSigningNodeWriter.cs
- DesignerExtenders.cs
- XmlSchemaAppInfo.cs
- SafeCryptContextHandle.cs
- FlowStep.cs
- Directory.cs
- Module.cs
- RequestCacheValidator.cs
- CorruptingExceptionCommon.cs
- TypedElement.cs
- ConvertersCollection.cs
- UpdateTracker.cs
- SafePEFileHandle.cs
- Decoder.cs
- MethodExpr.cs
- CalculatedColumn.cs