This commit is contained in:
David Rose 2009-01-22 20:17:22 +00:00
parent 07461ccbdd
commit 42fa5dd7ac
2 changed files with 6 additions and 3 deletions

View File

@ -159,7 +159,7 @@ get_current_queue_size() const {
//
// If block is true, this will not return false if the
// send queue is filled; instead, it will wait until
// this is space available.
// there is space available.
////////////////////////////////////////////////////////////////////
bool ConnectionWriter::
send(const Datagram &datagram, const PT(Connection) &connection, bool block) {
@ -198,7 +198,7 @@ send(const Datagram &datagram, const PT(Connection) &connection, bool block) {
//
// If block is true, this will not return false if the
// send queue is filled; instead, it will wait until
// this is space available.
// there is space available.
////////////////////////////////////////////////////////////////////
bool ConnectionWriter::
send(const Datagram &datagram, const PT(Connection) &connection,

View File

@ -22,7 +22,10 @@
// Description:
////////////////////////////////////////////////////////////////////
DatagramQueue::
DatagramQueue() : _cv(_cvlock) {
DatagramQueue() :
_cvlock("DatagramQueue::_cvlock"),
_cv(_cvlock)
{
_shutdown = false;
_max_queue_size = get_net_max_write_queue();
}