Skip to content

Commit 2edfc82

Browse files
danielmarbachlukebakken
authored andcommitted
My preference for the field name (feel free to drop)
1 parent a5a9915 commit 2edfc82

File tree

4 files changed

+9
-9
lines changed

4 files changed

+9
-9
lines changed

projects/RabbitMQ.Client/Impl/AutorecoveringChannel.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ internal sealed class AutorecoveringChannel : IChannel, IRecoverable
4949
private AutorecoveringConnection _connection;
5050
private RecoveryAwareChannel _innerChannel;
5151
private bool _disposed;
52-
private int _isDisposing;
52+
private int _disposeSignaled;
5353

5454
private ushort _prefetchCountConsumer;
5555
private ushort _prefetchCountGlobal;
@@ -258,7 +258,7 @@ public override string ToString()
258258

259259
public async ValueTask DisposeAsync()
260260
{
261-
if (Interlocked.Exchange(ref _isDisposing, 1) != 0)
261+
if (Interlocked.Exchange(ref _disposeSignaled, 1) != 0)
262262
{
263263
return;
264264
}

projects/RabbitMQ.Client/Impl/AutorecoveringConnection.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ internal sealed partial class AutorecoveringConnection : IConnection
5151

5252
private Connection _innerConnection;
5353
private bool _disposed;
54-
private int _isDisposing;
54+
private int _disposeSignaled;
5555

5656
private Connection InnerConnection
5757
{
@@ -274,7 +274,7 @@ await RecordChannelAsync(autorecoveringChannel, channelsSemaphoreHeld: false, ca
274274

275275
public async ValueTask DisposeAsync()
276276
{
277-
if (Interlocked.Exchange(ref _isDisposing, 1) != 0)
277+
if (Interlocked.Exchange(ref _disposeSignaled, 1) != 0)
278278
{
279279
return;
280280
}

projects/RabbitMQ.Client/Impl/Channel.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ internal partial class Channel : IChannel, IRecoverable
6464
internal readonly IConsumerDispatcher ConsumerDispatcher;
6565

6666
private bool _disposed;
67-
private int _isDisposing;
67+
private int _disposeSignaled;
6868

6969
public Channel(ISession session, CreateChannelOptions createChannelOptions)
7070
{
@@ -529,7 +529,7 @@ void IDisposable.Dispose()
529529

530530
protected virtual void Dispose(bool disposing)
531531
{
532-
if (Interlocked.Exchange(ref _isDisposing, 1) != 0)
532+
if (Interlocked.Exchange(ref _disposeSignaled, 1) != 0)
533533
{
534534
return;
535535
}
@@ -567,7 +567,7 @@ await DisposeAsyncCore()
567567

568568
protected virtual async ValueTask DisposeAsyncCore()
569569
{
570-
if (Interlocked.Exchange(ref _isDisposing, 1) != 0)
570+
if (Interlocked.Exchange(ref _disposeSignaled, 1) != 0)
571571
{
572572
return;
573573
}

projects/RabbitMQ.Client/Impl/Connection.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ namespace RabbitMQ.Client.Framing
4747
internal sealed partial class Connection : IConnection
4848
{
4949
private bool _disposed;
50-
private int _isDisposing;
50+
private int _disposeSignaled;
5151
private volatile bool _closed;
5252

5353
private readonly ConnectionConfig _config;
@@ -491,7 +491,7 @@ internal ValueTask WriteAsync(RentedMemory frames, CancellationToken cancellatio
491491

492492
public async ValueTask DisposeAsync()
493493
{
494-
if (Interlocked.Exchange(ref _isDisposing, 1) != 0)
494+
if (Interlocked.Exchange(ref _disposeSignaled, 1) != 0)
495495
{
496496
return;
497497
}

0 commit comments

Comments
 (0)