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
- PlanCompilerUtil.cs
- EdmToObjectNamespaceMap.cs
- SmiSettersStream.cs
- GroupItemAutomationPeer.cs
- ProfileServiceManager.cs
- EventProviderWriter.cs
- VirtualDirectoryMappingCollection.cs
- RankException.cs
- PartitionerQueryOperator.cs
- DataSourceView.cs
- DeclarativeCatalogPart.cs
- httpserverutility.cs
- _ListenerResponseStream.cs
- FileFormatException.cs
- ClockGroup.cs
- PhysicalFontFamily.cs
- ContentFileHelper.cs
- Message.cs
- DatePickerAutomationPeer.cs
- ConstantExpression.cs
- Timer.cs
- QuaternionKeyFrameCollection.cs
- XmlIlVisitor.cs
- ConfigurationErrorsException.cs
- OleDbRowUpdatedEvent.cs
- Win32PrintDialog.cs
- QilNode.cs
- UntrustedRecipientException.cs
- TypeName.cs
- MemberBinding.cs
- MenuItem.cs
- ComboBoxAutomationPeer.cs
- X500Name.cs
- ToolStripRendererSwitcher.cs
- ButtonAutomationPeer.cs
- ConnectionConsumerAttribute.cs
- CustomLineCap.cs
- SocketPermission.cs
- ValidationPropertyAttribute.cs
- ExportOptions.cs
- ObjectHandle.cs
- ValidationErrorCollection.cs
- AmbientLight.cs
- SQLGuidStorage.cs
- Trace.cs
- ActionFrame.cs
- XsltConvert.cs
- DnsPermission.cs
- TextProperties.cs
- TextTreeTextBlock.cs
- UntypedNullExpression.cs
- WindowsListViewGroup.cs
- MethodCallExpression.cs
- PriorityQueue.cs
- ExpressionCopier.cs
- SqlUnionizer.cs
- InkCanvasSelection.cs
- SoapCommonClasses.cs
- UnsafeNativeMethods.cs
- MouseGestureConverter.cs
- SelectionHighlightInfo.cs
- ChildrenQuery.cs
- TableCellCollection.cs
- X509CertificateValidator.cs
- WpfWebRequestHelper.cs
- TdsParserHelperClasses.cs
- CodeAccessSecurityEngine.cs
- RSACryptoServiceProvider.cs
- XmlValidatingReaderImpl.cs
- BitmapEffectDrawing.cs
- DesignTimeResourceProviderFactoryAttribute.cs
- CharEnumerator.cs
- ToolboxComponentsCreatingEventArgs.cs
- TiffBitmapEncoder.cs
- ObjectConverter.cs
- SponsorHelper.cs
- DoubleAnimationUsingPath.cs
- SQLResource.cs
- CodeTypeDelegate.cs
- FormatSettings.cs
- EqualityComparer.cs
- UmAlQuraCalendar.cs
- TextEffect.cs
- ClientData.cs
- AppDomainFactory.cs
- ExpressionLink.cs
- DeviceSpecificDialogCachedState.cs
- HttpCacheVary.cs
- JsonFormatReaderGenerator.cs
- LongSumAggregationOperator.cs
- MemberJoinTreeNode.cs
- XmlSiteMapProvider.cs
- OrderedDictionaryStateHelper.cs
- DiscoveryVersion.cs
- OleDbConnection.cs
- CallbackValidator.cs
- TrackingExtract.cs
- TextEffect.cs
- SemanticResolver.cs
- DataSourceXmlSerializationAttribute.cs