Skip to content

Commit f9f5a0c

Browse files
authored
Merge pull request #873 from mikepmiller/master
PgmSender Encoding Fix
2 parents cc4dd5c + c1b6936 commit f9f5a0c

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/NetMQ/Core/Transports/Pgm/PgmSender.cs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -214,18 +214,19 @@ private void BeginSending()
214214
int bufferSize = m_outBufferSize - sizeof(ushort);
215215

216216
int bytes = m_encoder.Encode(ref buffer, bufferSize);
217+
int lastBytes = bytes;
217218
while (bytes < bufferSize)
218219
{
219220
if (!m_moreFlag && offset == 0xffff)
220-
offset = (ushort) bytes;
221+
offset = (ushort)bytes;
221222
Msg msg = new Msg();
222223
if (m_session.PullMsg(ref msg) != PullMsgResult.Ok)
223224
break;
224225
m_moreFlag = msg.HasMore;
225226
m_encoder.LoadMsg(ref msg);
226-
buffer = buffer + bytes;
227-
var n = m_encoder.Encode(ref buffer, bufferSize - bytes);
228-
bytes += n;
227+
buffer = buffer + lastBytes;
228+
lastBytes = m_encoder.Encode(ref buffer, bufferSize - bytes);
229+
bytes += lastBytes;
229230
}
230231

231232
// If there are no data to write stop polling for output.

0 commit comments

Comments
 (0)