aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/protobuf/ybusbuf.h
diff options
context:
space:
mode:
authorvladimir <vladimir@yandex-team.ru>2022-02-10 16:50:28 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:28 +0300
commit3e7ff6e4ee637c04455854159e84850e613ebc16 (patch)
tree1ea1786a47f104a0657e0f935ce63dcaeec3fd26 /library/cpp/messagebus/protobuf/ybusbuf.h
parentdad82c0e0157ebad6bfd7cf0e5fb3c15c42922b3 (diff)
downloadydb-3e7ff6e4ee637c04455854159e84850e613ebc16.tar.gz
Restoring authorship annotation for <vladimir@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/protobuf/ybusbuf.h')
-rw-r--r--library/cpp/messagebus/protobuf/ybusbuf.h32
1 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.h b/library/cpp/messagebus/protobuf/ybusbuf.h
index 57b4267ea5..7e3a125868 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.h
+++ b/library/cpp/messagebus/protobuf/ybusbuf.h
@@ -1,24 +1,24 @@
#pragma once
-
+
#include <library/cpp/messagebus/ybus.h>
-
+
#include <google/protobuf/descriptor.h>
#include <google/protobuf/message.h>
-
+
#include <util/generic/cast.h>
#include <util/generic/vector.h>
#include <util/stream/mem.h>
-
+
#include <array>
-namespace NBus {
+namespace NBus {
using TBusBufferRecord = ::google::protobuf::Message;
-
+
template <class TBufferMessage>
class TBusBufferMessagePtr;
template <class TBufferMessage>
class TBusBufferMessageAutoPtr;
-
+
class TBusBufferBase: public TBusMessage {
public:
TBusBufferBase(int type)
@@ -43,7 +43,7 @@ namespace NBus {
/// @param TBufferRecord is record described in .proto file with namespace
/// @param MessageFile is offset for .proto file message ids
-
+
/// \attention If you want one protocol NBus::TBusBufferProtocol to handle
/// messageges described in different .proto files, make sure that they have
/// unique values for MessageFile
@@ -52,7 +52,7 @@ namespace NBus {
class TBusBufferMessage: public TBusBufferBase {
public:
static const int MessageType = MType;
-
+
typedef TBusBufferMessagePtr<TBusBufferMessage<TBufferRecord, MType>> TPtr;
typedef TBusBufferMessageAutoPtr<TBusBufferMessage<TBufferRecord, MType>> TAutoPtr;
@@ -88,7 +88,7 @@ namespace NBus {
return new TBusBufferMessage<TBufferRecord, MessageType>();
}
};
-
+
template <class TSelf, class TBufferMessage>
class TBusBufferMessagePtrBase {
public:
@@ -101,7 +101,7 @@ namespace NBus {
const TSelf* GetSelf() const {
return static_cast<const TSelf*>(this);
}
-
+
public:
RecordType* operator->() {
Y_ASSERT(GetSelf()->Get());
@@ -119,7 +119,7 @@ namespace NBus {
Y_ASSERT(GetSelf()->Get());
return GetSelf()->Get()->Record;
}
-
+
TBusHeader* GetHeader() {
return GetSelf()->Get()->GetHeader();
}
@@ -127,7 +127,7 @@ namespace NBus {
return GetSelf()->Get()->GetHeader();
}
};
-
+
template <class TBufferMessage>
class TBusBufferMessagePtr: public TBusBufferMessagePtrBase<TBusBufferMessagePtr<TBufferMessage>, TBufferMessage> {
protected:
@@ -179,7 +179,7 @@ namespace NBus {
: AutoPtr(message)
{
}
-
+
TBufferMessage* Get() {
return AutoPtr.Get();
}
@@ -198,7 +198,7 @@ namespace NBus {
return AutoPtr.Release();
}
};
-
+
/////////////////////////////////////////////
/// \brief Generic protocol object for messages descibed with protobuf
@@ -223,7 +223,7 @@ namespace NBus {
void RegisterType(TAutoPtr<TBusBufferBase> mess);
TArrayRef<TBusBufferBase* const> GetTypes() const;
-
+
/// serialized protocol specific data into TBusData
void Serialize(const TBusMessage* mess, TBuffer& data) override;