summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_input_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_input_session.cpp
parent9b125f6128d9d867117ec970348d2e8062a22cc5 (diff)
intermediate changes
ref:4321fe5a69e3b93ba446bc212e9b4668fff799c8
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index cbb2d16e466..6c80ddd2959 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -384,12 +384,14 @@ namespace NActors {
TString err;
LWPROBE_IF_TOO_LONG(SlowICReadFromSocket, ms) {
do {
+ const ui64 begin = GetCycleCountFast();
#ifndef _win_
recvres = iovcnt == 1 ? Socket->Recv(iovec->iov_base, iovec->iov_len, &err) : Socket->ReadV(iovec, iovcnt);
#else
recvres = Socket->Recv(iovec[0].iov_base, iovec[0].iov_len, &err);
#endif
- Metrics->IncRecvSyscalls();
+ const ui64 end = GetCycleCountFast();
+ Metrics->IncRecvSyscalls((end - begin) * 1'000'000 / GetCyclesPerMillisecond());
} while (recvres == -EINTR);
}