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
- HtmlInputButton.cs
- PromptBuilder.cs
- Material.cs
- XPathPatternParser.cs
- ConfigurationPropertyCollection.cs
- NativeMethods.cs
- PageContentCollection.cs
- XmlSerializerFactory.cs
- DataKey.cs
- DocumentGrid.cs
- XamlDesignerSerializationManager.cs
- InstanceLockTracking.cs
- Soap12ServerProtocol.cs
- FixedTextContainer.cs
- CurrentChangingEventArgs.cs
- TextBoxBase.cs
- FieldTemplateUserControl.cs
- DetailsViewRow.cs
- MethodCallTranslator.cs
- BrushValueSerializer.cs
- WebServiceEnumData.cs
- InOutArgumentConverter.cs
- XmlAttributes.cs
- EmissiveMaterial.cs
- LicenseManager.cs
- DataServiceRequestException.cs
- SqlFacetAttribute.cs
- DrawingCollection.cs
- Vector3DAnimation.cs
- GroupBoxRenderer.cs
- HandlerWithFactory.cs
- AnonymousIdentificationModule.cs
- SqlXml.cs
- AbstractDataSvcMapFileLoader.cs
- CompositeCollection.cs
- CultureInfoConverter.cs
- RuleSetCollection.cs
- Events.cs
- EncryptedPackageFilter.cs
- ObjectDataSource.cs
- XmlReaderSettings.cs
- LogAppendAsyncResult.cs
- PropertyBuilder.cs
- SequentialActivityDesigner.cs
- BamlRecordReader.cs
- AppliedDeviceFiltersEditor.cs
- FigureParagraph.cs
- codemethodreferenceexpression.cs
- StoragePropertyMapping.cs
- ParseNumbers.cs
- HtmlElementEventArgs.cs
- InitializerFacet.cs
- SurrogateDataContract.cs
- ExecutionContext.cs
- FormViewRow.cs
- IApplicationTrustManager.cs
- XmlSchemaSimpleContentExtension.cs
- CqlLexer.cs
- ReadOnlyCollectionBase.cs
- XmlSchemaRedefine.cs
- TdsParserStaticMethods.cs
- WebRequestModuleElementCollection.cs
- WindowsHyperlink.cs
- AndCondition.cs
- WebPartDescription.cs
- WindowManager.cs
- RSAPKCS1SignatureDeformatter.cs
- XmlSchemaComplexContent.cs
- NaturalLanguageHyphenator.cs
- RedirectionProxy.cs
- ReachDocumentSequenceSerializer.cs
- ContentTextAutomationPeer.cs
- ParameterToken.cs
- EncodingNLS.cs
- DbProviderFactory.cs
- OrderedEnumerableRowCollection.cs
- PieceNameHelper.cs
- DbDataSourceEnumerator.cs
- FontStretch.cs
- Constants.cs
- DataGridViewSortCompareEventArgs.cs
- DataControlHelper.cs
- BinaryNegotiation.cs
- SafeHandles.cs
- TableCellsCollectionEditor.cs
- FileChangesMonitor.cs
- TypeConverter.cs
- QueryMath.cs
- NextPreviousPagerField.cs
- DataGridViewElement.cs
- TrackingStringDictionary.cs
- IndependentAnimationStorage.cs
- BitmapMetadataBlob.cs
- CodeSpit.cs
- Model3D.cs
- MenuDesigner.cs
- GeometryHitTestResult.cs
- ProcessManager.cs
- LinqDataSourceDeleteEventArgs.cs
- _BasicClient.cs