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
- SqlDependencyUtils.cs
- SemanticAnalyzer.cs
- DbDataReader.cs
- Page.cs
- ParserContext.cs
- AccessedThroughPropertyAttribute.cs
- XmlMtomWriter.cs
- LogEntrySerializationException.cs
- StrongNameIdentityPermission.cs
- SetStoryboardSpeedRatio.cs
- ColumnMapVisitor.cs
- CqlLexerHelpers.cs
- CalendarDay.cs
- JsonServiceDocumentSerializer.cs
- SchemaNamespaceManager.cs
- OperationParameterInfoCollection.cs
- BitmapData.cs
- EmptyStringExpandableObjectConverter.cs
- LongPath.cs
- ConvertTextFrag.cs
- SQLString.cs
- SiblingIterators.cs
- AnnotationObservableCollection.cs
- WebContext.cs
- AnonymousIdentificationSection.cs
- AssemblyFilter.cs
- UserControl.cs
- ExceptionUtil.cs
- PenThread.cs
- COMException.cs
- XPathExpr.cs
- ASCIIEncoding.cs
- ApplicationSecurityManager.cs
- XPathAxisIterator.cs
- PasswordDeriveBytes.cs
- ObjectRef.cs
- CatalogPart.cs
- StaticFileHandler.cs
- XmlSchemaComplexContentExtension.cs
- LineProperties.cs
- WindowShowOrOpenTracker.cs
- Menu.cs
- SqlDelegatedTransaction.cs
- RegistryDataKey.cs
- ZoneButton.cs
- RawStylusInputReport.cs
- EntityContainerRelationshipSet.cs
- EntityDataSourceEntityTypeFilterConverter.cs
- Int64KeyFrameCollection.cs
- SequenceNumber.cs
- FusionWrap.cs
- TextBox.cs
- ValueUtilsSmi.cs
- XslAst.cs
- MetadataConversionError.cs
- WindowsListViewGroupHelper.cs
- ToolStripItemRenderEventArgs.cs
- MetadataArtifactLoaderCompositeResource.cs
- LocatorManager.cs
- ConnectionOrientedTransportBindingElement.cs
- DataBoundControlAdapter.cs
- CheckedListBox.cs
- CookieProtection.cs
- AccessibleObject.cs
- DesignTimeTemplateParser.cs
- GlobalAclOperationRequirement.cs
- Transform3DGroup.cs
- TextElementEnumerator.cs
- ImageListUtils.cs
- Triangle.cs
- HtmlInputCheckBox.cs
- WebScriptMetadataFormatter.cs
- InputProcessorProfilesLoader.cs
- TableSectionStyle.cs
- HtmlInputFile.cs
- WindowsGraphics.cs
- LocatorManager.cs
- httpapplicationstate.cs
- SqlProvider.cs
- LingerOption.cs
- GAC.cs
- XPathChildIterator.cs
- Vector3DAnimationUsingKeyFrames.cs
- InternalRelationshipCollection.cs
- GeneralTransform3DTo2DTo3D.cs
- TextSchema.cs
- Point3DCollectionConverter.cs
- AxParameterData.cs
- TdsParser.cs
- MissingMemberException.cs
- DSASignatureDeformatter.cs
- ContextBase.cs
- HttpBrowserCapabilitiesBase.cs
- DataReceivedEventArgs.cs
- PrintDialog.cs
- HttpListenerContext.cs
- XmlAttributeAttribute.cs
- PolyBezierSegmentFigureLogic.cs
- Stackframe.cs
- ListViewInsertionMark.cs