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
- InstanceDataCollectionCollection.cs
- Int32Collection.cs
- ResXResourceWriter.cs
- SqlBulkCopyColumnMappingCollection.cs
- HasCopySemanticsAttribute.cs
- StylusShape.cs
- BuildTopDownAttribute.cs
- ContextDataSourceContextData.cs
- ACE.cs
- Int16Animation.cs
- NameValuePair.cs
- UserControlBuildProvider.cs
- GenericTextProperties.cs
- FileUpload.cs
- SBCSCodePageEncoding.cs
- GeometryGroup.cs
- StylusCollection.cs
- BinaryFormatterWriter.cs
- AttributeCollection.cs
- XmlValidatingReaderImpl.cs
- _IPv4Address.cs
- AgileSafeNativeMemoryHandle.cs
- FilterableAttribute.cs
- BooleanToVisibilityConverter.cs
- TagPrefixAttribute.cs
- DataGridAutomationPeer.cs
- SaveFileDialog.cs
- Subtree.cs
- FileDialog_Vista.cs
- HttpPostServerProtocol.cs
- Debug.cs
- TabPage.cs
- MobileUserControlDesigner.cs
- DynamicDataManager.cs
- DispatcherSynchronizationContext.cs
- HttpDebugHandler.cs
- FilterableAttribute.cs
- ConfigurationFileMap.cs
- XmlSchemaSimpleTypeUnion.cs
- ClientBuildManagerCallback.cs
- NegotiationTokenProvider.cs
- XmlDictionaryWriter.cs
- HebrewNumber.cs
- ADMembershipUser.cs
- ScrollContentPresenter.cs
- PreservationFileWriter.cs
- DirtyTextRange.cs
- ReflectEventDescriptor.cs
- QueueException.cs
- FixedFlowMap.cs
- EntityModelBuildProvider.cs
- SQLCharsStorage.cs
- CanonicalFontFamilyReference.cs
- PanelContainerDesigner.cs
- XPathExpr.cs
- WorkflowInstanceUnhandledExceptionRecord.cs
- LicenseException.cs
- DataColumnChangeEvent.cs
- PreviewControlDesigner.cs
- GradientStop.cs
- glyphs.cs
- CssStyleCollection.cs
- ItemAutomationPeer.cs
- GroupDescription.cs
- ConfigurationValue.cs
- ValueSerializerAttribute.cs
- DataSvcMapFileSerializer.cs
- ChangeInterceptorAttribute.cs
- SoapReflectionImporter.cs
- SQLInt16Storage.cs
- ProcessHostConfigUtils.cs
- TypePropertyEditor.cs
- SystemColors.cs
- DataGridBoolColumn.cs
- DefaultPropertyAttribute.cs
- PolicyLevel.cs
- ItemAutomationPeer.cs
- BaseAddressElementCollection.cs
- ResourceDescriptionAttribute.cs
- StoreConnection.cs
- DataListItemCollection.cs
- clipboard.cs
- ServiceDescriptionReflector.cs
- Rule.cs
- InheritanceUI.cs
- HMACSHA256.cs
- MenuDesigner.cs
- ModifiableIteratorCollection.cs
- CharStorage.cs
- ContextStaticAttribute.cs
- ActiveXHelper.cs
- PersistenceTask.cs
- HostVisual.cs
- Rotation3DKeyFrameCollection.cs
- ConfigDefinitionUpdates.cs
- TypeResolvingOptionsAttribute.cs
- Style.cs
- XamlTypeMapper.cs
- ModulesEntry.cs
- Context.cs