Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Fix member naming
  • Loading branch information
roji committed Sep 29, 2022
commit e068128aadbf4407ffb808829829acf62291f972
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ internal sealed class DtcProxyShimFactory
private readonly ConcurrentQueue<ITransactionTransmitter> _cachedTransmitters = new();
private readonly ConcurrentQueue<ITransactionReceiver> _cachedReceivers = new();

private static readonly int _maxCachedInterfaces = Environment.ProcessorCount * 2;
private static readonly int s_maxCachedInterfaces = Environment.ProcessorCount * 2;

private readonly EventWaitHandle _eventHandle;

Expand Down Expand Up @@ -353,7 +353,7 @@ internal ITransactionTransmitter GetCachedTransmitter(ITransaction transaction)

internal void ReturnCachedTransmitter(ITransactionTransmitter transmitter)
{
if (_cachedTransmitters.Count < _maxCachedInterfaces)
if (_cachedTransmitters.Count < s_maxCachedInterfaces)
{
transmitter.Reset();
_cachedTransmitters.Enqueue(transmitter);
Expand All @@ -375,7 +375,7 @@ internal ITransactionReceiver GetCachedReceiver()

internal void ReturnCachedReceiver(ITransactionReceiver receiver)
{
if (_cachedReceivers.Count < _maxCachedInterfaces)
if (_cachedReceivers.Count < s_maxCachedInterfaces)
{
receiver.Reset();
_cachedReceivers.Enqueue(receiver);
Expand Down