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
- ShadowGlyph.cs
- DrawingCollection.cs
- MasterPageBuildProvider.cs
- MemoryRecordBuffer.cs
- DataTableNameHandler.cs
- ProfileGroupSettingsCollection.cs
- DataGridViewTextBoxEditingControl.cs
- SymmetricKeyWrap.cs
- HttpFileCollection.cs
- X509CertificateClaimSet.cs
- KeyValuePair.cs
- EventLevel.cs
- ProfileEventArgs.cs
- NameValueSectionHandler.cs
- InkCanvasInnerCanvas.cs
- assemblycache.cs
- InheritanceContextChangedEventManager.cs
- OnOperation.cs
- WindowAutomationPeer.cs
- UriScheme.cs
- DataRowView.cs
- DbParameterCollection.cs
- safelink.cs
- ConditionalBranch.cs
- ETagAttribute.cs
- SapiAttributeParser.cs
- GlobalizationSection.cs
- DataSourceIDConverter.cs
- UnsafeNativeMethods.cs
- DelegateSerializationHolder.cs
- EventData.cs
- SymbolUsageManager.cs
- HtmlEncodedRawTextWriter.cs
- SerializationTrace.cs
- Line.cs
- AsyncOperationManager.cs
- BaseTransportHeaders.cs
- LinkLabel.cs
- UnsafeNetInfoNativeMethods.cs
- DesignOnlyAttribute.cs
- DataGridViewTextBoxCell.cs
- VirtualPathData.cs
- NodeInfo.cs
- WorkflowOperationErrorHandler.cs
- InputEventArgs.cs
- IncrementalReadDecoders.cs
- DeviceSpecificChoice.cs
- IntellisenseTextBox.cs
- EncryptedData.cs
- CompiledQuery.cs
- UnsafeNativeMethods.cs
- DecodeHelper.cs
- ToolStripDropDownItem.cs
- DnsPermission.cs
- NullableLongMinMaxAggregationOperator.cs
- DispatcherSynchronizationContext.cs
- Itemizer.cs
- TypeDependencyAttribute.cs
- CheckBoxBaseAdapter.cs
- BaseContextMenu.cs
- OneOfConst.cs
- ServerIdentity.cs
- DataSourceUtil.cs
- AssemblyHash.cs
- SelectionWordBreaker.cs
- DataRelationPropertyDescriptor.cs
- ComponentCollection.cs
- FrameworkPropertyMetadata.cs
- XomlCompilerError.cs
- SizeLimitedCache.cs
- ListViewItem.cs
- HtmlSelect.cs
- SrgsToken.cs
- _SpnDictionary.cs
- ProfileService.cs
- DomNameTable.cs
- ResourceReferenceExpressionConverter.cs
- CompModSwitches.cs
- COMException.cs
- SignatureToken.cs
- FormViewUpdatedEventArgs.cs
- EUCJPEncoding.cs
- IconBitmapDecoder.cs
- EventLogPermissionAttribute.cs
- DbProviderFactory.cs
- SingleConverter.cs
- DataGridViewEditingControlShowingEventArgs.cs
- DomainUpDown.cs
- DelegatedStream.cs
- X509InitiatorCertificateClientElement.cs
- ColorTransformHelper.cs
- SrgsElementFactory.cs
- XmlAttributeCollection.cs
- ToolStripHighContrastRenderer.cs
- XmlResolver.cs
- RepeatBehavior.cs
- WebConfigurationManager.cs
- TitleStyle.cs
- DataServiceQueryProvider.cs
- ImageAnimator.cs