From 379e4a5b83953e5ff3a0b89340c6bc0738ebc7ef Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Fri, 21 Jun 2019 14:12:22 +0800 Subject: [PATCH] 1 --- a8/tcplistener.h | 3 +++ a8/tcpsession2.cc | 2 ++ 2 files changed, 5 insertions(+) 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_) {