aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorblaze <blaze@yandex-team.ru>2022-02-10 16:50:31 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:31 +0300
commit6813864abdb5ce336cde7a2e5cd80232ba54eef1 (patch)
tree4d210665182fb648da2838c38dba04bab6878dc1 /library/cpp/messagebus
parent6e1e62cdffc32768898ccdfd24e046d8b929a45b (diff)
downloadydb-6813864abdb5ce336cde7a2e5cd80232ba54eef1.tar.gz
Restoring authorship annotation for <blaze@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/message.cpp4
-rw-r--r--library/cpp/messagebus/ya.make6
-rw-r--r--library/cpp/messagebus/ybus.h2
3 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/messagebus/message.cpp b/library/cpp/messagebus/message.cpp
index bfa7ed8e9b..8083df8261 100644
--- a/library/cpp/messagebus/message.cpp
+++ b/library/cpp/messagebus/message.cpp
@@ -163,8 +163,8 @@ namespace NBus {
} else {
GetHeader()->FlagsInternal &= ~(MESSAGE_COMPRESS_INTERNAL);
}
- }
-
+ }
+
void TBusMessage::SetCompressedResponse(bool v) {
if (v) {
GetHeader()->FlagsInternal |= MESSAGE_COMPRESS_RESPONSE;
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index e13cf06dea..7c95035e82 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -51,7 +51,7 @@ SRCS(
ybus.h
)
-PEERDIR(
+PEERDIR(
contrib/libs/sparsehash
library/cpp/codecs
library/cpp/deprecated/enum_codegen
@@ -63,6 +63,6 @@ PEERDIR(
library/cpp/messagebus/scheduler
library/cpp/string_utils/indent_text
library/cpp/threading/future
-)
-
+)
+
END()
diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h
index de21ad8521..4fbaaf851f 100644
--- a/library/cpp/messagebus/ybus.h
+++ b/library/cpp/messagebus/ybus.h
@@ -98,7 +98,7 @@ namespace NBus {
return NCodecs::ICodec::GetInstance("snappy");
}
};
-
+
class TBusSyncSourceSession: public TAtomicRefCount<TBusSyncSourceSession> {
friend class TBusMessageQueue;