server_common/a8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2019-06-21 14:12:22 +08:00
parent c086156f80
commit 379e4a5b83
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
a8/tcplistener.h
View File

@ -25,6 +25,9 @@ namespace a8
std::string bind_address;
unsigned short bind_port = 0;
std::atomic<long long> send_node_num = {0};
std::atomic<long long> sent_node_num = {0};
std::atomic<long long> sent_bytes_num = {0};
std::atomic<long long> recv_bytes_num = {0};
public:
TcpListener(unsigned short max_client_cnt=0xEFFF);

2
a8/tcpsession2.cc
View File

@ -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_) {