diff options
author | arcadia-devtools <[email protected]> | 2022-06-27 17:16:05 +0300 |
---|---|---|
committer | arcadia-devtools <[email protected]> | 2022-06-27 17:16:05 +0300 |
commit | 244fc68b04485d0d740b3e0befb4e52d6c9caf1f (patch) | |
tree | 04b6e302408ccc85a331d619b37ac997e955a9ec /library/cpp/actors/interconnect/interconnect_tcp_session.cpp | |
parent | 9b125f6128d9d867117ec970348d2e8062a22cc5 (diff) |
intermediate changes
ref:4321fe5a69e3b93ba446bc212e9b4668fff799c8
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_session.cpp')
-rw-r--r-- | library/cpp/actors/interconnect/interconnect_tcp_session.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp index 1602f4b8b2f..0f286153ea5 100644 --- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp +++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp @@ -581,12 +581,14 @@ namespace NActors { TString err; ssize_t r = 0; do { + const ui64 begin = GetCycleCountFast(); #ifndef _win_ r = iovcnt == 1 ? Socket->Send(iovec[0].iov_base, iovec[0].iov_len, &err) : Socket->WriteV(iovec, iovcnt); #else r = Socket->Send(iovec[0].iov_base, iovec[0].iov_len, &err); #endif - Proxy->Metrics->IncSendSyscalls(); + const ui64 end = GetCycleCountFast(); + Proxy->Metrics->IncSendSyscalls((end - begin) * 1'000'000 / GetCyclesPerMillisecond()); } while (r == -EINTR); LOG_DEBUG_IC_SESSION("ICS16", "written# %zd iovcnt# %d err# %s", r, iovcnt, err.data()); |