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
- QueryableDataSourceHelper.cs
- TdsParserSessionPool.cs
- XmlDataProvider.cs
- GeneralTransformCollection.cs
- GatewayIPAddressInformationCollection.cs
- IndentTextWriter.cs
- ConnectionPointConverter.cs
- TemplatePropertyEntry.cs
- SizeAnimationBase.cs
- IdnMapping.cs
- PublisherMembershipCondition.cs
- TableLayoutSettingsTypeConverter.cs
- HitTestWithGeometryDrawingContextWalker.cs
- PropertyItem.cs
- StatementContext.cs
- LockedBorderGlyph.cs
- AttachmentService.cs
- GenericsInstances.cs
- SystemBrushes.cs
- ReaderContextStackData.cs
- Separator.cs
- SqlBulkCopyColumnMappingCollection.cs
- UIElement3D.cs
- GroupItemAutomationPeer.cs
- PasswordTextNavigator.cs
- ADMembershipUser.cs
- WindowsEditBoxRange.cs
- BaseTemplateBuildProvider.cs
- processwaithandle.cs
- ViewCellRelation.cs
- CrossContextChannel.cs
- EntityDataSourceWrapperCollection.cs
- CompositeCollection.cs
- TraceLog.cs
- XmlStreamStore.cs
- FatalException.cs
- ReachIDocumentPaginatorSerializerAsync.cs
- EntityDataSourceStatementEditorForm.cs
- VirtualizedCellInfoCollection.cs
- MD5.cs
- SectionXmlInfo.cs
- SByte.cs
- Latin1Encoding.cs
- ElementNotEnabledException.cs
- GridViewRow.cs
- MemberPathMap.cs
- MaterializeFromAtom.cs
- DeferredTextReference.cs
- OdbcFactory.cs
- AvTrace.cs
- MetabaseSettingsIis7.cs
- SrgsDocumentParser.cs
- MessageAction.cs
- DataKeyCollection.cs
- PartialClassGenerationTask.cs
- SqlCacheDependencyDatabase.cs
- AuthorizationRule.cs
- AppliesToBehaviorDecisionTable.cs
- SortableBindingList.cs
- CaseCqlBlock.cs
- CodeSubDirectoriesCollection.cs
- GeneralTransformGroup.cs
- AcceptorSessionSymmetricTransportSecurityProtocol.cs
- TreeWalker.cs
- RepeaterItemEventArgs.cs
- LoginUtil.cs
- CompiledELinqQueryState.cs
- CacheOutputQuery.cs
- SafeProcessHandle.cs
- TemplatedWizardStep.cs
- TreeView.cs
- EdmSchemaError.cs
- DataGridViewImageCell.cs
- Highlights.cs
- PerformanceCounterNameAttribute.cs
- XmlIlVisitor.cs
- ValueProviderWrapper.cs
- DataGridViewCellErrorTextNeededEventArgs.cs
- Label.cs
- BoundingRectTracker.cs
- DependencyObject.cs
- Message.cs
- SmiSettersStream.cs
- TimeSpanConverter.cs
- References.cs
- StrokeRenderer.cs
- ContentPlaceHolderDesigner.cs
- ReadOnlyCollection.cs
- ErrorFormatter.cs
- PersonalizationAdministration.cs
- AsyncWaitHandle.cs
- FrameworkTemplate.cs
- TrustManagerPromptUI.cs
- DmlSqlGenerator.cs
- MemoryStream.cs
- InputDevice.cs
- AssemblyFilter.cs
- ImpersonationContext.cs
- DateTimeParse.cs
- DesignerAttribute.cs