Code:
/ 4.0 / 4.0 / 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. //------------------------------------------------------------------------------ //// 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
- UdpAnnouncementEndpoint.cs
- MappingItemCollection.cs
- EnglishPluralizationService.cs
- Soap12ServerProtocol.cs
- GcSettings.cs
- HostingMessageProperty.cs
- Executor.cs
- TCEAdapterGenerator.cs
- DrawingContext.cs
- SecurityPolicySection.cs
- ObservableCollection.cs
- WorkflowMarkupSerializationManager.cs
- Substitution.cs
- WebRequestModuleElement.cs
- TimelineGroup.cs
- GuidTagList.cs
- DropShadowBitmapEffect.cs
- TextTreeInsertElementUndoUnit.cs
- ServiceReference.cs
- TreeChangeInfo.cs
- WeakReferenceList.cs
- Identifier.cs
- EnterpriseServicesHelper.cs
- MenuCommand.cs
- odbcmetadatafactory.cs
- XmlDocumentFieldSchema.cs
- ThicknessAnimationUsingKeyFrames.cs
- BitmapImage.cs
- _CookieModule.cs
- XmlSchemaComplexType.cs
- ColumnMapProcessor.cs
- SchemaAttDef.cs
- TcpHostedTransportConfiguration.cs
- ResourceDictionary.cs
- TextDecorationCollectionConverter.cs
- ExpressionBinding.cs
- HttpRequestCacheValidator.cs
- MailMessage.cs
- InputProcessorProfilesLoader.cs
- ColumnHeaderConverter.cs
- PlacementWorkspace.cs
- DiagnosticSection.cs
- CodeVariableDeclarationStatement.cs
- SqlCommand.cs
- _IPv4Address.cs
- WmlTextBoxAdapter.cs
- TogglePattern.cs
- DbReferenceCollection.cs
- NameValueConfigurationElement.cs
- DescendantBaseQuery.cs
- ToolStripOverflowButton.cs
- StdRegProviderWrapper.cs
- DebugHandleTracker.cs
- DataKey.cs
- RequestQueue.cs
- DbParameterHelper.cs
- FlowDecisionDesigner.xaml.cs
- PipelineModuleStepContainer.cs
- ZipIOExtraFieldPaddingElement.cs
- SplitterPanel.cs
- PageContentAsyncResult.cs
- PhonemeConverter.cs
- AutomationPropertyInfo.cs
- XamlNamespaceHelper.cs
- EventManager.cs
- SafeIUnknown.cs
- SamlAuthenticationStatement.cs
- LinqDataSourceValidationException.cs
- WindowsSolidBrush.cs
- LocalizationComments.cs
- SourceLineInfo.cs
- MeasurementDCInfo.cs
- PresentationSource.cs
- XmlAutoDetectWriter.cs
- Canvas.cs
- Light.cs
- AutomationEventArgs.cs
- DelegateBodyWriter.cs
- Size.cs
- printdlgexmarshaler.cs
- GenericTypeParameterConverter.cs
- OdbcParameterCollection.cs
- ViewStateChangedEventArgs.cs
- ClientBuildManagerCallback.cs
- X509SubjectKeyIdentifierClause.cs
- GridViewDeleteEventArgs.cs
- Range.cs
- XamlStyleSerializer.cs
- Latin1Encoding.cs
- SQLSingleStorage.cs
- BackgroundWorker.cs
- MSAAEventDispatcher.cs
- DoubleConverter.cs
- SystemResourceKey.cs
- XamlSerializerUtil.cs
- ThousandthOfEmRealPoints.cs
- MenuAutomationPeer.cs
- ThreadInterruptedException.cs
- RelAssertionDirectKeyIdentifierClause.cs
- DataGridViewComboBoxColumn.cs