4 types derived from DbConnectionInternal
System.Data (4)
fx\src\data\System\Data\Odbc\OdbcConnectionOpen.cs (1)
17
sealed internal class OdbcConnectionOpen :
DbConnectionInternal
{
fx\src\data\System\Data\OleDb\OleDbConnectionInternal.cs (1)
28
sealed internal class OleDbConnectionInternal :
DbConnectionInternal
, IDisposable {
fx\src\data\System\Data\ProviderBase\DbConnectionClosed.cs (1)
21
abstract internal class DbConnectionClosed :
DbConnectionInternal
{
fx\src\data\System\Data\SqlClient\SqlInternalConnection.cs (1)
28
abstract internal class SqlInternalConnection :
DbConnectionInternal
{
136 references to DbConnectionInternal
System.Data (136)
fx\src\data\System\Data\Odbc\OdbcConnectionFactory.cs (8)
37
override protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningObject) {
38
DbConnectionInternal
result = new OdbcConnectionOpen(owningObject as OdbcConnection, options as OdbcConnectionString);
63
override protected DbMetaDataFactory CreateMetaDataFactory(
DbConnectionInternal
internalConnection, out bool cacheMetaDataFactory){
130
override internal
DbConnectionInternal
GetInnerConnection(DbConnection connection) {
160
override internal void SetInnerConnectionEvent(DbConnection owningObject,
DbConnectionInternal
to) {
167
override internal bool SetInnerConnectionFrom(DbConnection owningObject,
DbConnectionInternal
to,
DbConnectionInternal
from) {
175
override internal void SetInnerConnectionTo(DbConnection owningObject,
DbConnectionInternal
to) {
fx\src\data\System\Data\OleDb\OleDbConnection.cs (1)
411
DbConnectionInternal
innerConnection = InnerConnection;
fx\src\data\System\Data\OleDb\OleDbConnectionFactory.cs (8)
37
override protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningObject) {
38
DbConnectionInternal
result = new OleDbConnectionInternal((OleDbConnectionString)options, (OleDbConnection)owningObject);
53
override protected DbMetaDataFactory CreateMetaDataFactory(
DbConnectionInternal
internalConnection, out bool cacheMetaDataFactory){
125
override internal
DbConnectionInternal
GetInnerConnection(DbConnection connection) {
155
override internal void SetInnerConnectionEvent(DbConnection owningObject,
DbConnectionInternal
to) {
162
override internal bool SetInnerConnectionFrom(DbConnection owningObject,
DbConnectionInternal
to,
DbConnectionInternal
from) {
170
override internal void SetInnerConnectionTo(DbConnection owningObject,
DbConnectionInternal
to) {
fx\src\data\System\Data\ProviderBase\DbConnectionClosed.cs (11)
65
internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
75
internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
82
internal static readonly
DbConnectionInternal
SingletonInstance = new DbConnectionClosedBusy(); // singleton object
90
internal static readonly
DbConnectionInternal
SingletonInstance = new DbConnectionOpenBusy(); // singleton object
99
internal static readonly
DbConnectionInternal
SingletonInstance = new DbConnectionClosedConnecting(); // singleton object
109
internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
113
internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
126
DbConnectionInternal
openConnection = retry.Task.Result;
140
internal static readonly
DbConnectionInternal
SingletonInstance = new DbConnectionClosedNeverOpened(); // singleton object
149
internal static readonly
DbConnectionInternal
SingletonInstance = new DbConnectionClosedPreviouslyOpened(); // singleton object
154
internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
fx\src\data\System\Data\ProviderBase\DbConnectionFactory.cs (24)
35
static Task<
DbConnectionInternal
>[] s_pendingOpenNonPooled = new Task<
DbConnectionInternal
>[Environment.ProcessorCount];
36
static Task<
DbConnectionInternal
> s_completedTask;
117
virtual protected DbMetaDataFactory CreateMetaDataFactory(
DbConnectionInternal
internalConnection, out bool cacheMetaDataFactory) {
124
internal
DbConnectionInternal
CreateNonPooledConnection(DbConnection owningConnection, DbConnectionPoolGroup poolGroup, DbConnectionOptions userOptions) {
132
DbConnectionInternal
newConnection = CreateConnection(connectionOptions, poolKey, poolGroupProviderInfo, null, owningConnection, userOptions);
141
internal
DbConnectionInternal
CreatePooledConnection(DbConnectionPool pool, DbConnection owningObject, DbConnectionOptions options, DbConnectionPoolKey poolKey, DbConnectionOptions userOptions) {
145
DbConnectionInternal
newConnection = CreateConnection(options, poolKey, poolGroupProviderInfo, pool, owningObject, userOptions);
176
static Task<
DbConnectionInternal
> GetCompletedTask()
179
TaskCompletionSource<
DbConnectionInternal
> source = new TaskCompletionSource<
DbConnectionInternal
>();
186
internal bool TryGetConnection(DbConnection owningConnection, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions,
DbConnectionInternal
oldConnection, out
DbConnectionInternal
connection) {
217
Task<
DbConnectionInternal
> newTask;
249
var
newConnection = CreateNonPooledConnection(owningConnection, poolGroup, userOptions);
444
internal DbMetaDataFactory GetMetaDataFactory(DbConnectionPoolGroup connectionPoolGroup,
DbConnectionInternal
internalConnection){
571
virtual protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningConnection, DbConnectionOptions userOptions) {
575
abstract protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningConnection);
583
abstract internal
DbConnectionInternal
GetInnerConnection(DbConnection connection);
591
abstract internal void SetInnerConnectionEvent(DbConnection owningObject,
DbConnectionInternal
to);
593
abstract internal bool SetInnerConnectionFrom(DbConnection owningObject,
DbConnectionInternal
to,
DbConnectionInternal
from) ;
595
abstract internal void SetInnerConnectionTo(DbConnection owningObject,
DbConnectionInternal
to);
fx\src\Data\System\Data\ProviderBase\DbConnectionHelper.cs (14)
29
private
DbConnectionInternal
_innerConnection;
99
DbConnectionInternal
connectionInternal = InnerConnection;
128
internal
DbConnectionInternal
InnerConnection {
155
DbConnectionInternal
innerConnection = _innerConnection; // Should not cause memory allocation...
248
DbConnectionInternal
innerConnection = InnerConnection;
276
private DbMetaDataFactory GetMetaDataFactory(
DbConnectionInternal
internalConnection) {
280
internal DbMetaDataFactory GetMetaDataFactoryInternal(
DbConnectionInternal
internalConnection) {
324
internal void SetInnerConnectionEvent(
DbConnectionInternal
to) {
340
OnStateChange(
DbConnectionInternal
.StateChangeOpen);
343
OnStateChange(
DbConnectionInternal
.StateChangeClosed);
359
internal bool SetInnerConnectionFrom(
DbConnectionInternal
to,
DbConnectionInternal
from) {
365
bool result = (from == Interlocked.CompareExchange<
DbConnectionInternal
>(ref _innerConnection, to, from));
371
internal void SetInnerConnectionTo(
DbConnectionInternal
to) {
fx\src\data\System\Data\ProviderBase\DbConnectionInternal.cs (4)
665
internal virtual bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
669
internal virtual bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
673
protected bool TryOpenConnectionInternal(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {
676
DbConnectionInternal
openConnection = null;
fx\src\data\System\Data\ProviderBase\DbConnectionPool.cs (46)
43
sealed private class TransactedConnectionList : List<
DbConnectionInternal
> {
57
public PendingGetConnection(long dueTime, DbConnection owner, TaskCompletionSource<
DbConnectionInternal
> completion, DbConnectionOptions userOptions) {
64
public TaskCompletionSource<
DbConnectionInternal
> Completion { get; private set; }
100
internal
DbConnectionInternal
GetTransactedObject(SysTx.Transaction transaction)
104
DbConnectionInternal
transactedObject = null;
144
internal void PutTransactedObject(SysTx.Transaction transaction,
DbConnectionInternal
transactedObject) {
243
internal void TransactionEnded(SysTx.Transaction transaction,
DbConnectionInternal
transactedObject)
436
private readonly ConcurrentStack<
DbConnectionInternal
> _stackOld = new ConcurrentStack<
DbConnectionInternal
>();
437
private readonly ConcurrentStack<
DbConnectionInternal
> _stackNew = new ConcurrentStack<
DbConnectionInternal
>();
457
private readonly List<
DbConnectionInternal
> _objectList;
493
_objectList = new List<
DbConnectionInternal
>(MaxPoolSize);
640
DbConnectionInternal
obj;
690
DbConnectionInternal
obj;
714
DbConnectionInternal
obj;
792
private
DbConnectionInternal
CreateObject(DbConnection owningObject, DbConnectionOptions userOptions,
DbConnectionInternal
oldConnection) {
793
DbConnectionInternal
newObj = null;
877
private void DeactivateObject(
DbConnectionInternal
obj)
1011
internal void DestroyObject(
DbConnectionInternal
obj) {
1104
DbConnectionInternal
connection = null;
1171
internal bool TryGetConnection(DbConnection owningObject, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions, out
DbConnectionInternal
connection) {
1223
private bool TryGetConnection(DbConnection owningObject, uint waitForMultipleObjectsTimeout, bool allowCreate, bool onlyOneCheckConnection, DbConnectionOptions userOptions, out
DbConnectionInternal
connection) {
1224
DbConnectionInternal
obj = null;
1406
private void PrepareConnection(DbConnection owningObject,
DbConnectionInternal
obj, SysTx.Transaction transaction) {
1431
internal
DbConnectionInternal
ReplaceConnection(DbConnection owningObject, DbConnectionOptions userOptions,
DbConnectionInternal
oldConnection) {
1435
DbConnectionInternal
newConnection = UserCreateRequest(owningObject, userOptions, oldConnection);
1447
private
DbConnectionInternal
GetFromGeneralPool() {
1448
DbConnectionInternal
obj = null;
1475
private
DbConnectionInternal
GetFromTransactedPool(out SysTx.Transaction transaction) {
1477
DbConnectionInternal
obj = null;
1557
DbConnectionInternal
newObj;
1615
internal void PutNewObject(
DbConnectionInternal
obj) {
1632
internal void PutObject(
DbConnectionInternal
obj, object owningObject) {
1658
internal void PutObjectFromTransactedPool(
DbConnectionInternal
obj) {
1694
List<
DbConnectionInternal
> reclaimedObjects = new List<
DbConnectionInternal
>();
1701
DbConnectionInternal
obj = _objectList[i];
1736
DbConnectionInternal
obj = reclaimedObjects[i];
1775
internal void TransactionEnded(SysTx.Transaction transaction,
DbConnectionInternal
transactedObject) {
1794
private
DbConnectionInternal
UserCreateRequest(DbConnection owningObject, DbConnectionOptions userOptions,
DbConnectionInternal
oldConnection = null) {
1798
DbConnectionInternal
obj = null;
fx\src\data\System\Data\SqlClient\SqlConnection.cs (11)
278
Tuple<TaskCompletionSource<
DbConnectionInternal
>, Task> _currentCompletion;
1097
OnStateChange(
DbConnectionInternal
.StateChangeClosed);
1404
TaskCompletionSource<
DbConnectionInternal
> completion = new TaskCompletionSource<
DbConnectionInternal
>(transaction);
1437
_currentCompletion = new Tuple<TaskCompletionSource<
DbConnectionInternal
>, Task>(completion, result.Task);
1455
TaskCompletionSource<
DbConnectionInternal
> _retry;
1459
public OpenAsyncRetry(SqlConnection parent, TaskCompletionSource<
DbConnectionInternal
> retry, TaskCompletionSource<object> result, CancellationTokenRegistration registration) {
1466
internal void Retry(Task<
DbConnectionInternal
> retryTask) {
1516
private bool TryOpen(TaskCompletionSource<
DbConnectionInternal
> retry) {
1551
private bool TryOpenInner(TaskCompletionSource<
DbConnectionInternal
> retry) {
1813
DbConnectionInternal
innerConnection = InnerConnection;
fx\src\data\System\Data\SqlClient\SqlConnectionFactory.cs (8)
35
override protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningConnection) {
39
override protected
DbConnectionInternal
CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool pool, DbConnection owningConnection, DbConnectionOptions userOptions) {
187
override protected DbMetaDataFactory CreateMetaDataFactory(
DbConnectionInternal
internalConnection, out bool cacheMetaDataFactory){
261
override internal
DbConnectionInternal
GetInnerConnection(DbConnection connection) {
291
override internal void SetInnerConnectionEvent(DbConnection owningObject,
DbConnectionInternal
to) {
298
override internal bool SetInnerConnectionFrom(DbConnection owningObject,
DbConnectionInternal
to,
DbConnectionInternal
from) {
306
override internal void SetInnerConnectionTo(DbConnection owningObject,
DbConnectionInternal
to) {
fx\src\data\System\Data\SqlClient\SqlInternalConnectionTds.cs (1)
2680
internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<
DbConnectionInternal
> retry, DbConnectionOptions userOptions) {