diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/config/defs.h | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/config/defs.h')
-rw-r--r-- | library/cpp/messagebus/config/defs.h | 90 |
1 files changed, 45 insertions, 45 deletions
diff --git a/library/cpp/messagebus/config/defs.h b/library/cpp/messagebus/config/defs.h index 92b1df9969..ad644cd279 100644 --- a/library/cpp/messagebus/config/defs.h +++ b/library/cpp/messagebus/config/defs.h @@ -1,5 +1,5 @@ #pragma once - + // unique tag to fix pragma once gcc glueing: ./library/cpp/messagebus/defs.h #include "codegen.h" @@ -18,65 +18,65 @@ class TCrawlerModule; struct TDebugReceiverHandler; namespace NBus { - namespace NPrivate { - class TAcceptor; - struct TBusSessionImpl; - class TRemoteServerSession; - class TRemoteClientSession; - class TRemoteConnection; - class TRemoteServerConnection; - class TRemoteClientConnection; - class TBusSyncSourceSessionImpl; + namespace NPrivate { + class TAcceptor; + struct TBusSessionImpl; + class TRemoteServerSession; + class TRemoteClientSession; + class TRemoteConnection; + class TRemoteServerConnection; + class TRemoteClientConnection; + class TBusSyncSourceSessionImpl; - struct TBusMessagePtrAndHeader; + struct TBusMessagePtrAndHeader; - struct TSessionDumpStatus; + struct TSessionDumpStatus; - struct TClientRequestImpl; + struct TClientRequestImpl; - } + } - class TBusSession; - struct TBusServerSession; - struct TBusClientSession; - class TBusProtocol; - class TBusMessage; - class TBusMessageConnection; - class TBusMessageQueue; - class TBusLocator; - struct TBusQueueConfig; - struct TBusSessionConfig; - struct TBusHeader; + class TBusSession; + struct TBusServerSession; + struct TBusClientSession; + class TBusProtocol; + class TBusMessage; + class TBusMessageConnection; + class TBusMessageQueue; + class TBusLocator; + struct TBusQueueConfig; + struct TBusSessionConfig; + struct TBusHeader; - class IThreadHandler; + class IThreadHandler; - using TBusKey = ui64; - using TBusMessageList = TList<TBusMessage*>; - using TBusKeyVec = TVector<std::pair<TBusKey, TBusKey>>; + using TBusKey = ui64; + using TBusMessageList = TList<TBusMessage*>; + using TBusKeyVec = TVector<std::pair<TBusKey, TBusKey>>; - using TBusMessageQueuePtr = TIntrusivePtr<TBusMessageQueue>; + using TBusMessageQueuePtr = TIntrusivePtr<TBusMessageQueue>; - class TBusModule; + class TBusModule; - using TBusData = TString; - using TBusService = const char*; + using TBusData = TString; + using TBusService = const char*; -#define YBUS_KEYMIN TBusKey(0L) -#define YBUS_KEYMAX TBusKey(-1L) -#define YBUS_KEYLOCAL TBusKey(7L) +#define YBUS_KEYMIN TBusKey(0L) +#define YBUS_KEYMAX TBusKey(-1L) +#define YBUS_KEYLOCAL TBusKey(7L) #define YBUS_KEYINVALID TBusKey(99999999L) - // Check that generated id is valid for remote message - inline bool IsBusKeyValid(TBusKey key) { - return key != YBUS_KEYINVALID && key != YBUS_KEYMAX && key > YBUS_KEYLOCAL; - } + // Check that generated id is valid for remote message + inline bool IsBusKeyValid(TBusKey key) { + return key != YBUS_KEYINVALID && key != YBUS_KEYMAX && key > YBUS_KEYLOCAL; + } -#define YBUS_VERSION 0 +#define YBUS_VERSION 0 -#define YBUS_INFINITE (1u << 30u) +#define YBUS_INFINITE (1u << 30u) -#define YBUS_STATUS_BASIC 0x0000 -#define YBUS_STATUS_CONNS 0x0001 +#define YBUS_STATUS_BASIC 0x0000 +#define YBUS_STATUS_CONNS 0x0001 #define YBUS_STATUS_INFLIGHT 0x0002 -} +} |