aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/debug_receiver
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/debug_receiver
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/debug_receiver')
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp10
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_handler.h2
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp4
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_proto.h22
4 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp
index 05f99e94ca..7a535290ab 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp
@@ -5,16 +5,16 @@
#include <util/generic/cast.h>
#include <util/string/printf.h>
-void TDebugReceiverHandler::OnError(TAutoPtr<NBus::TBusMessage>, NBus::EMessageStatus status) {
+void TDebugReceiverHandler::OnError(TAutoPtr<NBus::TBusMessage>, NBus::EMessageStatus status) {
Cerr << "error " << status << "\n";
}
-void TDebugReceiverHandler::OnMessage(NBus::TOnMessageContext& message) {
+void TDebugReceiverHandler::OnMessage(NBus::TOnMessageContext& message) {
TDebugReceiverMessage* typedMessage = VerifyDynamicCast<TDebugReceiverMessage*>(message.GetMessage());
Cerr << "type=" << typedMessage->GetHeader()->Type
- << " size=" << typedMessage->GetHeader()->Size
- << " flags=" << Sprintf("0x%04x", (int)typedMessage->GetHeader()->FlagsInternal)
- << "\n";
+ << " size=" << typedMessage->GetHeader()->Size
+ << " flags=" << Sprintf("0x%04x", (int)typedMessage->GetHeader()->FlagsInternal)
+ << "\n";
message.ForgetRequest();
}
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
index 0aed6b9984..a01140e06c 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
@@ -2,7 +2,7 @@
#include <library/cpp/messagebus/ybus.h>
-struct TDebugReceiverHandler: public NBus::IBusServerHandler {
+struct TDebugReceiverHandler: public NBus::IBusServerHandler {
NBus::TBusServerSession* ServerSession;
void OnError(TAutoPtr<NBus::TBusMessage> pMessage, NBus::EMessageStatus status) override;
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
index 0c74f9ecc3..3dcb949a20 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
@@ -7,11 +7,11 @@ TDebugReceiverProtocol::TDebugReceiverProtocol()
{
}
-void TDebugReceiverProtocol::Serialize(const NBus::TBusMessage*, TBuffer&) {
+void TDebugReceiverProtocol::Serialize(const NBus::TBusMessage*, TBuffer&) {
Y_FAIL("it is receiver only");
}
-TAutoPtr<NBus::TBusMessage> TDebugReceiverProtocol::Deserialize(ui16, TArrayRef<const char> payload) {
+TAutoPtr<NBus::TBusMessage> TDebugReceiverProtocol::Deserialize(ui16, TArrayRef<const char> payload) {
THolder<TDebugReceiverMessage> r(new TDebugReceiverMessage(ECreateUninitialized()));
r->Payload.Append(payload.data(), payload.size());
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
index d34710dcf7..ed08d3cd9e 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
@@ -2,26 +2,26 @@
#include <library/cpp/messagebus/ybus.h>
-struct TDebugReceiverMessage: public NBus::TBusMessage {
+struct TDebugReceiverMessage: public NBus::TBusMessage {
/// constructor to create messages on sending end
- TDebugReceiverMessage(ui16 type)
- : NBus::TBusMessage(type)
- {
- }
+ TDebugReceiverMessage(ui16 type)
+ : NBus::TBusMessage(type)
+ {
+ }
/// constructor with serialzed data to examine the header
- TDebugReceiverMessage(NBus::ECreateUninitialized)
- : NBus::TBusMessage(NBus::ECreateUninitialized())
- {
- }
+ TDebugReceiverMessage(NBus::ECreateUninitialized)
+ : NBus::TBusMessage(NBus::ECreateUninitialized())
+ {
+ }
TBuffer Payload;
};
-struct TDebugReceiverProtocol: public NBus::TBusProtocol {
+struct TDebugReceiverProtocol: public NBus::TBusProtocol {
TDebugReceiverProtocol();
- void Serialize(const NBus::TBusMessage* mess, TBuffer& data) override;
+ void Serialize(const NBus::TBusMessage* mess, TBuffer& data) override;
TAutoPtr<NBus::TBusMessage> Deserialize(ui16 messageType, TArrayRef<const char> payload) override;
};