|
@@ -21,7 +21,7 @@ size_t client_count = 0;
|
|
|
NodeIO::NodeIO(tcp::socket &&socket, nodenum_t nodenum) :
|
|
|
sock(std::move(socket)), node_num(nodenum), msgsize_inflight(0),
|
|
|
chunksize_inflight(0), recv_msgsize_inflight(0),
|
|
|
- recv_chunksize_inflight(0)
|
|
|
+ recv_chunksize_inflight(0), bytes_sent(0)
|
|
|
{
|
|
|
}
|
|
|
|
|
@@ -88,6 +88,7 @@ void NodeIO::async_send_commands()
|
|
|
commands_deque_lock.lock();
|
|
|
assert(!commands_inflight.empty() &&
|
|
|
&(commands_inflight.front()) == commandp);
|
|
|
+ bytes_sent = bytes_sent + 5 + std::get<2>(*commandp);
|
|
|
uint8_t *data = std::get<1>(*commandp);
|
|
|
commands_inflight.pop_front();
|
|
|
if (commands_inflight.size() > 0) {
|