3 types derived from DbConnectionInternal
System.Data.Odbc (3)
Common\System\Data\ProviderBase\DbConnectionClosed.cs (1)
8internal abstract partial class DbConnectionClosed : DbConnectionInternal
src\libraries\Common\src\System\Data\ProviderBase\DbConnectionClosed.cs (1)
10internal abstract partial class DbConnectionClosed : DbConnectionInternal
System\Data\Odbc\OdbcConnectionOpen.cs (1)
9internal sealed class OdbcConnectionOpen : DbConnectionInternal
94 references to DbConnectionInternal
System.Data.Odbc (94)
Common\System\Data\ProviderBase\DbConnectionFactory.cs (5)
13internal bool TryGetConnection(DbConnection owningConnection, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection, out DbConnectionInternal? connection) 47Task<DbConnectionInternal> newTask; 82var newConnection = CreateNonPooledConnection(owningConnection, poolGroup, userOptions);
Common\System\Data\ProviderBase\DbConnectionPool.cs (37)
25public PendingGetConnection(long dueTime, DbConnection owner, TaskCompletionSource<DbConnectionInternal> completion) 33public TaskCompletionSource<DbConnectionInternal> Completion { get; } 108private readonly ConcurrentStack<DbConnectionInternal> _stackOld = new ConcurrentStack<DbConnectionInternal>(); 109private readonly ConcurrentStack<DbConnectionInternal> _stackNew = new ConcurrentStack<DbConnectionInternal>(); 128private readonly List<DbConnectionInternal> _objectList; 164_objectList = new List<DbConnectionInternal>(MaxPoolSize); 296DbConnectionInternal? obj; 325DbConnectionInternal? obj; 347DbConnectionInternal? obj; 384private DbConnectionInternal CreateObject(DbConnection? owningObject, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection) 386DbConnectionInternal? newObj = null; 472private void DeactivateObject(DbConnectionInternal obj) 546internal void DestroyObject(DbConnectionInternal obj) 620DbConnectionInternal? connection = null; 664internal bool TryGetConnection(DbConnection owningObject, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions, out DbConnectionInternal? connection) 716private bool TryGetConnection(DbConnection owningObject, uint waitForMultipleObjectsTimeout, bool allowCreate, bool onlyOneCheckConnection, DbConnectionOptions? userOptions, out DbConnectionInternal? connection) 718DbConnectionInternal? obj = null; 854private void PrepareConnection(DbConnection owningObject, DbConnectionInternal obj) 880internal DbConnectionInternal? ReplaceConnection(DbConnection owningObject, DbConnectionOptions userOptions, DbConnectionInternal oldConnection) 882DbConnectionInternal? newConnection = UserCreateRequest(owningObject, userOptions, oldConnection); 895private DbConnectionInternal? GetFromGeneralPool() 897DbConnectionInternal? obj; 967DbConnectionInternal newObj; 1010internal void PutNewObject(DbConnectionInternal obj) 1020internal void PutObject(DbConnectionInternal obj, object owningObject) 1059List<DbConnectionInternal> reclaimedObjects = new List<DbConnectionInternal>(); 1068DbConnectionInternal obj = _objectList[i]; 1109DbConnectionInternal obj = reclaimedObjects[i]; 1138private DbConnectionInternal? UserCreateRequest(DbConnection owningObject, DbConnectionOptions? userOptions, DbConnectionInternal? oldConnection = null) 1143DbConnectionInternal? obj = null;
src\libraries\Common\src\System\Data\ProviderBase\DbConnectionClosed.cs (11)
35internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 45internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 52internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedBusy(); // singleton object 62internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionOpenBusy(); // singleton object 73internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedConnecting(); // singleton object 84internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 87internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 101DbConnectionInternal openConnection = retry.Task.Result; 117internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedNeverOpened(); // singleton object 128internal static readonly DbConnectionInternal SingletonInstance = new DbConnectionClosedPreviouslyOpened(); // singleton object 134internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions)
src\libraries\Common\src\System\Data\ProviderBase\DbConnectionFactory.cs (18)
26private static readonly Task<DbConnectionInternal?>[] s_pendingOpenNonPooled = new Task<DbConnectionInternal?>[Environment.ProcessorCount]; 27private static Task<DbConnectionInternal?>? s_completedTask; 81internal DbConnectionInternal? CreateNonPooledConnection(DbConnection owningConnection, DbConnectionPoolGroup poolGroup, DbConnectionOptions? userOptions) 90DbConnectionInternal? newConnection = CreateConnection(connectionOptions, poolKey, poolGroupProviderInfo, null, owningConnection, userOptions); 95internal DbConnectionInternal? CreatePooledConnection(DbConnectionPool pool, DbConnection? owningObject, DbConnectionOptions options, DbConnectionPoolKey poolKey, DbConnectionOptions? userOptions) 100DbConnectionInternal? newConnection = CreateConnection(options, poolKey, poolGroupProviderInfo, pool, owningObject, userOptions); 132private static Task<DbConnectionInternal?> GetCompletedTask() 135return s_completedTask ??= Task.FromResult<DbConnectionInternal?>(null); 360protected virtual DbConnectionInternal? CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningConnection, DbConnectionOptions? userOptions) 365internal DbMetaDataFactory GetMetaDataFactory(DbConnectionPoolGroup connectionPoolGroup, DbConnectionInternal internalConnection) 383protected abstract DbMetaDataFactory CreateMetaDataFactory(DbConnectionInternal internalConnection); 385protected abstract DbConnectionInternal CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningConnection); 393internal abstract DbConnectionInternal? GetInnerConnection(DbConnection connection); 399internal abstract void SetInnerConnectionEvent(DbConnection owningObject, DbConnectionInternal to); 401internal abstract bool SetInnerConnectionFrom(DbConnection owningObject, DbConnectionInternal to, DbConnectionInternal from); 403internal abstract void SetInnerConnectionTo(DbConnection owningObject, DbConnectionInternal to);
src\libraries\Common\src\System\Data\ProviderBase\DbConnectionInternal.cs (4)
303internal virtual bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 308internal virtual bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 313protected bool TryOpenConnectionInternal(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal>? retry, DbConnectionOptions? userOptions) 318DbConnectionInternal? openConnection;
System\Data\Odbc\OdbcConnectionFactory.cs (8)
30protected override DbConnectionInternal CreateConnection(DbConnectionOptions options, DbConnectionPoolKey poolKey, object poolGroupProviderInfo, DbConnectionPool? pool, DbConnection? owningObject) 33DbConnectionInternal result = new OdbcConnectionOpen((owningObject as OdbcConnection)!, (options as OdbcConnectionString)!); 56protected override DbMetaDataFactory CreateMetaDataFactory(DbConnectionInternal internalConnection) 88internal override DbConnectionInternal? GetInnerConnection(DbConnection connection) 112internal override void SetInnerConnectionEvent(DbConnection owningObject, DbConnectionInternal to) 117internal override bool SetInnerConnectionFrom(DbConnection owningObject, DbConnectionInternal to, DbConnectionInternal from) 127internal override void SetInnerConnectionTo(DbConnection owningObject, DbConnectionInternal to)
System\Data\Odbc\OdbcConnectionHelper.cs (11)
17private DbConnectionInternal _innerConnection; 90DbConnectionInternal connectionInternal = InnerConnection; 108internal DbConnectionInternal InnerConnection 140DbConnectionInternal innerConnection = _innerConnection; 215internal void SetInnerConnectionEvent(DbConnectionInternal to) 230OnStateChange(DbConnectionInternal.StateChangeOpen); 234OnStateChange(DbConnectionInternal.StateChangeClosed); 246internal bool SetInnerConnectionFrom(DbConnectionInternal to, DbConnectionInternal from) 251bool result = (from == Interlocked.CompareExchange<DbConnectionInternal>(ref _innerConnection, to, from)); 255internal void SetInnerConnectionTo(DbConnectionInternal to)