Code:
/ DotNET / DotNET / 8.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
- FileVersionInfo.cs
- HtmlInputImage.cs
- DoubleLinkListEnumerator.cs
- Journaling.cs
- EnumerableRowCollection.cs
- PropertyRecord.cs
- ObjectViewListener.cs
- ArgumentException.cs
- FragmentQueryKB.cs
- NativeMethods.cs
- Constraint.cs
- ComEventsInfo.cs
- CollectionContainer.cs
- CounterNameConverter.cs
- SchemaComplexType.cs
- Bidi.cs
- QilInvoke.cs
- AnimationTimeline.cs
- PageSetupDialog.cs
- SmtpMail.cs
- Int32CollectionConverter.cs
- ImportContext.cs
- RightsManagementEncryptionTransform.cs
- TableItemStyle.cs
- ClientTargetSection.cs
- safelinkcollection.cs
- StructureChangedEventArgs.cs
- Interlocked.cs
- CursorConverter.cs
- XmlSerializerVersionAttribute.cs
- SByte.cs
- CapabilitiesPattern.cs
- EmulateRecognizeCompletedEventArgs.cs
- FormConverter.cs
- BuildDependencySet.cs
- Int32AnimationUsingKeyFrames.cs
- BindingExpression.cs
- ByValueEqualityComparer.cs
- GiveFeedbackEventArgs.cs
- EncryptedReference.cs
- ToolStripPanelRow.cs
- DefaultPropertyAttribute.cs
- DbProviderFactory.cs
- OracleDataAdapter.cs
- ObjectListDataBindEventArgs.cs
- AsyncResult.cs
- SequentialOutput.cs
- FormViewAutoFormat.cs
- PrimitiveCodeDomSerializer.cs
- NullableLongSumAggregationOperator.cs
- DbConvert.cs
- EventDescriptorCollection.cs
- XmlNamedNodeMap.cs
- CallContext.cs
- UshortList2.cs
- Normalizer.cs
- CompileLiteralTextParser.cs
- ApplicationServiceManager.cs
- TextFindEngine.cs
- TextServicesProperty.cs
- ParseChildrenAsPropertiesAttribute.cs
- SharedUtils.cs
- UnsafeNativeMethods.cs
- UnregisterInfo.cs
- ResolveDuplexAsyncResult.cs
- TransformProviderWrapper.cs
- Input.cs
- RuntimeConfig.cs
- TextBoxBase.cs
- Timer.cs
- CompressEmulationStream.cs
- DataListItem.cs
- Condition.cs
- DrawingContextDrawingContextWalker.cs
- EntityConnectionStringBuilder.cs
- ServiceBuildProvider.cs
- LogEntryHeaderDeserializer.cs
- TableItemPattern.cs
- WindowsFont.cs
- EventHandlerService.cs
- GridViewColumnCollectionChangedEventArgs.cs
- TargetControlTypeAttribute.cs
- PerformanceCountersElement.cs
- SqlBinder.cs
- DocumentApplicationJournalEntryEventArgs.cs
- PipelineModuleStepContainer.cs
- _DigestClient.cs
- WebConfigurationHost.cs
- LayoutEditorPart.cs
- RepeatButton.cs
- SecurityDescriptor.cs
- CustomPopupPlacement.cs
- CacheVirtualItemsEvent.cs
- MemberProjectedSlot.cs
- ListenerElementsCollection.cs
- ExpressionBuilderContext.cs
- WindowsAuthenticationModule.cs
- EdgeProfileValidation.cs
- DetailsViewDeleteEventArgs.cs
- RSAOAEPKeyExchangeFormatter.cs