aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/messagebus/mon_service_messagebus.h
diff options
context:
space:
mode:
authorSergey Polovko <sergey@polovko.me>2022-02-10 16:47:02 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:02 +0300
commit3e0b762a82514bac89c1dd6ea7211e381d8aa248 (patch)
treec2d1b379ecaf05ca8f11ed0b5da9d1a950e6e554 /library/cpp/monlib/messagebus/mon_service_messagebus.h
parentab3783171cc30e262243a0227c86118f7080c896 (diff)
downloadydb-3e0b762a82514bac89c1dd6ea7211e381d8aa248.tar.gz
Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/messagebus/mon_service_messagebus.h')
-rw-r--r--library/cpp/monlib/messagebus/mon_service_messagebus.h72
1 files changed, 36 insertions, 36 deletions
diff --git a/library/cpp/monlib/messagebus/mon_service_messagebus.h b/library/cpp/monlib/messagebus/mon_service_messagebus.h
index fe791e8a9b..32c7b4cb70 100644
--- a/library/cpp/monlib/messagebus/mon_service_messagebus.h
+++ b/library/cpp/monlib/messagebus/mon_service_messagebus.h
@@ -1,46 +1,46 @@
#pragma once
-#include "mon_messagebus.h"
-
-#include <library/cpp/monlib/service/monservice.h>
-
+#include "mon_messagebus.h"
+
+#include <library/cpp/monlib/service/monservice.h>
+
#include <util/system/mutex.h>
namespace NMonitoring {
- class TMonServiceMessageBus: public TMonService2 {
- private:
- TMutex Mtx;
- TIntrusivePtr<NMonitoring::TBusNgMonPage> BusNgMonPage;
-
- public:
- TMonServiceMessageBus(ui16 port, const TString& title);
-
- private:
- NBus::TBusWww* RegisterBusNgMonPage() {
- TGuard<TMutex> g(Mtx);
- if (!BusNgMonPage) {
- BusNgMonPage = new NMonitoring::TBusNgMonPage();
- Register(BusNgMonPage.Get());
- }
- return BusNgMonPage->BusWww.Get();
+ class TMonServiceMessageBus: public TMonService2 {
+ private:
+ TMutex Mtx;
+ TIntrusivePtr<NMonitoring::TBusNgMonPage> BusNgMonPage;
+
+ public:
+ TMonServiceMessageBus(ui16 port, const TString& title);
+
+ private:
+ NBus::TBusWww* RegisterBusNgMonPage() {
+ TGuard<TMutex> g(Mtx);
+ if (!BusNgMonPage) {
+ BusNgMonPage = new NMonitoring::TBusNgMonPage();
+ Register(BusNgMonPage.Get());
+ }
+ return BusNgMonPage->BusWww.Get();
+ }
+
+ public:
+ void RegisterClientSession(NBus::TBusClientSessionPtr clientSession) {
+ RegisterBusNgMonPage()->RegisterClientSession(clientSession);
}
- public:
- void RegisterClientSession(NBus::TBusClientSessionPtr clientSession) {
- RegisterBusNgMonPage()->RegisterClientSession(clientSession);
- }
+ void RegisterServerSession(NBus::TBusServerSessionPtr serverSession) {
+ RegisterBusNgMonPage()->RegisterServerSession(serverSession);
+ }
- void RegisterServerSession(NBus::TBusServerSessionPtr serverSession) {
- RegisterBusNgMonPage()->RegisterServerSession(serverSession);
- }
+ void RegisterQueue(NBus::TBusMessageQueuePtr queue) {
+ RegisterBusNgMonPage()->RegisterQueue(queue);
+ }
- void RegisterQueue(NBus::TBusMessageQueuePtr queue) {
- RegisterBusNgMonPage()->RegisterQueue(queue);
- }
-
- void RegisterModule(NBus::TBusModule* module) {
- RegisterBusNgMonPage()->RegisterModule(module);
- }
- };
+ void RegisterModule(NBus::TBusModule* module) {
+ RegisterBusNgMonPage()->RegisterModule(module);
+ }
+ };
-}
+}