Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Semaphore.cs
- SqlRemoveConstantOrderBy.cs
- CheckBoxField.cs
- AnnotationHighlightLayer.cs
- String.cs
- SchemaCreator.cs
- PageThemeCodeDomTreeGenerator.cs
- TableCell.cs
- OdbcConnectionFactory.cs
- TextBlockAutomationPeer.cs
- UnlockInstanceCommand.cs
- StretchValidation.cs
- HighlightComponent.cs
- WebPartDisplayModeCollection.cs
- _Rfc2616CacheValidators.cs
- SimpleType.cs
- WebPartDisplayModeCollection.cs
- UniqueConstraint.cs
- ExpressionBuilderCollection.cs
- RecognizedAudio.cs
- _AutoWebProxyScriptHelper.cs
- IResourceProvider.cs
- FileClassifier.cs
- StrokeNodeOperations.cs
- EUCJPEncoding.cs
- XmlNullResolver.cs
- ActivityInstanceReference.cs
- tooltip.cs
- LogStore.cs
- WebContext.cs
- BitSet.cs
- Enlistment.cs
- CodeSubDirectoriesCollection.cs
- EntityTransaction.cs
- DbConnectionHelper.cs
- BridgeDataReader.cs
- EventlogProvider.cs
- DocumentViewerConstants.cs
- ArrangedElement.cs
- CodeVariableReferenceExpression.cs
- Panel.cs
- ResourceAttributes.cs
- SByteStorage.cs
- ObjectKeyFrameCollection.cs
- UnsafeMethods.cs
- ProgressBarRenderer.cs
- ListViewTableCell.cs
- PublisherMembershipCondition.cs
- ADMembershipUser.cs
- ConfigurationSection.cs
- RowUpdatingEventArgs.cs
- DbConnectionOptions.cs
- GradientBrush.cs
- ToolStripHighContrastRenderer.cs
- ToolboxItemCollection.cs
- RequestUriProcessor.cs
- ObjectPersistData.cs
- XsdBuildProvider.cs
- ValueTable.cs
- DesignerDataSchemaClass.cs
- TCPListener.cs
- securestring.cs
- TimeoutTimer.cs
- XmlEnumAttribute.cs
- GridPattern.cs
- UnmanagedBitmapWrapper.cs
- TimeEnumHelper.cs
- TextSelectionHighlightLayer.cs
- CodeSnippetCompileUnit.cs
- BufferedOutputStream.cs
- IdleTimeoutMonitor.cs
- _ShellExpression.cs
- HtmlGenericControl.cs
- activationcontext.cs
- SafeProcessHandle.cs
- DashStyles.cs
- ObjectTag.cs
- QuadraticBezierSegment.cs
- SafeIUnknown.cs
- BufferModeSettings.cs
- DocumentReference.cs
- DataRowChangeEvent.cs
- MetabaseSettings.cs
- ElapsedEventArgs.cs
- ModulesEntry.cs
- PackageFilter.cs
- PeerObject.cs
- NameScopePropertyAttribute.cs
- FormatException.cs
- EmptyEnumerator.cs
- InternalException.cs
- ExpressionReplacer.cs
- __ComObject.cs
- ToolStrip.cs
- FileChangeNotifier.cs
- Compiler.cs
- TabItemWrapperAutomationPeer.cs
- WpfWebRequestHelper.cs
- BinaryObjectInfo.cs
- TrackingProfileManager.cs