diff --git a/a8/tcplistener.h b/a8/tcplistener.h index 09caa3b..d745648 100644 --- a/a8/tcplistener.h +++ b/a8/tcplistener.h @@ -25,6 +25,9 @@ namespace a8 std::string bind_address; unsigned short bind_port = 0; std::atomic send_node_num = {0}; + std::atomic sent_node_num = {0}; + std::atomic sent_bytes_num = {0}; + std::atomic recv_bytes_num = {0}; public: TcpListener(unsigned short max_client_cnt=0xEFFF); diff --git a/a8/tcpsession2.cc b/a8/tcpsession2.cc index 4e3c25c..2e92cad 100644 --- a/a8/tcpsession2.cc +++ b/a8/tcpsession2.cc @@ -354,6 +354,8 @@ namespace a8 a8::SendQueueNode *pdelnode = work_node_; work_node_ = work_node_->next; --master->send_node_num; + ++master->sent_node_num; + master->sent_bytes_num += pdelnode->sent_bytes; if (!work_node_) { send_buffer_mutex_.lock(); if (top_node_) {