intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

2 files changed, 55 insertions, 0 deletions

diff --git a/library/cpp/testing/unittest/fat/test_port_manager.cpp b/library/cpp/testing/unittest/fat/test_port_manager.cpp
new file mode 100644
index 0000000000..f77d2e3a25
--- /dev/null
+++ b/library/cpp/testing/unittest/fat/test_port_manager.cpp
@@ -0,0 +1,36 @@
+#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/tests_data.h>
+
+bool IsFreePort(ui16 port) {
+    TInet6StreamSocket sock;
+    TSockAddrInet6 addr("::", port);
+    Y_ENSURE(SetSockOpt(sock, SOL_SOCKET, SO_REUSEADDR, 1) == 0);
+    SetReuseAddressAndPort(sock);
+    if (sock.Bind(&addr) == 0) {
+        return true;
+    }
+    return false;
+}
+
+void get_port_ranges() {
+    for (int i = 1; i < 10; ++i) {
+        TPortManager pm;
+        ui16 port = pm.GetPortsRange(1024, i);
+        for (int p = port; p < port + i; ++p) {
+            UNIT_ASSERT(IsFreePort(p));
+        }
+    }
+}
+
+Y_UNIT_TEST_SUITE(TestTPortManager) {
+    Y_UNIT_TEST(ParallelRun0) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun1) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun2) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun3) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun4) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun5) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun6) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun7) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun8) {get_port_ranges();}
+    Y_UNIT_TEST(ParallelRun9) {get_port_ranges();}
+}
diff --git a/library/cpp/testing/unittest/fat/ya.make b/library/cpp/testing/unittest/fat/ya.make
new file mode 100644
index 0000000000..d405e599ee
--- /dev/null
+++ b/library/cpp/testing/unittest/fat/ya.make
@@ -0,0 +1,19 @@
+UNITTEST()
+
+OWNER(g:yatool)
+
+SRCS(
+    test_port_manager.cpp
+)
+
+SIZE(LARGE)
+
+# We need to run tests at the same time on the single machine
+FORK_SUBTESTS()
+
+TAG(
+    ya:fat
+    ya:force_sandbox
+)
+
+END()