2 types derived from DbConnectionInternal
System.Data.OleDb (2)
OleDbConnectionInternal.cs (1)
19internal sealed class OleDbConnectionInternal : DbConnectionInternal, IDisposable
System\Data\ProviderBase\DbConnectionClosed.cs (1)
11internal abstract class DbConnectionClosed : DbConnectionInternal
98 references to DbConnectionInternal
System.Data.OleDb (98)
OleDbConnection.cs (1)
406DbConnectionInternal innerConnection = InnerConnection;
OleDbConnectionFactory.cs (7)
36protected override DbConnectionInternal CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningObject) 38DbConnectionInternal result = new OleDbConnectionInternal((OleDbConnectionString)options, (OleDbConnection?)owningObject); 49protected override DbMetaDataFactory CreateMetaDataFactory(DbConnectionInternal internalConnection, out bool cacheMetaDataFactory) 139internal override void SetInnerConnectionEvent(DbConnection owningObject, DbConnectionInternal to) 144internal override bool SetInnerConnectionFrom(DbConnection owningObject, DbConnectionInternal to, DbConnectionInternal from) 154internal override void SetInnerConnectionTo(DbConnection owningObject, DbConnectionInternal to)
System\Data\ProviderBase\DbConnectionClosed.cs (9)
61internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 73internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 82internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedBusy(); // singleton object 92internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionOpenBusy(); // singleton object 103internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedConnecting(); // singleton object 114internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 128DbConnectionInternal openConnection = retry.Task.Result; 144internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedNeverOpened(); // singleton object 155internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedPreviouslyOpened(); // singleton object
System\Data\ProviderBase\DbConnectionFactory.cs (23)
26private static readonly Task<DbConnectionInternal?>[] s_pendingOpenNonPooled = new Task<DbConnectionInternal?>[Environment.ProcessorCount]; 27private static Task<DbConnectionInternal?>? s_completedTask; 59protected virtual DbMetaDataFactory CreateMetaDataFactory(DbConnectionInternal internalConnection, out bool cacheMetaDataFactory) 67internal DbConnectionInternal? CreateNonPooledConnection(DbConnection owningConnection, DbConnectionPoolGroup poolGroup, DbConnectionOptions? userOptions) 76DbConnectionInternal newConnection = CreateConnection(connectionOptions, poolKey, poolGroupProviderInfo, null, owningConnection, userOptions); 85internal DbConnectionInternal? CreatePooledConnection(DbConnectionPool pool, DbConnection? owningObject, DbConnectionOptions options, DbConnectionPoolKey poolKey, DbConnectionOptions? userOptions) 90DbConnectionInternal newConnection = CreateConnection(options, poolKey, poolGroupProviderInfo, pool, owningObject, userOptions); 111private static Task<DbConnectionInternal?> GetCompletedTask() 115TaskCompletionSource<DbConnectionInternal?> source = new TaskCompletionSource<DbConnectionInternal?>(); 122internal bool TryGetConnection(DbConnection owningConnection, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection, out DbConnectionInternal? connection) 156Task<DbConnectionInternal> newTask; 193var newConnection = CreateNonPooledConnection(owningConnection, poolGroup, userOptions); 410internal DbMetaDataFactory GetMetaDataFactory(DbConnectionPoolGroup connectionPoolGroup, DbConnectionInternal internalConnection) 548protected virtual DbConnectionInternal CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningConnection, DbConnectionOptions? userOptions) 553protected abstract DbConnectionInternal CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningConnection); 564internal abstract void SetInnerConnectionEvent(DbConnection owningObject, DbConnectionInternal to); 566internal abstract bool SetInnerConnectionFrom(DbConnection owningObject, DbConnectionInternal to, DbConnectionInternal from); 568internal abstract void SetInnerConnectionTo(DbConnection owningObject, DbConnectionInternal to);
System\Data\ProviderBase\DbConnectionHelper.cs (11)
19private DbConnectionInternal _innerConnection; 83DbConnectionInternal connectionInternal = InnerConnection; 111internal DbConnectionInternal InnerConnection 197DbConnectionInternal innerConnection = InnerConnection; 271internal void SetInnerConnectionEvent(DbConnectionInternal to) 291OnStateChange(DbConnectionInternal.StateChangeOpen); 295OnStateChange(DbConnectionInternal.StateChangeClosed); 310internal bool SetInnerConnectionFrom(DbConnectionInternal to, DbConnectionInternal from) 317bool result = (from == Interlocked.CompareExchange<DbConnectionInternal>(ref _innerConnection, to, from)); 323internal void SetInnerConnectionTo(DbConnectionInternal to)
System\Data\ProviderBase\DbConnectionInternal.Shared.cs (3)
473internal virtual bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 478protected bool TryOpenConnectionInternal(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 483DbConnectionInternal? openConnection;
System\Data\ProviderBase\DbConnectionPool.cs (44)
31private sealed class TransactedConnectionList : List<DbConnectionInternal> 47public PendingGetConnection(long dueTime, DbConnection owner, TaskCompletionSource<DbConnectionInternal> completion) 55public TaskCompletionSource<DbConnectionInternal> Completion { get; } 81internal DbConnectionInternal? GetTransactedObject(SysTx.Transaction transaction) 85DbConnectionInternal? transactedObject = null; 121internal void PutTransactedObject(SysTx.Transaction transaction, DbConnectionInternal transactedObject) 346private readonly ConcurrentStack<DbConnectionInternal> _stackOld = new ConcurrentStack<DbConnectionInternal>(); 347private readonly ConcurrentStack<DbConnectionInternal> _stackNew = new ConcurrentStack<DbConnectionInternal>(); 367private readonly List<DbConnectionInternal> _objectList; 401_objectList = new List<DbConnectionInternal>(MaxPoolSize); 536DbConnectionInternal? obj; 595DbConnectionInternal? obj; 616DbConnectionInternal? obj; 653private DbConnectionInternal CreateObject(DbConnection? owningObject, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection) 655DbConnectionInternal? newObj = null; 748private void DeactivateObject(DbConnectionInternal obj) 880internal void DestroyObject(DbConnectionInternal obj) 970DbConnectionInternal? connection = null; 1032internal bool TryGetConnection(DbConnection owningObject, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions, out DbConnectionInternal? connection) 1084private bool TryGetConnection(DbConnection owningObject, uint waitForMultipleObjectsTimeout, bool allowCreate, bool onlyOneCheckConnection, DbConnectionOptions? userOptions, out DbConnectionInternal? connection) 1086DbConnectionInternal? obj = null; 1286private void PrepareConnection(DbConnection owningObject, DbConnectionInternal obj, SysTx.Transaction? transaction) 1312internal DbConnectionInternal? ReplaceConnection(DbConnection owningObject, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection) 1316DbConnectionInternal? newConnection = UserCreateRequest(owningObject, userOptions, oldConnection); 1329private DbConnectionInternal? GetFromGeneralPool() 1331DbConnectionInternal? obj; 1362private DbConnectionInternal? GetFromTransactedPool(out SysTx.Transaction? transaction) 1365DbConnectionInternal? obj = null; 1451DbConnectionInternal newObj; 1514internal void PutNewObject(DbConnectionInternal obj) 1530internal void PutObject(DbConnectionInternal obj, object owningObject) 1558internal void PutObjectFromTransactedPool(DbConnectionInternal obj) 1596List<DbConnectionInternal> reclaimedObjects = new List<DbConnectionInternal>(); 1605DbConnectionInternal obj = _objectList[i]; 1646DbConnectionInternal obj = reclaimedObjects[i]; 1676private DbConnectionInternal? UserCreateRequest(DbConnection owningObject, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection = null) 1681DbConnectionInternal? obj = null;