aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/debug_receiver
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:17 +0300
commitd3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch)
treedd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/messagebus/debug_receiver
parent72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff)
downloadydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 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 7a535290ab..05f99e94ca 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 a01140e06c..0aed6b9984 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 3dcb949a20..0c74f9ecc3 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 ed08d3cd9e..d34710dcf7 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;
};