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
- SiteMapNodeCollection.cs
- LiteralTextContainerControlBuilder.cs
- StylusButton.cs
- Errors.cs
- ParseNumbers.cs
- TextChange.cs
- ImageMapEventArgs.cs
- DataGridToolTip.cs
- EditorPart.cs
- RepeaterItemCollection.cs
- CacheEntry.cs
- ProcessHost.cs
- Label.cs
- XmlUtil.cs
- BaseProcessor.cs
- WebServiceTypeData.cs
- MultiBindingExpression.cs
- HttpResponseWrapper.cs
- Opcode.cs
- PropertyBuilder.cs
- ConnectivityStatus.cs
- ComAdminWrapper.cs
- DecimalConverter.cs
- OleDbFactory.cs
- ProxyManager.cs
- EDesignUtil.cs
- BigIntegerStorage.cs
- MdiWindowListItemConverter.cs
- ResetableIterator.cs
- DateTime.cs
- ContentDefinition.cs
- PlatformCulture.cs
- EntityConnectionStringBuilderItem.cs
- DockProviderWrapper.cs
- WizardPanel.cs
- MetadataArtifactLoaderXmlReaderWrapper.cs
- ListViewPagedDataSource.cs
- OSEnvironmentHelper.cs
- DataGrid.cs
- BroadcastEventHelper.cs
- TransformProviderWrapper.cs
- FlowchartDesignerCommands.cs
- DoWorkEventArgs.cs
- PreviewPrintController.cs
- OleDbConnectionFactory.cs
- FaultReason.cs
- WebConfigurationManager.cs
- InvalidDataContractException.cs
- Multiply.cs
- AutomationProperty.cs
- CompositeFontFamily.cs
- NonceToken.cs
- WebPartManagerInternals.cs
- _SSPISessionCache.cs
- DispatcherProcessingDisabled.cs
- LinearGradientBrush.cs
- BitmapEffectrendercontext.cs
- MetafileHeader.cs
- CdpEqualityComparer.cs
- CharAnimationBase.cs
- DesignerListAdapter.cs
- DocumentsTrace.cs
- DataObject.cs
- EventItfInfo.cs
- UnicastIPAddressInformationCollection.cs
- OdbcRowUpdatingEvent.cs
- NeutralResourcesLanguageAttribute.cs
- odbcmetadatacollectionnames.cs
- ModuleElement.cs
- WorkflowNamespace.cs
- Gdiplus.cs
- DateTimeConverter2.cs
- NullableDecimalSumAggregationOperator.cs
- CorrelationToken.cs
- DbConnectionOptions.cs
- CommandConverter.cs
- PeerPresenceInfo.cs
- ColorConvertedBitmap.cs
- DocumentSequenceHighlightLayer.cs
- PageTheme.cs
- XmlSchemaInferenceException.cs
- NestedContainer.cs
- ThreadStartException.cs
- DesignerHelpers.cs
- IconConverter.cs
- ActivationArguments.cs
- ExtenderControl.cs
- EntityClassGenerator.cs
- ListViewVirtualItemsSelectionRangeChangedEvent.cs
- RawStylusActions.cs
- DataServiceHost.cs
- TextFindEngine.cs
- IssuanceLicense.cs
- GeneralTransform3DTo2DTo3D.cs
- SynchronousChannel.cs
- DataServiceBuildProvider.cs
- PostBackTrigger.cs
- SiteOfOriginPart.cs
- ToolStripPanelRenderEventArgs.cs
- ProfileService.cs