aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/config/defs.h
diff options
context:
space:
mode:
authornga <nga@yandex-team.ru>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:09 +0300
commitc2a1af049e9deca890e9923abe64fe6c59060348 (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/messagebus/config/defs.h
parent1f553f46fb4f3c5eec631352cdd900a0709016af (diff)
downloadydb-c2a1af049e9deca890e9923abe64fe6c59060348.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/config/defs.h')
-rw-r--r--library/cpp/messagebus/config/defs.h56
1 files changed, 28 insertions, 28 deletions
diff --git a/library/cpp/messagebus/config/defs.h b/library/cpp/messagebus/config/defs.h
index 10820f83fd..92b1df9969 100644
--- a/library/cpp/messagebus/config/defs.h
+++ b/library/cpp/messagebus/config/defs.h
@@ -1,23 +1,23 @@
-#pragma once
+#pragma once
// unique tag to fix pragma once gcc glueing: ./library/cpp/messagebus/defs.h
-
+
#include "codegen.h"
#include "netaddr.h"
#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
-#include <util/generic/list.h>
+#include <util/generic/list.h>
#include <utility>
-
-// For historical reasons TCrawlerModule need to access
-// APIs that should be private.
-class TCrawlerModule;
-
-struct TDebugReceiverHandler;
-
-namespace NBus {
+
+// For historical reasons TCrawlerModule need to access
+// APIs that should be private.
+class TCrawlerModule;
+
+struct TDebugReceiverHandler;
+
+namespace NBus {
namespace NPrivate {
class TAcceptor;
struct TBusSessionImpl;
@@ -27,15 +27,15 @@ namespace NBus {
class TRemoteServerConnection;
class TRemoteClientConnection;
class TBusSyncSourceSessionImpl;
-
+
struct TBusMessagePtrAndHeader;
-
+
struct TSessionDumpStatus;
-
+
struct TClientRequestImpl;
-
+
}
-
+
class TBusSession;
struct TBusServerSession;
struct TBusClientSession;
@@ -47,36 +47,36 @@ namespace NBus {
struct TBusQueueConfig;
struct TBusSessionConfig;
struct TBusHeader;
-
+
class IThreadHandler;
-
+
using TBusKey = ui64;
using TBusMessageList = TList<TBusMessage*>;
using TBusKeyVec = TVector<std::pair<TBusKey, TBusKey>>;
-
+
using TBusMessageQueuePtr = TIntrusivePtr<TBusMessageQueue>;
-
+
class TBusModule;
-
+
using TBusData = TString;
using TBusService = const char*;
-
+
#define YBUS_KEYMIN TBusKey(0L)
#define YBUS_KEYMAX TBusKey(-1L)
#define YBUS_KEYLOCAL TBusKey(7L)
-#define YBUS_KEYINVALID TBusKey(99999999L)
-
+#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;
}
#define YBUS_VERSION 0
-
+
#define YBUS_INFINITE (1u << 30u)
-
+
#define YBUS_STATUS_BASIC 0x0000
#define YBUS_STATUS_CONNS 0x0001
-#define YBUS_STATUS_INFLIGHT 0x0002
-
+#define YBUS_STATUS_INFLIGHT 0x0002
+
}