aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/remote_server_connection.cpp
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /library/cpp/messagebus/remote_server_connection.cpp
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/remote_server_connection.cpp')
-rw-r--r--library/cpp/messagebus/remote_server_connection.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/messagebus/remote_server_connection.cpp b/library/cpp/messagebus/remote_server_connection.cpp
index d98653f06a..74be34ded9 100644
--- a/library/cpp/messagebus/remote_server_connection.cpp
+++ b/library/cpp/messagebus/remote_server_connection.cpp
@@ -19,7 +19,7 @@ void TRemoteServerConnection::Init(SOCKET socket, TInstant now) {
WriterData.Status.ConnectTime = now;
WriterData.Status.Connected = true;
- Y_VERIFY(socket != INVALID_SOCKET, "must be a valid socket");
+ Y_VERIFY(socket != INVALID_SOCKET, "must be a valid socket");
TSocket readSocket(socket);
TSocket writeSocket = readSocket;
@@ -37,8 +37,8 @@ TRemoteServerSession* TRemoteServerConnection::GetSession() {
}
void TRemoteServerConnection::HandleEvent(SOCKET socket, void* cookie) {
- Y_UNUSED(socket);
- Y_ASSERT(cookie == ReadCookie || cookie == WriteCookie);
+ Y_UNUSED(socket);
+ Y_ASSERT(cookie == ReadCookie || cookie == WriteCookie);
if (cookie == ReadCookie) {
GetSession()->ServerOwnedMessages.Wait();
ScheduleRead();
@@ -55,9 +55,9 @@ void TRemoteServerConnection::MessageSent(TArrayRef<TBusMessagePtrAndHeader> mes
TInstant now = TInstant::Now();
GetSession()->ReleaseInWorkResponses(messages);
- for (auto& message : messages) {
- TInstant recvTime = message.MessagePtr->RecvTime;
- GetSession()->ServerHandler->OnSent(message.MessagePtr.Release());
+ for (auto& message : messages) {
+ TInstant recvTime = message.MessagePtr->RecvTime;
+ GetSession()->ServerHandler->OnSent(message.MessagePtr.Release());
TDuration d = now - recvTime;
WriterData.Status.DurationCounter.AddDuration(d);
WriterData.Status.Incremental.ProcessDurationHistogram.AddTime(d);