MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-17 07:20:55 +01:00
Code Issues Releases Wiki Activity

ircd::net::socket: Add static counters for totals.

Browse source
This commit is contained in:
Jason Volk 2019-07-08 01:22:16 -07:00
parent 400c8ecfcb
commit 015cbe53b1
2 changed files with 31 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
include/ircd/net/socket.h
View file

@ -48,6 +48,7 @@ struct ircd::net::socket
static uint64_t count; // monotonic
static uint64_t instances; // current socket count
static stat in_total, out_total;
uint64_t id {++count};
ip::tcp::socket sd;

38
ircd/net.cc
View file

@ -2697,6 +2697,12 @@ decltype(ircd::net::socket::instances)
ircd::net::socket::instances
{};
decltype(ircd::net::socket::in_total)
ircd::net::socket::in_total;
decltype(ircd::net::socket::out_total)
ircd::net::socket::out_total;
//
// socket
//
@ -3185,8 +3191,10 @@ try
boost::asio::error::eof, boost::asio::error::get_misc_category()
};
in.bytes += ret;
++in.calls;
in.bytes += ret;
++in_total.calls;
in_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)
@ -3221,8 +3229,10 @@ try
asio::error::eof, asio::error::get_misc_category()
};
in.bytes += ret;
++in.calls;
in.bytes += ret;
++in_total.calls;
in_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)
@ -3247,8 +3257,10 @@ ircd::net::socket::read_any(iov&& bufs)
asio::read(ssl, std::forward<iov>(bufs), completion, ec)
};
in.bytes += ret;
++in.calls;
in.bytes += ret;
++in_total.calls;
in_total.bytes += ret;
if(likely(!ec))
return ret;
@ -3273,8 +3285,10 @@ ircd::net::socket::read_one(iov&& bufs)
ssl.read_some(std::forward<iov>(bufs), ec)
};
in.bytes += ret;
++in.calls;
in.bytes += ret;
++in_total.calls;
in_total.bytes += ret;
if(likely(!ec))
return ret;
@ -3312,8 +3326,10 @@ try
}
};
out.bytes += ret;
++out.calls;
out.bytes += ret;
++out_total.calls;
out_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)
@ -3342,8 +3358,10 @@ try
}
};
out.bytes += ret;
++out.calls;
out.bytes += ret;
++out_total.calls;
out_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)
@ -3368,8 +3386,10 @@ try
asio::write(ssl, std::forward<iov>(bufs), completion)
};
out.bytes += ret;
++out.calls;
out.bytes += ret;
++out_total.calls;
out_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)
@ -3389,8 +3409,10 @@ try
ssl.write_some(std::forward<iov>(bufs))
};
out.bytes += ret;
++out.calls;
out.bytes += ret;
++out_total.calls;
out_total.bytes += ret;
return ret;
}
catch(const boost::system::system_error &e)