add ymake export to ydb

27 files changed, 470 insertions, 0 deletions

diff --git a/library/cpp/messagebus/actor/ut/ya.make b/library/cpp/messagebus/actor/ut/ya.make
new file mode 100644
index 0000000000..c2078d41b5
--- /dev/null
+++ b/library/cpp/messagebus/actor/ut/ya.make
@@ -0,0 +1,14 @@
+UNITTEST()
+
+PEERDIR(
+    library/cpp/messagebus/actor
+)
+
+SRCS(
+    ../actor_ut.cpp
+    ../ring_buffer_ut.cpp
+    ../tasks_ut.cpp
+    ../what_thread_does_guard_ut.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/actor/ya.make b/library/cpp/messagebus/actor/ya.make
new file mode 100644
index 0000000000..bd871502b6
--- /dev/null
+++ b/library/cpp/messagebus/actor/ya.make
@@ -0,0 +1,17 @@
+LIBRARY(messagebus_actor)
+
+SRCS(
+    executor.cpp
+    thread_extra.cpp
+    what_thread_does.cpp
+)
+
+PEERDIR(
+    library/cpp/deprecated/atomic
+)
+
+END()
+
+RECURSE_FOR_TESTS(
+    ut
+)
diff --git a/library/cpp/messagebus/config/ya.make b/library/cpp/messagebus/config/ya.make
new file mode 100644
index 0000000000..81ffbef0c6
--- /dev/null
+++ b/library/cpp/messagebus/config/ya.make
@@ -0,0 +1,13 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/getopt
+    library/cpp/deprecated/enum_codegen
+)
+
+SRCS(
+    netaddr.cpp
+    session_config.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/debug_receiver/ya.make b/library/cpp/messagebus/debug_receiver/ya.make
new file mode 100644
index 0000000000..fe6904bdd7
--- /dev/null
+++ b/library/cpp/messagebus/debug_receiver/ya.make
@@ -0,0 +1,15 @@
+PROGRAM(messagebus_debug_receiver)
+
+SRCS(
+    debug_receiver.cpp
+    debug_receiver_proto.cpp
+    debug_receiver_handler.cpp
+)
+
+PEERDIR(
+    library/cpp/getopt
+    library/cpp/lwtrace
+    library/cpp/messagebus
+)
+
+END()
diff --git a/library/cpp/messagebus/monitoring/ya.make b/library/cpp/messagebus/monitoring/ya.make
new file mode 100644
index 0000000000..7176d83951
--- /dev/null
+++ b/library/cpp/messagebus/monitoring/ya.make
@@ -0,0 +1,13 @@
+PROTO_LIBRARY()
+
+PEERDIR(
+    library/cpp/monlib/encode/legacy_protobuf/protos
+)
+
+SRCS(
+    mon_proto.proto
+)
+
+EXCLUDE_TAGS(GO_PROTO)
+
+END()
diff --git a/library/cpp/messagebus/oldmodule/ya.make b/library/cpp/messagebus/oldmodule/ya.make
new file mode 100644
index 0000000000..b9ada63467
--- /dev/null
+++ b/library/cpp/messagebus/oldmodule/ya.make
@@ -0,0 +1,13 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/messagebus
+    library/cpp/messagebus/actor
+)
+
+SRCS(
+    module.cpp
+    startsession.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/protobuf/ya.make b/library/cpp/messagebus/protobuf/ya.make
new file mode 100644
index 0000000000..cbe79df675
--- /dev/null
+++ b/library/cpp/messagebus/protobuf/ya.make
@@ -0,0 +1,13 @@
+LIBRARY(messagebus_protobuf)
+
+SRCS(
+    ybusbuf.cpp
+)
+
+PEERDIR(
+    contrib/libs/protobuf
+    library/cpp/messagebus
+    library/cpp/messagebus/actor
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/core/ya.make b/library/cpp/messagebus/rain_check/core/ya.make
new file mode 100644
index 0000000000..dfbbb1446b
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/core/ya.make
@@ -0,0 +1,23 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/coroutine/engine
+    library/cpp/deprecated/enum_codegen
+    library/cpp/messagebus
+    library/cpp/messagebus/actor
+    library/cpp/messagebus/scheduler
+)
+
+SRCS(
+    coro.cpp
+    coro_stack.cpp
+    env.cpp
+    rain_check.cpp
+    simple.cpp
+    sleep.cpp
+    spawn.cpp
+    task.cpp
+    track.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/http/ya.make b/library/cpp/messagebus/rain_check/http/ya.make
new file mode 100644
index 0000000000..f9aaf08fbf
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/http/ya.make
@@ -0,0 +1,15 @@
+LIBRARY()
+
+SRCS(
+    client.cpp
+    http_code_extractor.cpp
+)
+
+PEERDIR(
+    library/cpp/messagebus/rain_check/core
+    library/cpp/neh
+    library/cpp/http/misc
+    library/cpp/http/io
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/messagebus/ya.make b/library/cpp/messagebus/rain_check/messagebus/ya.make
new file mode 100644
index 0000000000..a2f9c2825a
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/messagebus/ya.make
@@ -0,0 +1,13 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/messagebus
+    library/cpp/messagebus/rain_check/core
+)
+
+SRCS(
+    messagebus_client.cpp
+    messagebus_server.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/test/helper/ya.make b/library/cpp/messagebus/rain_check/test/helper/ya.make
new file mode 100644
index 0000000000..4cbdeeb441
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/test/helper/ya.make
@@ -0,0 +1,11 @@
+LIBRARY(messagebus-rain_check-test-helper)
+
+PEERDIR(
+    library/cpp/messagebus/rain_check/core
+)
+
+SRCS(
+    misc.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/test/perftest/ya.make b/library/cpp/messagebus/rain_check/test/perftest/ya.make
new file mode 100644
index 0000000000..79d2884835
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/test/perftest/ya.make
@@ -0,0 +1,12 @@
+PROGRAM(messagebus_rain_check_perftest)
+
+PEERDIR(
+    library/cpp/messagebus/rain_check/core
+    library/cpp/messagebus/rain_check/test/helper
+)
+
+SRCS(
+    perftest.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/test/ut/ya.make b/library/cpp/messagebus/rain_check/test/ut/ya.make
new file mode 100644
index 0000000000..ba6fa9fc8e
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/test/ut/ya.make
@@ -0,0 +1,22 @@
+PROGRAM(library-messagebus-rain_check-test-ut)
+
+PEERDIR(
+    library/cpp/testing/unittest_main
+    library/cpp/messagebus/rain_check/core
+    library/cpp/messagebus/rain_check/http
+    library/cpp/messagebus/rain_check/messagebus
+    library/cpp/messagebus/test/helper
+)
+
+SRCS(
+    ../../core/coro_ut.cpp
+    ../../core/simple_ut.cpp
+    ../../core/sleep_ut.cpp
+    ../../core/spawn_ut.cpp
+    ../../core/track_ut.cpp
+    ../../http/client_ut.cpp
+    ../../messagebus/messagebus_client_ut.cpp
+    ../../messagebus/messagebus_server_ut.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/rain_check/test/ya.make b/library/cpp/messagebus/rain_check/test/ya.make
new file mode 100644
index 0000000000..347086cbc3
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/test/ya.make
@@ -0,0 +1,4 @@
+RECURSE(
+    perftest
+    ut
+)
diff --git a/library/cpp/messagebus/rain_check/ya.make b/library/cpp/messagebus/rain_check/ya.make
new file mode 100644
index 0000000000..c871464744
--- /dev/null
+++ b/library/cpp/messagebus/rain_check/ya.make
@@ -0,0 +1,6 @@
+RECURSE(
+    core
+    http
+    messagebus
+    test
+)
diff --git a/library/cpp/messagebus/scheduler/ut/ya.make b/library/cpp/messagebus/scheduler/ut/ya.make
new file mode 100644
index 0000000000..b43dc6f2d5
--- /dev/null
+++ b/library/cpp/messagebus/scheduler/ut/ya.make
@@ -0,0 +1,11 @@
+UNITTEST()
+
+PEERDIR(
+    library/cpp/messagebus/scheduler
+)
+
+SRCS(
+    ../scheduler_ut.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/scheduler/ya.make b/library/cpp/messagebus/scheduler/ya.make
new file mode 100644
index 0000000000..9ad77875de
--- /dev/null
+++ b/library/cpp/messagebus/scheduler/ya.make
@@ -0,0 +1,16 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/threading/future
+    library/cpp/deprecated/atomic
+)
+
+SRCS(
+    scheduler.cpp
+)
+
+END()
+
+RECURSE_FOR_TESTS(
+    ut
+)
diff --git a/library/cpp/messagebus/test/example/client/ya.make b/library/cpp/messagebus/test/example/client/ya.make
new file mode 100644
index 0000000000..41dace996a
--- /dev/null
+++ b/library/cpp/messagebus/test/example/client/ya.make
@@ -0,0 +1,11 @@
+PROGRAM(messagebus_example_client)
+
+PEERDIR(
+    library/cpp/messagebus/test/example/common
+)
+
+SRCS(
+    client.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/test/example/common/ya.make b/library/cpp/messagebus/test/example/common/ya.make
new file mode 100644
index 0000000000..1281f6b16a
--- /dev/null
+++ b/library/cpp/messagebus/test/example/common/ya.make
@@ -0,0 +1,13 @@
+LIBRARY(messagebus_test_example_common)
+
+PEERDIR(
+    library/cpp/messagebus
+    library/cpp/messagebus/protobuf
+)
+
+SRCS(
+    proto.cpp
+    messages.proto
+)
+
+END()
diff --git a/library/cpp/messagebus/test/example/server/ya.make b/library/cpp/messagebus/test/example/server/ya.make
new file mode 100644
index 0000000000..70101f175c
--- /dev/null
+++ b/library/cpp/messagebus/test/example/server/ya.make
@@ -0,0 +1,11 @@
+PROGRAM(messagebus_example_server)
+
+PEERDIR(
+    library/cpp/messagebus/test/example/common
+)
+
+SRCS(
+    server.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/test/example/ya.make b/library/cpp/messagebus/test/example/ya.make
new file mode 100644
index 0000000000..3635124115
--- /dev/null
+++ b/library/cpp/messagebus/test/example/ya.make
@@ -0,0 +1,5 @@
+RECURSE(
+    client
+    common
+    server
+)
diff --git a/library/cpp/messagebus/test/helper/ya.make b/library/cpp/messagebus/test/helper/ya.make
new file mode 100644
index 0000000000..bf65ab4ea0
--- /dev/null
+++ b/library/cpp/messagebus/test/helper/ya.make
@@ -0,0 +1,16 @@
+LIBRARY(messagebus_test_helper)
+
+SRCS(
+    example.cpp
+    example_module.cpp
+    fixed_port.cpp
+    message_handler_error.cpp
+    hanging_server.cpp
+)
+
+PEERDIR(
+    library/cpp/messagebus/oldmodule
+    library/cpp/deprecated/atomic
+)
+
+END()
diff --git a/library/cpp/messagebus/test/perftest/ya.make b/library/cpp/messagebus/test/perftest/ya.make
new file mode 100644
index 0000000000..4e71ae64cb
--- /dev/null
+++ b/library/cpp/messagebus/test/perftest/ya.make
@@ -0,0 +1,22 @@
+PROGRAM(messagebus_perftest)
+
+PEERDIR(
+    library/cpp/deprecated/threadable
+    library/cpp/execprofile
+    library/cpp/getopt
+    library/cpp/lwtrace
+    library/cpp/messagebus
+    library/cpp/messagebus/oldmodule
+    library/cpp/messagebus/protobuf
+    library/cpp/messagebus/www
+    library/cpp/sighandler
+    library/cpp/threading/future
+)
+
+SRCS(
+    messages.proto
+    perftest.cpp
+    simple_proto.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/test/ut/ya.make b/library/cpp/messagebus/test/ut/ya.make
new file mode 100644
index 0000000000..561c6743a1
--- /dev/null
+++ b/library/cpp/messagebus/test/ut/ya.make
@@ -0,0 +1,51 @@
+UNITTEST_FOR(library/cpp/messagebus)
+
+TIMEOUT(1200)
+
+SIZE(LARGE)
+
+TAG(
+    ya:not_autocheck
+    ya:fat
+)
+
+FORK_SUBTESTS()
+
+PEERDIR(
+    library/cpp/messagebus
+    library/cpp/messagebus/test/helper
+    library/cpp/messagebus/www
+    library/cpp/resource
+    library/cpp/deprecated/atomic
+)
+
+SRCS(
+    messagebus_ut.cpp
+    module_client_ut.cpp
+    module_client_one_way_ut.cpp
+    module_server_ut.cpp
+    one_way_ut.cpp
+    starter_ut.cpp
+    sync_client_ut.cpp
+    locator_uniq_ut.cpp
+    www_ut.cpp
+    ../../async_result_ut.cpp
+    ../../cc_semaphore_ut.cpp
+    ../../coreconn_ut.cpp
+    ../../duration_histogram_ut.cpp
+    ../../message_status_counter_ut.cpp
+    ../../misc/weak_ptr_ut.cpp
+    ../../latch_ut.cpp
+    ../../lfqueue_batch_ut.cpp
+    ../../local_flags_ut.cpp
+    ../../memory_ut.cpp
+    ../../moved_ut.cpp
+    ../../netaddr_ut.cpp
+    ../../network_ut.cpp
+    ../../nondestroying_holder_ut.cpp
+    ../../scheduler_actor_ut.cpp
+    ../../socket_addr_ut.cpp
+    ../../vector_swaps_ut.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/test/ya.make b/library/cpp/messagebus/test/ya.make
new file mode 100644
index 0000000000..ec6d54b093
--- /dev/null
+++ b/library/cpp/messagebus/test/ya.make
@@ -0,0 +1,5 @@
+RECURSE(
+    example
+    perftest
+    ut
+)
diff --git a/library/cpp/messagebus/www/ya.make b/library/cpp/messagebus/www/ya.make
new file mode 100644
index 0000000000..18329845ba
--- /dev/null
+++ b/library/cpp/messagebus/www/ya.make
@@ -0,0 +1,26 @@
+LIBRARY()
+
+SRCS(
+    html_output.cpp
+    www.cpp
+)
+
+RESOURCE(
+    messagebus.js /messagebus.js
+    bus-ico.png /bus-ico.png
+)
+
+PEERDIR(
+    library/cpp/resource
+    library/cpp/cgiparam
+    library/cpp/html/pcdata
+    library/cpp/http/fetch
+    library/cpp/http/server
+    library/cpp/json/writer
+    library/cpp/messagebus
+    library/cpp/messagebus/oldmodule
+    library/cpp/monlib/deprecated/json
+    library/cpp/uri
+)
+
+END()
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
new file mode 100644
index 0000000000..c6ee800bb8
--- /dev/null
+++ b/library/cpp/messagebus/ya.make
@@ -0,0 +1,79 @@
+LIBRARY()
+
+IF (SANITIZER_TYPE == "undefined")
+    NO_SANITIZE()
+ENDIF()
+
+SRCS(
+    acceptor.cpp
+    acceptor_status.cpp
+    connection.cpp
+    coreconn.cpp
+    duration_histogram.cpp
+    event_loop.cpp
+    futex_like.cpp
+    handler.cpp
+    key_value_printer.cpp
+    local_flags.cpp
+    locator.cpp
+    mb_lwtrace.cpp
+    message.cpp
+    message_counter.cpp
+    message_status.cpp
+    message_status_counter.cpp
+    messqueue.cpp
+    misc/atomic_box.h
+    misc/granup.h
+    misc/test_sync.h
+    misc/tokenquota.h
+    misc/weak_ptr.h
+    network.cpp
+    queue_config.cpp
+    remote_client_connection.cpp
+    remote_client_session.cpp
+    remote_client_session_semaphore.cpp
+    remote_connection.cpp
+    remote_connection_status.cpp
+    remote_server_connection.cpp
+    remote_server_session.cpp
+    remote_server_session_semaphore.cpp
+    session.cpp
+    session_impl.cpp
+    session_job_count.cpp
+    shutdown_state.cpp
+    socket_addr.cpp
+    storage.cpp
+    synchandler.cpp
+    use_after_free_checker.cpp
+    use_count_checker.cpp
+    ybus.h
+)
+
+PEERDIR(
+    contrib/libs/sparsehash
+    library/cpp/codecs
+    library/cpp/deprecated/enum_codegen
+    library/cpp/getopt/small
+    library/cpp/lwtrace
+    library/cpp/messagebus/actor
+    library/cpp/messagebus/config
+    library/cpp/messagebus/monitoring
+    library/cpp/messagebus/scheduler
+    library/cpp/string_utils/indent_text
+    library/cpp/threading/future
+    library/cpp/deprecated/atomic
+)
+
+END()
+
+RECURSE(
+    actor
+    config
+    debug_receiver
+    monitoring
+    oldmodule
+    rain_check
+    scheduler
+    test
+    www
+)