Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 of 2.

2 files changed, 63 insertions, 63 deletions

diff --git a/library/cpp/messagebus/test/example/server/server.cpp b/library/cpp/messagebus/test/example/server/server.cpp
index 13e52d75f5..a080f3548b 100644
--- a/library/cpp/messagebus/test/example/server/server.cpp
+++ b/library/cpp/messagebus/test/example/server/server.cpp
@@ -1,58 +1,58 @@
 #include <library/cpp/messagebus/test/example/common/proto.h>
-
-using namespace NBus;
-using namespace NCalculator;
-
-namespace NCalculator {
+ 
+using namespace NBus; 
+using namespace NCalculator; 
+ 
+namespace NCalculator { 
     struct TCalculatorServer: public IBusServerHandler {
-        TCalculatorProtocol Proto;
-        TBusMessageQueuePtr MessageQueue;
-        TBusServerSessionPtr ServerSession;
-
-        TCalculatorServer() {
-            MessageQueue = CreateMessageQueue();
-            TBusServerSessionConfig config;
-            ServerSession = TBusServerSession::Create(&Proto, this, config, MessageQueue);
-        }
-
+        TCalculatorProtocol Proto; 
+        TBusMessageQueuePtr MessageQueue; 
+        TBusServerSessionPtr ServerSession; 
+ 
+        TCalculatorServer() { 
+            MessageQueue = CreateMessageQueue(); 
+            TBusServerSessionConfig config; 
+            ServerSession = TBusServerSession::Create(&Proto, this, config, MessageQueue); 
+        } 
+ 
         ~TCalculatorServer() override {
-            MessageQueue->Stop();
-        }
-
+            MessageQueue->Stop(); 
+        } 
+ 
         void OnMessage(TOnMessageContext& request) override {
-            if (request.GetMessage()->GetHeader()->Type == TRequestSum::MessageType) {
-                TRequestSum* requestSum = VerifyDynamicCast<TRequestSum*>(request.GetMessage());
-                int a = requestSum->Record.GetA();
-                int b = requestSum->Record.GetB();
-                int result = a + b;
-                Cerr << "requested " << a << " + " << b << ", sending " << result << "\n";
-                TAutoPtr<TResponse> response(new TResponse);
-                response->Record.SetResult(result);
-                request.SendReplyMove(response);
-            } else if (request.GetMessage()->GetHeader()->Type == TRequestMul::MessageType) {
-                TRequestMul* requestMul = VerifyDynamicCast<TRequestMul*>(request.GetMessage());
-                int a = requestMul->Record.GetA();
-                int b = requestMul->Record.GetB();
-                int result = a * b;
-                Cerr << "requested " << a << " * " << b << ", sending " << result << "\n";
-                TAutoPtr<TResponse> response(new TResponse);
-                response->Record.SetResult(result);
-                request.SendReplyMove(response);
-            } else {
+            if (request.GetMessage()->GetHeader()->Type == TRequestSum::MessageType) { 
+                TRequestSum* requestSum = VerifyDynamicCast<TRequestSum*>(request.GetMessage()); 
+                int a = requestSum->Record.GetA(); 
+                int b = requestSum->Record.GetB(); 
+                int result = a + b; 
+                Cerr << "requested " << a << " + " << b << ", sending " << result << "\n"; 
+                TAutoPtr<TResponse> response(new TResponse); 
+                response->Record.SetResult(result); 
+                request.SendReplyMove(response); 
+            } else if (request.GetMessage()->GetHeader()->Type == TRequestMul::MessageType) { 
+                TRequestMul* requestMul = VerifyDynamicCast<TRequestMul*>(request.GetMessage()); 
+                int a = requestMul->Record.GetA(); 
+                int b = requestMul->Record.GetB(); 
+                int result = a * b; 
+                Cerr << "requested " << a << " * " << b << ", sending " << result << "\n"; 
+                TAutoPtr<TResponse> response(new TResponse); 
+                response->Record.SetResult(result); 
+                request.SendReplyMove(response); 
+            } else { 
                 Y_FAIL("unknown request");
-            }
-        }
-    };
-}
-
-int main(int, char**) {
-    TCalculatorServer server;
-
-    Cerr << "listening on port " << server.ServerSession->GetActualListenPort() << "\n";
-
-    for (;;) {
-        Sleep(TDuration::Seconds(1));
-    }
-
-    return 0;
+            } 
+        } 
+    }; 
 }
+ 
+int main(int, char**) { 
+    TCalculatorServer server; 
+ 
+    Cerr << "listening on port " << server.ServerSession->GetActualListenPort() << "\n"; 
+ 
+    for (;;) { 
+        Sleep(TDuration::Seconds(1)); 
+    } 
+ 
+    return 0; 
+} 
diff --git a/library/cpp/messagebus/test/example/server/ya.make b/library/cpp/messagebus/test/example/server/ya.make
index 8cdd97cb12..3bf4c31853 100644
--- a/library/cpp/messagebus/test/example/server/ya.make
+++ b/library/cpp/messagebus/test/example/server/ya.make
@@ -1,13 +1,13 @@
-PROGRAM(messagebus_example_server)
-
+PROGRAM(messagebus_example_server) 
+ 
 OWNER(g:messagebus)
-
-PEERDIR(
+ 
+PEERDIR( 
     library/cpp/messagebus/test/example/common
-)
-
-SRCS(
-    server.cpp
-)
-
-END()
+) 
+ 
+SRCS( 
+    server.cpp 
+) 
+ 
+END()