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
- DataServiceQueryContinuation.cs
- TypeBuilderInstantiation.cs
- SvcMapFileLoader.cs
- EntityClientCacheEntry.cs
- ButtonChrome.cs
- HtmlTableRow.cs
- SelectionItemPattern.cs
- OpacityConverter.cs
- OracleDateTime.cs
- SamlConditions.cs
- SoapAttributes.cs
- HostedTransportConfigurationManager.cs
- SmiXetterAccessMap.cs
- DataGridViewCheckBoxColumn.cs
- SmtpFailedRecipientsException.cs
- OpacityConverter.cs
- QueueAccessMode.cs
- TabControlAutomationPeer.cs
- InvalidOperationException.cs
- CopyNamespacesAction.cs
- CommandEventArgs.cs
- QilInvokeEarlyBound.cs
- WhitespaceRuleLookup.cs
- XmlSchemaSimpleContentRestriction.cs
- SmtpException.cs
- Transform3DGroup.cs
- CacheVirtualItemsEvent.cs
- NameValueCollection.cs
- PropertyFilterAttribute.cs
- XmlDataContract.cs
- ConstructorNeedsTagAttribute.cs
- LinearQuaternionKeyFrame.cs
- CalendarDesigner.cs
- FileSystemWatcher.cs
- MailDefinition.cs
- XmlSchemaComplexContentExtension.cs
- HttpListenerResponse.cs
- ToolStripLocationCancelEventArgs.cs
- SchemaObjectWriter.cs
- ExpandCollapsePattern.cs
- WebMessageBodyStyleHelper.cs
- StringKeyFrameCollection.cs
- EmptyCollection.cs
- MethodToken.cs
- StrongName.cs
- StringDictionaryEditor.cs
- Floater.cs
- SafeFileMappingHandle.cs
- DataColumnCollection.cs
- Guid.cs
- URLIdentityPermission.cs
- XmlText.cs
- WindowPattern.cs
- HttpRuntimeSection.cs
- StaticFileHandler.cs
- Pts.cs
- EventLogPermission.cs
- ChangeConflicts.cs
- DbProviderFactories.cs
- CursorConverter.cs
- FileRegion.cs
- XPathDescendantIterator.cs
- ParseNumbers.cs
- IItemContainerGenerator.cs
- StatusBarItemAutomationPeer.cs
- FieldDescriptor.cs
- RuntimeResourceSet.cs
- XmlSchemaSet.cs
- TraceLog.cs
- CompositeActivityTypeDescriptorProvider.cs
- XmlDictionary.cs
- JavaScriptSerializer.cs
- VideoDrawing.cs
- ListBindingHelper.cs
- QilInvokeEarlyBound.cs
- SerializableAttribute.cs
- TrackingMemoryStreamFactory.cs
- StrokeSerializer.cs
- WebPartEditorOkVerb.cs
- TemplatedWizardStep.cs
- AutomationEvent.cs
- DependsOnAttribute.cs
- PriorityBinding.cs
- PageParserFilter.cs
- NativeRightsManagementAPIsStructures.cs
- XmlValidatingReaderImpl.cs
- IdnElement.cs
- RequestCacheManager.cs
- EntityTypeBase.cs
- SqlUserDefinedAggregateAttribute.cs
- COM2ExtendedTypeConverter.cs
- Int32CAMarshaler.cs
- ServiceReference.cs
- MatrixCamera.cs
- StrongTypingException.cs
- HttpApplicationStateWrapper.cs
- FolderLevelBuildProvider.cs
- Int32KeyFrameCollection.cs
- SHA1.cs
- ToolStripPanel.cs