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_input_session.cpp | |
| parent | 9b125f6128d9d867117ec970348d2e8062a22cc5 (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.cpp | 4 |
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); } |
