Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- MaskedTextBox.cs
- CodeCastExpression.cs
- StatusBar.cs
- SqlDataSourceView.cs
- WeakEventTable.cs
- TreeViewEvent.cs
- Misc.cs
- GroupLabel.cs
- Visual.cs
- RuntimeConfigurationRecord.cs
- Utils.cs
- WebPartEventArgs.cs
- SecurityPolicySection.cs
- BuildManagerHost.cs
- InkCanvasSelectionAdorner.cs
- HtmlForm.cs
- VariableModifiersHelper.cs
- Vector.cs
- ReliabilityContractAttribute.cs
- UnionCodeGroup.cs
- WorkflowDesignerColors.cs
- RegexGroup.cs
- EmbeddedMailObject.cs
- BinHexDecoder.cs
- CallbackHandler.cs
- Hashtable.cs
- Win32KeyboardDevice.cs
- NavigationWindow.cs
- Misc.cs
- DataGridViewSelectedCellCollection.cs
- basecomparevalidator.cs
- PageStatePersister.cs
- CancellableEnumerable.cs
- ListControlDesigner.cs
- RenderData.cs
- CheckBoxStandardAdapter.cs
- XhtmlBasicSelectionListAdapter.cs
- SvcFileManager.cs
- ListViewAutomationPeer.cs
- Vector.cs
- RequestCacheEntry.cs
- RepeatInfo.cs
- ServiceMetadataBehavior.cs
- CrossAppDomainChannel.cs
- LinkedList.cs
- HtmlInputHidden.cs
- TextSerializer.cs
- DebugView.cs
- oledbmetadatacolumnnames.cs
- MetadataArtifactLoaderFile.cs
- SudsWriter.cs
- DisplayMemberTemplateSelector.cs
- BaseDataListActionList.cs
- Variable.cs
- DetailsViewRowCollection.cs
- safelinkcollection.cs
- RectAnimationClockResource.cs
- SoapConverter.cs
- GridViewCancelEditEventArgs.cs
- OleDbDataReader.cs
- FormViewInsertEventArgs.cs
- UnmanagedMarshal.cs
- Matrix.cs
- XmlSchemaAny.cs
- TemplateInstanceAttribute.cs
- BindingList.cs
- ConstructorNeedsTagAttribute.cs
- RelationHandler.cs
- ListControlActionList.cs
- PreviewPageInfo.cs
- ISAPIRuntime.cs
- CultureSpecificCharacterBufferRange.cs
- WpfPayload.cs
- SQLGuid.cs
- SchemaComplexType.cs
- PriorityQueue.cs
- Type.cs
- ComboBox.cs
- VectorAnimationUsingKeyFrames.cs
- DBSqlParserTableCollection.cs
- SwitchElementsCollection.cs
- EdmPropertyAttribute.cs
- X509ChainElement.cs
- FilterEventArgs.cs
- HwndAppCommandInputProvider.cs
- DrawListViewSubItemEventArgs.cs
- Int16Converter.cs
- GradientBrush.cs
- EmptyEnumerable.cs
- TrustVersion.cs
- WinCategoryAttribute.cs
- UnsafeNativeMethods.cs
- TypeBrowser.xaml.cs
- UnaryQueryOperator.cs
- MessageBox.cs
- X509UI.cs
- Inline.cs
- SafeNativeMethods.cs
- CodeCatchClause.cs
- DataGridTextBox.cs