Browse Source

fixed race condition

pull/50/head
orignal 11 years ago
parent
commit
5ed34cc52a
  1. 3
      Streaming.cpp

3
Streaming.cpp

@ -60,6 +60,7 @@ namespace stream
} }
// send ack for last message // send ack for last message
if (m_IsOpen)
SendQuickAck (); SendQuickAck ();
} }
else else
@ -127,9 +128,9 @@ namespace stream
if (flags & PACKET_FLAG_CLOSE) if (flags & PACKET_FLAG_CLOSE)
{ {
LogPrint ("Closed"); LogPrint ("Closed");
SendQuickAck (); // send ack for close explicitly?
m_IsOpen = false; m_IsOpen = false;
m_ReceiveQueue.WakeUp (); m_ReceiveQueue.WakeUp ();
m_ReceiveTimer.cancel ();
} }
} }

Loading…
Cancel
Save