Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Data / System / Data / Common / DBAsyncResult.cs / 1305376 / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- HwndKeyboardInputProvider.cs
- UnauthorizedWebPart.cs
- Assert.cs
- ValueUnavailableException.cs
- OracleCommandBuilder.cs
- peernodeimplementation.cs
- NavigatorInput.cs
- LateBoundBitmapDecoder.cs
- EnumValAlphaComparer.cs
- _StreamFramer.cs
- CodeActivityContext.cs
- File.cs
- CorrelationManager.cs
- SEHException.cs
- SqlCommandBuilder.cs
- ListCardsInFileRequest.cs
- NamedElement.cs
- ExpressionPrinter.cs
- SplitterCancelEvent.cs
- DetailsView.cs
- StringDictionary.cs
- ToolStripOverflow.cs
- Control.cs
- SHA256Managed.cs
- CharEntityEncoderFallback.cs
- RectValueSerializer.cs
- nulltextcontainer.cs
- ToolboxItemCollection.cs
- DiagnosticStrings.cs
- StorageEndPropertyMapping.cs
- XmlSchemaAny.cs
- ViewCellRelation.cs
- TableCell.cs
- SynchronizationLockException.cs
- ResourceLoader.cs
- DbModificationClause.cs
- QilInvoke.cs
- QilFunction.cs
- DoubleIndependentAnimationStorage.cs
- DoubleLink.cs
- KernelTypeValidation.cs
- PathGradientBrush.cs
- FrameDimension.cs
- SortedDictionary.cs
- BoundColumn.cs
- Viewport3DAutomationPeer.cs
- WorkflowApplicationAbortedException.cs
- ConfigurationStrings.cs
- RoleGroupCollection.cs
- SafeFileMappingHandle.cs
- NavigationWindowAutomationPeer.cs
- DelegateSerializationHolder.cs
- OperandQuery.cs
- ExpressionEditorAttribute.cs
- MsmqAppDomainProtocolHandler.cs
- LogFlushAsyncResult.cs
- InstanceDescriptor.cs
- AutoGeneratedFieldProperties.cs
- StructuralCache.cs
- ImageFormat.cs
- FacetEnabledSchemaElement.cs
- Pen.cs
- TextContainerChangedEventArgs.cs
- DataGridViewCellErrorTextNeededEventArgs.cs
- RoleManagerSection.cs
- QueryPageSettingsEventArgs.cs
- DataSourceListEditor.cs
- LazyTextWriterCreator.cs
- X509CertificateChain.cs
- StorageAssociationSetMapping.cs
- ObsoleteAttribute.cs
- NamespaceTable.cs
- DataGridViewComboBoxEditingControl.cs
- CardSpaceException.cs
- LineProperties.cs
- TextElementAutomationPeer.cs
- CorePropertiesFilter.cs
- StreamInfo.cs
- UInt32.cs
- SynchronizationLockException.cs
- NotifyCollectionChangedEventArgs.cs
- TrackBarDesigner.cs
- ComponentEvent.cs
- TableParagraph.cs
- DBProviderConfigurationHandler.cs
- SecurityKeyType.cs
- Positioning.cs
- Camera.cs
- ReliableSessionElement.cs
- DoWorkEventArgs.cs
- HideDisabledControlAdapter.cs
- ListViewTableCell.cs
- XmlElementList.cs
- SamlConstants.cs
- PolyQuadraticBezierSegment.cs
- UpDownEvent.cs
- MappingItemCollection.cs
- HandlerFactoryWrapper.cs
- ModuleElement.cs
- SemaphoreSlim.cs