43 references to AsyncHelper
System.Data (43)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (17)
1758AsyncHelper.ContinueTask(writeTask, tcs, () => tcs.SetResult(null)); 1764AsyncHelper.WaitForCompletion(reconnectTask, BulkCopyTimeout, () => { throw SQL.CR_ReconnectTimeout(); }, rethrowExceptions: false); 2051AsyncHelper.ContinueTask(task, source, () => { 2146AsyncHelper.ContinueTask(task, source, () => { 2187AsyncHelper.ContinueTask(readTask, source, () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.GetOpenTdsConnection()); 2195AsyncHelper.ContinueTask(task, source, onSuccess: () => { 2203AsyncHelper.ContinueTask(readTask, source, onSuccess: () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.GetOpenTdsConnection()); 2261AsyncHelper.ContinueTask(commandTask, source, () => { 2312AsyncHelper.ContinueTask(task, source, () => { 2356AsyncHelper.ContinueTask(writeTask, source, () => { 2482AsyncHelper.ContinueTask(task, source, () => { 2585AsyncHelper.ContinueTask(reconnectTask, cancellableReconnectTS, () => { cancellableReconnectTS.SetResult(null); }); 2587AsyncHelper.SetTimeoutException(cancellableReconnectTS, BulkCopyTimeout, 2589AsyncHelper.ContinueTask(cancellableReconnectTS.Task, source, 2608AsyncHelper.WaitForCompletion(reconnectTask, this.BulkCopyTimeout, () => { throw SQL.CR_ReconnectTimeout(); } ); 2642AsyncHelper.ContinueTask(internalResultsTask, source, () => WriteToServerInternalRestContinuedAsync(internalResultsTask.Result, cts, source), _connection.GetOpenTdsConnection()); 2699AsyncHelper.ContinueTask(readTask, source, () => {
fx\src\data\System\Data\SqlClient\SqlCommand.cs (16)
1277AsyncHelper.ContinueTask(execNQ, localCompletion, () => BeginExecuteNonQueryInternalReadStage(localCompletion)); 1661task = AsyncHelper.CreateContinuationTask(task, () => reader.Close()); 1781AsyncHelper.ContinueTask(writeTask, localCompletion, () => BeginExecuteXmlReaderInternalReadStage(localCompletion)); 2174AsyncHelper.ContinueTask(writeTask, localCompletion, () => BeginExecuteReaderInternalReadStage(localCompletion)); 3072AsyncHelper.SetTimeoutException(completion, timeout, SQL.CR_ReconnectTimeout, timeoutCTS.Token); 3073AsyncHelper.ContinueTask(reconnectTask, completion, 3085AsyncHelper.ContinueTask(subTask, completion, () => completion.SetResult(null)); 3091AsyncHelper.WaitForCompletion(reconnectTask, timeout, () => { throw SQL.CR_ReconnectTimeout(); }); 3370returnTask = AsyncHelper.CreateContinuationTask(fetchInputParameterEncryptionInfoTask, () => { 4283AsyncHelper.ContinueTask(describeParameterEncryptionTask, completion, 4292AsyncHelper.ContinueTask(subTask, completion, () => completion.SetResult(null)); 4358AsyncHelper.SetTimeoutException(completion, timeout, SQL.CR_ReconnectTimeout, timeoutCTS.Token); 4359AsyncHelper.ContinueTask(reconnectTask, completion, 4372AsyncHelper.ContinueTask(subTask, completion, () => completion.SetResult(null)); 4379AsyncHelper.WaitForCompletion(reconnectTask, timeout, () => { throw SQL.CR_ReconnectTimeout(); }); 4543task = AsyncHelper.CreateContinuationTask(writeTask, () => {
fx\src\data\System\Data\SqlClient\SqlConnection.cs (2)
1095AsyncHelper.WaitForCompletion(reconnectTask, 0, null, rethrowExceptions: false); // we do not need to deal with possible exceptions in reconnection 1367AsyncHelper.WaitForCompletion(reconnectTask, 0, null, rethrowExceptions: false);
fx\src\data\System\Data\SqlClient\SqlInternalConnectionTds.cs (2)
1126AsyncHelper.WaitForCompletion(reconnectTask, 0); // there is no specific timeout for BeginTransaction, uses ConnectTimeout 2048AsyncHelper.WaitForCompletion(reconnectTask, timeout);
fx\src\data\System\Data\SqlClient\TdsParser.cs (3)
8544AsyncHelper.ContinueTask(writeParamTask, completion, 9931return AsyncHelper.CreateContinuationTask<int, TdsParserStateObject>(unterminatedWriteTask, 10722return AsyncHelper.CreateContinuationTask<SqlColumnEncryptionInputParameterInfo, TdsParserStateObject>(terminatedWriteTask,
fx\src\data\System\Data\SqlClient\TdsParserStateObject.cs (3)
968return AsyncHelper.CreateContinuationTask(writePacketTask, () => { _pendingData = true; _messageStatus = 0; }); 2804AsyncHelper.ContinueTask(packetTask, completion, 2862task = AsyncHelper.CreateContinuationTask(task, CancelWritePacket, _parser.Connection);