summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
diff options
context:
space:
mode:
authorarcadia-devtools <[email protected]>2022-06-27 17:16:05 +0300
committerarcadia-devtools <[email protected]>2022-06-27 17:16:05 +0300
commit244fc68b04485d0d740b3e0befb4e52d6c9caf1f (patch)
tree04b6e302408ccc85a331d619b37ac997e955a9ec /library/cpp/actors/interconnect/interconnect_tcp_session.cpp
parent9b125f6128d9d867117ec970348d2e8062a22cc5 (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.cpp4
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());