FilesExpand file tree

 main

/

MultiHostConnectorPoolWrapper.cs

Copy path

BlameMore file actions

BlameMore file actions

Latest commit

 

History

History

History

38 lines (31 loc) · 2.15 KB

 main

/

MultiHostConnectorPoolWrapper.cs

Top

File metadata and controls

• Code
• Blame

38 lines (31 loc) · 2.15 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

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);

}