Browse Source

show queue size

pull/102/head
orignal 10 years ago
parent
commit
9b3ac19b58
  1. 1
      HTTPServer.cpp
  2. 2
      Streaming.cpp
  3. 2
      Streaming.h

1
HTTPServer.cpp

@ -817,6 +817,7 @@ namespace util
{ {
s << it.first << "->" << it.second->GetRemoteIdentity ().GetIdentHash ().ToBase32 () << ".b32.i2p "; s << it.first << "->" << it.second->GetRemoteIdentity ().GetIdentHash ().ToBase32 () << ".b32.i2p ";
s << " [" << it.second->GetNumSentBytes () << ":" << it.second->GetNumReceivedBytes () << "]"; s << " [" << it.second->GetNumSentBytes () << ":" << it.second->GetNumReceivedBytes () << "]";
s << " [out:" << it.second->GetSendQueueSize () << "][in:" << it.second->GetReceiveQueueSize () << "]";
s << "<br>"<< std::endl; s << "<br>"<< std::endl;
} }
} }

2
Streaming.cpp

@ -412,6 +412,8 @@ namespace stream
if (isEmpty) if (isEmpty)
ScheduleResend (); ScheduleResend ();
} }
else
delete packet;
return true; return true;
} }
else else

2
Streaming.h

@ -100,6 +100,8 @@ namespace stream
size_t GetNumSentBytes () const { return m_NumSentBytes; }; size_t GetNumSentBytes () const { return m_NumSentBytes; };
size_t GetNumReceivedBytes () const { return m_NumReceivedBytes; }; size_t GetNumReceivedBytes () const { return m_NumReceivedBytes; };
size_t GetSendQueueSize () const { return m_SentPackets.size (); };
size_t GetReceiveQueueSize () const { return m_ReceiveQueue.size (); };
private: private:

Loading…
Cancel
Save