Code:
/ DotNET / DotNET / 8.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
- OleDbMetaDataFactory.cs
- MSAAWinEventWrap.cs
- SoapReflectionImporter.cs
- AudioDeviceOut.cs
- SocketAddress.cs
- IisTraceListener.cs
- PointLight.cs
- TraceHandler.cs
- ExpressionConverter.cs
- XmlQueryRuntime.cs
- ArithmeticLiteral.cs
- BitmapEffectState.cs
- SchemaTypeEmitter.cs
- CaseKeyBox.xaml.cs
- Imaging.cs
- PngBitmapEncoder.cs
- DrawingVisualDrawingContext.cs
- WebServicesInteroperability.cs
- VariableAction.cs
- Vector3DCollection.cs
- BamlBinaryReader.cs
- BindValidationContext.cs
- NameSpaceExtractor.cs
- WebPartManager.cs
- XmlUtil.cs
- EntityAdapter.cs
- COM2Enum.cs
- HttpProfileGroupBase.cs
- BitmapEffectInputData.cs
- SrgsElement.cs
- ProtocolsConfigurationEntry.cs
- IdentityNotMappedException.cs
- Constraint.cs
- DropShadowBitmapEffect.cs
- DrawingAttributeSerializer.cs
- VirtualPath.cs
- WmlLabelAdapter.cs
- HttpModule.cs
- FileUtil.cs
- QilTernary.cs
- NumericUpDownAcceleration.cs
- SortQuery.cs
- StickyNoteHelper.cs
- TypeBrowser.xaml.cs
- ResourceDescriptionAttribute.cs
- BufferedConnection.cs
- NamespaceDisplayAutomationPeer.cs
- AuthorizationSection.cs
- Base64Stream.cs
- DataGridTable.cs
- HtmlContainerControl.cs
- ViewKeyConstraint.cs
- _NestedMultipleAsyncResult.cs
- GroupBox.cs
- GeneralTransform3DTo2D.cs
- RenderingEventArgs.cs
- PackageRelationshipSelector.cs
- IPEndPointCollection.cs
- Journal.cs
- WebPartCollection.cs
- XmlNamespaceMapping.cs
- StylusDevice.cs
- SingleTagSectionHandler.cs
- OdbcConnectionHandle.cs
- EntityKeyElement.cs
- Error.cs
- NestedContainer.cs
- DesignerActionList.cs
- ObfuscationAttribute.cs
- LinqDataSourceStatusEventArgs.cs
- ItemCollection.cs
- ImageKeyConverter.cs
- X509Certificate.cs
- MetafileHeaderWmf.cs
- AmbientLight.cs
- SmtpSection.cs
- PersistenceTypeAttribute.cs
- Cursor.cs
- CultureNotFoundException.cs
- UInt64.cs
- IList.cs
- ClientSponsor.cs
- MultilineStringEditor.cs
- XmlDocumentSerializer.cs
- ToolStripItemDataObject.cs
- OrthographicCamera.cs
- DataGridViewToolTip.cs
- SqlDelegatedTransaction.cs
- _HeaderInfo.cs
- UriSection.cs
- WindowsListViewItemCheckBox.cs
- ExtendedPropertyDescriptor.cs
- ImportContext.cs
- UriTemplateClientFormatter.cs
- LayoutDump.cs
- OdbcDataReader.cs
- AspNetSynchronizationContext.cs
- TimelineGroup.cs
- HandoffBehavior.cs
- WebServiceHost.cs