intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 82 insertions, 0 deletions

diff --git a/library/cpp/messagebus/config/defs.h b/library/cpp/messagebus/config/defs.h
new file mode 100644
index 00000000000..92b1df99698
--- /dev/null
+++ b/library/cpp/messagebus/config/defs.h
@@ -0,0 +1,82 @@
+#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 <utility>
+
+// For historical reasons TCrawlerModule need to access
+// APIs that should be private.
+class TCrawlerModule;
+
+struct TDebugReceiverHandler;
+
+namespace NBus {
+    namespace NPrivate {
+        class TAcceptor;
+        struct TBusSessionImpl;
+        class TRemoteServerSession;
+        class TRemoteClientSession;
+        class TRemoteConnection;
+        class TRemoteServerConnection;
+        class TRemoteClientConnection;
+        class TBusSyncSourceSessionImpl;
+
+        struct TBusMessagePtrAndHeader;
+
+        struct TSessionDumpStatus;
+
+        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 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)
+
+    // 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
+
+}