File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
src/NetMQ/Core/Transports/Pgm Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -214,18 +214,19 @@ private void BeginSending()
214
214
int bufferSize = m_outBufferSize - sizeof ( ushort ) ;
215
215
216
216
int bytes = m_encoder . Encode ( ref buffer , bufferSize ) ;
217
+ int lastBytes = bytes ;
217
218
while ( bytes < bufferSize )
218
219
{
219
220
if ( ! m_moreFlag && offset == 0xffff )
220
- offset = ( ushort ) bytes ;
221
+ offset = ( ushort ) bytes ;
221
222
Msg msg = new Msg ( ) ;
222
223
if ( m_session . PullMsg ( ref msg ) != PullMsgResult . Ok )
223
224
break ;
224
225
m_moreFlag = msg . HasMore ;
225
226
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 ;
229
230
}
230
231
231
232
// If there are no data to write stop polling for output.
You can’t perform that action at this time.
0 commit comments