fix ya.make

1 files changed, 57 insertions, 0 deletions

diff --git a/library/cpp/netliba/v6/ib_cs.h b/library/cpp/netliba/v6/ib_cs.h
new file mode 100644
index 0000000000..932f2880dc
--- /dev/null
+++ b/library/cpp/netliba/v6/ib_cs.h
@@ -0,0 +1,57 @@
+#pragma once
+
+#include "udp_address.h"
+#include "block_chain.h"
+#include "net_request.h"
+#include <util/generic/guid.h>
+#include <util/system/hp_timer.h>
+
+namespace NNetliba {
+    struct TIBConnectInfo {
+        TGUID SocketId;
+        ui64 Subnet, Interface;
+        int LID;
+        int QPN;
+    };
+
+    struct TRCQueuePairHandshake {
+        int QPN, PSN;
+    };
+
+    using TIBMsgHandle = i64;
+
+    struct TIBSendResult {
+        TIBMsgHandle Handle;
+        bool Success;
+        TIBSendResult()
+            : Handle(0)
+            , Success(false)
+        {
+        }
+        TIBSendResult(TIBMsgHandle handle, bool success)
+            : Handle(handle)
+            , Success(success)
+        {
+        }
+    };
+
+    struct IIBPeer: public TThrRefBase {
+        enum EState {
+            CONNECTING,
+            OK,
+            FAILED,
+        };
+        virtual EState GetState() = 0;
+    };
+
+    struct IIBClientServer: public TThrRefBase {
+        virtual TRequest* GetRequest() = 0;
+        virtual TIBMsgHandle Send(TPtrArg<IIBPeer> peer, TRopeDataPacket* data, const TGUID& packetGuid) = 0;
+        virtual bool GetSendResult(TIBSendResult* res) = 0;
+        virtual bool Step(NHPTimer::STime tCurrent) = 0;
+        virtual IIBPeer* ConnectPeer(const TIBConnectInfo& info, const TUdpAddress& peerAddr, const TUdpAddress& myAddr) = 0;
+        virtual const TIBConnectInfo& GetConnectInfo() = 0;
+    };
+
+    IIBClientServer* CreateIBClientServer();
+}