Skip to content

Commit 0cfc025

Browse files
author
Emile Joubert
committed
Style
1 parent 5750778 commit 0cfc025

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public abstract class ModelBase : IFullModel
8585
private BasicRecoverOkEventHandler m_basicRecoverOk;
8686

8787
public ManualResetEvent m_flowControlBlock = new ManualResetEvent(true);
88-
private Object flowSendLock = new object();
88+
private Object m_flowSendLock = new object();
8989

9090
public event ModelShutdownEventHandler ModelShutdown
9191
{
@@ -376,7 +376,7 @@ public void ModelSend(MethodBase method, ContentHeaderBase header, byte[] body)
376376
{
377377
if (method.HasContent)
378378
{
379-
lock (flowSendLock)
379+
lock (m_flowSendLock)
380380
{
381381
m_flowControlBlock.WaitOne();
382382
m_session.Transmit(new Command(method, header, body));
@@ -465,11 +465,13 @@ public void HandleChannelFlow(bool active)
465465
_Private_ChannelFlowOk(active);
466466
}
467467
else
468-
lock (flowSendLock)
468+
{
469+
lock (m_flowSendLock)
469470
{
470471
m_flowControlBlock.Reset();
471472
_Private_ChannelFlowOk(active);
472473
}
474+
}
473475
}
474476

475477
public void HandleConnectionStart(byte versionMajor,

0 commit comments

Comments
 (0)