30 references to GetOpenTdsConnection
System.Data (30)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (21)
1189
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
1204
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
1216
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
1232
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
1772
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
1936
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
2059
_connection.
GetOpenTdsConnection
());
2187
AsyncHelper.ContinueTask(readTask, source, () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.
GetOpenTdsConnection
());
2203
AsyncHelper.ContinueTask(readTask, source, onSuccess: () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.
GetOpenTdsConnection
());
2205
}, connectionToDoom: _connection.
GetOpenTdsConnection
());
2234
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
2267
}, _connection.
GetOpenTdsConnection
());
2318
}, _connection.
GetOpenTdsConnection
(), _ => CopyBatchesAsyncContinuedOnError(cleanupParser: false), () => CopyBatchesAsyncContinuedOnError(cleanupParser: true));
2369
}, connectionToDoom: _connection.
GetOpenTdsConnection
(), onFailure: _ => CopyBatchesAsyncContinuedOnError(cleanupParser: false));
2386
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
2514
}, _connection.
GetOpenTdsConnection
());
2559
SqlInternalConnectionTds internalConnection = _connection.
GetOpenTdsConnection
();
2596
_parserLock = _connection.
GetOpenTdsConnection
()._parserLock;
2613
_parserLock = _connection.
GetOpenTdsConnection
()._parserLock;
2642
AsyncHelper.ContinueTask(internalResultsTask, source, () => WriteToServerInternalRestContinuedAsync(internalResultsTask.Result, cts, source), _connection.
GetOpenTdsConnection
());
2706
}, _connection.
GetOpenTdsConnection
());
fx\src\data\System\Data\SqlClient\SqlCommand.cs (8)
1419
_activeConnection.
GetOpenTdsConnection
().DecrementAsyncCount();
2257
_activeConnection.
GetOpenTdsConnection
().DecrementAsyncCount();
3256
SqlInternalConnectionTds internalConnectionTds = _activeConnection.
GetOpenTdsConnection
();
3387
SqlInternalConnectionTds internalConnectionTds = _activeConnection.
GetOpenTdsConnection
();
3458
SqlInternalConnectionTds internalConnectionTds = _activeConnection.
GetOpenTdsConnection
();
4402
_activeConnection.
GetOpenTdsConnection
().IncrementAsyncCount();
4544
_activeConnection.
GetOpenTdsConnection
(); // it will throw if connection is closed
4548
_activeConnection.
GetOpenTdsConnection
().DecrementAsyncCount();
fx\src\data\System\Data\SqlClient\SqlConnection.cs (1)
1285
SqlInternalConnectionTds tdsConn =
GetOpenTdsConnection
();