38 lines
2.1 KiB
C#
38 lines
2.1 KiB
C#
using Npgsql.Internal;
|
|
using Npgsql.Util;
|
|
using System.Diagnostics.CodeAnalysis;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Transactions;
|
|
|
|
namespace Npgsql;
|
|
|
|
sealed class MultiHostConnectorPoolWrapper : ConnectorSource
|
|
{
|
|
internal override bool OwnsConnectors => false;
|
|
|
|
readonly MultiHostConnectorPool _wrappedSource;
|
|
|
|
public MultiHostConnectorPoolWrapper(NpgsqlConnectionStringBuilder settings, string connString, MultiHostConnectorPool source) : base(settings, connString)
|
|
=> _wrappedSource = source;
|
|
|
|
internal override (int Total, int Idle, int Busy) Statistics => _wrappedSource.Statistics;
|
|
|
|
internal override void Clear() => _wrappedSource.Clear();
|
|
internal override ValueTask<NpgsqlConnector> Get(NpgsqlConnection conn, NpgsqlTimeout timeout, bool async, CancellationToken cancellationToken)
|
|
=> _wrappedSource.Get(conn, timeout, async, cancellationToken);
|
|
internal override bool TryGetIdleConnector([NotNullWhen(true)] out NpgsqlConnector? connector)
|
|
=> throw new NpgsqlException("Npgsql bug: trying to get an idle connector from " + nameof(MultiHostConnectorPoolWrapper));
|
|
internal override ValueTask<NpgsqlConnector?> OpenNewConnector(NpgsqlConnection conn, NpgsqlTimeout timeout, bool async, CancellationToken cancellationToken)
|
|
=> throw new NpgsqlException("Npgsql bug: trying to open a new connector from " + nameof(MultiHostConnectorPoolWrapper));
|
|
internal override void Return(NpgsqlConnector connector)
|
|
=> _wrappedSource.Return(connector);
|
|
|
|
internal override void AddPendingEnlistedConnector(NpgsqlConnector connector, Transaction transaction)
|
|
=> _wrappedSource.AddPendingEnlistedConnector(connector, transaction);
|
|
internal override bool TryRemovePendingEnlistedConnector(NpgsqlConnector connector, Transaction transaction)
|
|
=> _wrappedSource.TryRemovePendingEnlistedConnector(connector, transaction);
|
|
internal override bool TryRentEnlistedPending(Transaction transaction, NpgsqlConnection connection,
|
|
[NotNullWhen(true)] out NpgsqlConnector? connector)
|
|
=> _wrappedSource.TryRentEnlistedPending(transaction, connection, out connector);
|
|
} |