Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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. // //[....] //[....] //----------------------------------------------------------------------------- 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
- ObsoleteAttribute.cs
- TextEditorCopyPaste.cs
- HostProtectionPermission.cs
- CapabilitiesAssignment.cs
- OraclePermissionAttribute.cs
- WindowsAltTab.cs
- ObjectCache.cs
- SectionVisual.cs
- VisualTreeHelper.cs
- DropShadowEffect.cs
- RecordsAffectedEventArgs.cs
- ObservableCollection.cs
- AQNBuilder.cs
- ToolStripDropDownClosedEventArgs.cs
- RectangleHotSpot.cs
- LayoutEngine.cs
- FieldNameLookup.cs
- CrossSiteScriptingValidation.cs
- TextTreeObjectNode.cs
- UnsafeNativeMethodsTablet.cs
- ColorTransformHelper.cs
- MarginsConverter.cs
- DesignerVerb.cs
- EncryptedKeyIdentifierClause.cs
- AbsoluteQuery.cs
- VScrollBar.cs
- RewritingValidator.cs
- MachineKeySection.cs
- OperationInfoBase.cs
- HitTestWithPointDrawingContextWalker.cs
- TypedDataSourceCodeGenerator.cs
- XmlWriterSettings.cs
- Mouse.cs
- MatrixAnimationUsingPath.cs
- BamlVersionHeader.cs
- Win32KeyboardDevice.cs
- IISMapPath.cs
- ObjectDataSourceSelectingEventArgs.cs
- SqlDataSourceCache.cs
- FlowPanelDesigner.cs
- EffectiveValueEntry.cs
- ClientSettings.cs
- FontCacheLogic.cs
- WeakReferenceKey.cs
- GlyphRunDrawing.cs
- WebRequestModuleElementCollection.cs
- WebExceptionStatus.cs
- Baml2006Reader.cs
- Pkcs9Attribute.cs
- ArraySet.cs
- DesignerOptionService.cs
- _RequestCacheProtocol.cs
- SoapIncludeAttribute.cs
- NameValuePair.cs
- AutoGeneratedField.cs
- AnimationException.cs
- TypeValidationEventArgs.cs
- HandleRef.cs
- HwndKeyboardInputProvider.cs
- HttpWriter.cs
- TextSpanModifier.cs
- DescriptionAttribute.cs
- TdsParser.cs
- KeyedHashAlgorithm.cs
- Lease.cs
- XmlSchemaFacet.cs
- HwndKeyboardInputProvider.cs
- TemplateControlParser.cs
- HtmlWindow.cs
- CompositeKey.cs
- AsymmetricSignatureDeformatter.cs
- LambdaReference.cs
- SQLDecimalStorage.cs
- WCFBuildProvider.cs
- BamlMapTable.cs
- InProcStateClientManager.cs
- PlaceHolder.cs
- BindingFormattingDialog.cs
- CompoundFileStorageReference.cs
- RangeValueProviderWrapper.cs
- basecomparevalidator.cs
- SerializationHelper.cs
- GlyphingCache.cs
- FilterFactory.cs
- NumberSubstitution.cs
- DummyDataSource.cs
- EditorPartChrome.cs
- RefreshPropertiesAttribute.cs
- Encoding.cs
- DropShadowBitmapEffect.cs
- BitStream.cs
- NodeLabelEditEvent.cs
- RecommendedAsConfigurableAttribute.cs
- RelationalExpressions.cs
- ToolStripItemDataObject.cs
- MasterPageParser.cs
- BindUriHelper.cs
- Column.cs
- RedistVersionInfo.cs
- AddressUtility.cs