Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 of 2.

1 files changed, 3 insertions, 3 deletions

diff --git a/library/cpp/messagebus/remote_client_session.cpp b/library/cpp/messagebus/remote_client_session.cpp
index 3bc421944f..a31c509e7b 100644
--- a/library/cpp/messagebus/remote_client_session.cpp
+++ b/library/cpp/messagebus/remote_client_session.cpp
@@ -71,7 +71,7 @@ void TRemoteClientSession::FillStatus() {
     StatusData.Status.InputPaused = false;
 }
 
-void TRemoteClientSession::AcquireInFlight(TArrayRef<TBusMessage* const> messages) {
+void TRemoteClientSession::AcquireInFlight(TArrayRef<TBusMessage* const> messages) { 
     for (auto message : messages) {
         Y_ASSERT(!(message->LocalFlags & MESSAGE_IN_FLIGHT_ON_CLIENT));
         message->LocalFlags |= MESSAGE_IN_FLIGHT_ON_CLIENT;
@@ -79,7 +79,7 @@ void TRemoteClientSession::AcquireInFlight(TArrayRef<TBusMessage* const> message
     ClientRemoteInFlight.IncrementMultiple(messages.size());
 }
 
-void TRemoteClientSession::ReleaseInFlight(TArrayRef<TBusMessage* const> messages) {
+void TRemoteClientSession::ReleaseInFlight(TArrayRef<TBusMessage* const> messages) { 
     for (auto message : messages) {
         Y_ASSERT(message->LocalFlags & MESSAGE_IN_FLIGHT_ON_CLIENT);
         message->LocalFlags &= ~MESSAGE_IN_FLIGHT_ON_CLIENT;
@@ -88,7 +88,7 @@ void TRemoteClientSession::ReleaseInFlight(TArrayRef<TBusMessage* const> message
 }
 
 void TRemoteClientSession::ReleaseInFlightAndCallOnReply(TNonDestroyingAutoPtr<TBusMessage> request, TBusMessagePtrAndHeader& response) {
-    ReleaseInFlight({request.Get()});
+    ReleaseInFlight({request.Get()}); 
     if (Y_UNLIKELY(AtomicGet(Down))) {
         InvokeOnError(request, MESSAGE_SHUTDOWN);
         InvokeOnError(response.MessagePtr.Release(), MESSAGE_SHUTDOWN);