Leaks in ydb/services/persqueue_v1/ut TPersQueueTest.DisableDeduplication #13565
Description
#13537 (comment) -- run
https://storage.yandexcloud.net/ydb-gh-logs/ydb-platform/ydb/PR-check/12858529626/ya-x86-64-asan/try_1/ya-test.html#FAIL --html report
=================================================================
==498095==ERROR: LeakSanitizer: detected memory leaks
Indirect leak of 4787048 byte(s) in 73 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18d62213 in grpc_event_engine::experimental::MemoryAllocator::MakeSlice(grpc_event_engine::experimental::MemoryRequest) /-S/contrib/libs/grpc/src/core/lib/event_engine/memory_allocator.cc:63:13
#2 0x18d3cbcd in maybe_make_read_slices /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1070:57
#3 0x18d3cbcd in tcp_handle_read(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1094:5
#4 0x18d40ff7 in Run /-S/contrib/libs/grpc/src/core/lib/iomgr/closure.h:303:5
#5 0x18d40ff7 in tcp_read(grpc_endpoint*, grpc_slice_buffer*, grpc_closure*, bool, int) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1156:5
#6 0x19099cd8 in continue_read_action_locked /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2592:3
#7 0x19099cd8 in read_action_locked(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2581:7
#8 0x18c327a6 in grpc_combiner_continue_exec_ctx() /-S/contrib/libs/grpc/src/core/lib/iomgr/combiner.cc:231:5
#9 0x18c0beb4 in grpc_core::ExecCtx::Flush() /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:75:17
#10 0x18d503e4 in end_worker /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc
#11 0x18d503e4 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc:1049:3
#12 0x18d4c0a8 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_posix.cc:249:7
#13 0x18d75ac8 in grpc_pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/pollset.cc:48:10
#14 0x18d2ab37 in cq_next(grpc_completion_queue*, gpr_timespec, void*) /-S/contrib/libs/grpc/src/core/lib/surface/completion_queue.cc:1036:29
#15 0x198c8f7e in grpc::CompletionQueue::AsyncNextInternal(void**, bool*, gpr_timespec) /-S/contrib/libs/grpc/src/cpp/common/completion_queue_cc.cc:166:15
#16 0x1f5ea31f in Next /-S/contrib/libs/grpc/include/grpcpp/completion_queue.h:182:13
#17 0x1f5ea31f in NYdbGrpc::PullEvents(grpc::CompletionQueue*) /-S/ydb/library/grpc/client/grpc_client_low.cpp:182:18
#18 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#19 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#20 0x198de2be in (anonymous namespace)::TThreadFactoryFuncObj::DoExecute() /-S/util/thread/factory.cpp:61:13
#21 0x198de80c in Execute /-S/util/thread/factory.h:15:13
#22 0x198de80c in (anonymous namespace)::TSystemThreadFactory::TPoolThread::ThreadProc(void*) /-S/util/thread/factory.cpp:36:41
#23 0x17e16e54 in (anonymous namespace)::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:244:20
#24 0x17acdf78 in asan_thread_start(void*) /-S/contrib/libs/clang18-rt/lib/asan/asan_interceptors.cpp:239:28
Indirect leak of 1311520 byte(s) in 20 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18d62213 in grpc_event_engine::experimental::MemoryAllocator::MakeSlice(grpc_event_engine::experimental::MemoryRequest) /-S/contrib/libs/grpc/src/core/lib/event_engine/memory_allocator.cc:63:13
#2 0x18d3cbcd in maybe_make_read_slices /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1070:57
#3 0x18d3cbcd in tcp_handle_read(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1094:5
#4 0x18d40ff7 in Run /-S/contrib/libs/grpc/src/core/lib/iomgr/closure.h:303:5
#5 0x18d40ff7 in tcp_read(grpc_endpoint*, grpc_slice_buffer*, grpc_closure*, bool, int) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1156:5
#6 0x19099cd8 in continue_read_action_locked /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2592:3
#7 0x19099cd8 in read_action_locked(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2581:7
#8 0x18c327a6 in grpc_combiner_continue_exec_ctx() /-S/contrib/libs/grpc/src/core/lib/iomgr/combiner.cc:231:5
#9 0x18c0beb4 in grpc_core::ExecCtx::Flush() /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:75:17
#10 0x18d503e4 in end_worker /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc
#11 0x18d503e4 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc:1049:3
#12 0x18d4c0a8 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_posix.cc:249:7
#13 0x18d75ac8 in grpc_pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/pollset.cc:48:10
#14 0x18d2ab37 in cq_next(grpc_completion_queue*, gpr_timespec, void*) /-S/contrib/libs/grpc/src/core/lib/surface/completion_queue.cc:1036:29
#15 0x198c8f7e in grpc::CompletionQueue::AsyncNextInternal(void**, bool*, gpr_timespec) /-S/contrib/libs/grpc/src/cpp/common/completion_queue_cc.cc:166:15
#16 0x2fc9f5b6 in Next /-S/contrib/libs/grpc/include/grpcpp/completion_queue.h:182:13
#17 0x2fc9f5b6 in PullEvents /-S/ydb/library/grpc/server/grpc_server.cpp:41:17
#18 0x2fc9f5b6 in operator() /-S/ydb/library/grpc/server/grpc_server.cpp:266:13
#19 0x2fc9f5b6 in __invoke<(lambda at /-S/ydb/library/grpc/server/grpc_server.cpp:265:49) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#20 0x2fc9f5b6 in __call<(lambda at /-S/ydb/library/grpc/server/grpc_server.cpp:265:49) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#21 0x2fc9f5b6 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#22 0x2fc9f5b6 in std::__y1::__function::__func<NYdbGrpc::TGRpcServer::Start()::$_0, std::__y1::allocator<NYdbGrpc::TGRpcServer::Start()::$_0>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#23 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#24 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#25 0x198de2be in (anonymous namespace)::TThreadFactoryFuncObj::DoExecute() /-S/util/thread/factory.cpp:61:13
#26 0x198de80c in Execute /-S/util/thread/factory.h:15:13
#27 0x198de80c in (anonymous namespace)::TSystemThreadFactory::TPoolThread::ThreadProc(void*) /-S/util/thread/factory.cpp:36:41
#28 0x17e16e54 in (anonymous namespace)::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:244:20
#29 0x17acdf78 in asan_thread_start(void*) /-S/contrib/libs/clang18-rt/lib/asan/asan_interceptors.cpp:239:28
Indirect leak of 459032 byte(s) in 7 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18d62213 in grpc_event_engine::experimental::MemoryAllocator::MakeSlice(grpc_event_engine::experimental::MemoryRequest) /-S/contrib/libs/grpc/src/core/lib/event_engine/memory_allocator.cc:63:13
#2 0x18d3cbcd in maybe_make_read_slices /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1070:57
#3 0x18d3cbcd in tcp_handle_read(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1094:5
#4 0x18d40ff7 in Run /-S/contrib/libs/grpc/src/core/lib/iomgr/closure.h:303:5
#5 0x18d40ff7 in tcp_read(grpc_endpoint*, grpc_slice_buffer*, grpc_closure*, bool, int) /-S/contrib/libs/grpc/src/core/lib/iomgr/tcp_posix.cc:1156:5
#6 0x19099cd8 in continue_read_action_locked /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2592:3
#7 0x19099cd8 in read_action_locked(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2581:7
#8 0x18c327a6 in grpc_combiner_continue_exec_ctx() /-S/contrib/libs/grpc/src/core/lib/iomgr/combiner.cc:231:5
#9 0x18c0beb4 in grpc_core::ExecCtx::Flush() /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:75:17
#10 0x18c3661b in grpc_core::Executor::RunClosures(char const*, grpc_closure_list) /-S/contrib/libs/grpc/src/core/lib/iomgr/executor.cc:141:21
#11 0x18c3705a in grpc_core::Executor::ThreadMain(void*) /-S/contrib/libs/grpc/src/core/lib/iomgr/executor.cc:257:22
#12 0x18c3a66e in operator() /-S/contrib/libs/grpc/src/core/lib/gprpp/posix/thd.cc:135:11
#13 0x18c3a66e in grpc_core::(anonymous namespace)::ThreadInternalsPosix::ThreadInternalsPosix(char const*, void (*)(void*), void*, bool*, grpc_core::Thread::Options const&)::'lambda'(void*)::__invoke(void*) /-S/contrib/libs/grpc/src/core/lib/gprpp/posix/thd.cc:117:9
#14 0x17acdf78 in asan_thread_start(void*) /-S/contrib/libs/clang18-rt/lib/asan/asan_interceptors.cpp:239:28
Indirect leak of 6464 byte(s) in 1 object(s) allocated from:
#0 0x17ad081c in realloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:82:3
#1 0x18bd68c6 in gpr_realloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:53:7
#2 0x18c08a7d in do_embiggen(grpc_slice_buffer*, unsigned long, unsigned long) /-S/contrib/libs/grpc/src/core/lib/slice/slice_buffer.cc:99:11
#3 0x18c03c36 in maybe_embiggen /-S/contrib/libs/grpc/src/core/lib/slice/slice_buffer.cc:116:5
#4 0x18c03c36 in grpc_slice_buffer_add_indexed /-S/contrib/libs/grpc/src/core/lib/slice/slice_buffer.cc:167:3
#5 0x18c03c36 in grpc_slice_buffer_add /-S/contrib/libs/grpc/src/core/lib/slice/slice_buffer.cc:225:3
#6 0x190f4589 in grpc_chttp2_data_parser_parse(void*, grpc_chttp2_transport*, grpc_chttp2_stream*, grpc_slice const&, int) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/frame_data.cc:146:3
#7 0x190fad3c in parse_frame_slice(grpc_chttp2_transport*, grpc_slice const&, int) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/parsing.cc:806:7
#8 0x190f9821 in grpc_chttp2_perform_read(grpc_chttp2_transport*, grpc_slice const&) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/parsing.cc:379:15
#9 0x190990ed in read_action_locked(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/ext/transport/chttp2/transport/chttp2_transport.cc:2528:19
#10 0x18c327a6 in grpc_combiner_continue_exec_ctx() /-S/contrib/libs/grpc/src/core/lib/iomgr/combiner.cc:231:5
#11 0x18c0beb4 in grpc_core::ExecCtx::Flush() /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:75:17
#12 0x18c3661b in grpc_core::Executor::RunClosures(char const*, grpc_closure_list) /-S/contrib/libs/grpc/src/core/lib/iomgr/executor.cc:141:21
#13 0x18c3705a in grpc_core::Executor::ThreadMain(void*) /-S/contrib/libs/grpc/src/core/lib/iomgr/executor.cc:257:22
#14 0x18c3a66e in operator() /-S/contrib/libs/grpc/src/core/lib/gprpp/posix/thd.cc:135:11
#15 0x18c3a66e in grpc_core::(anonymous namespace)::ThreadInternalsPosix::ThreadInternalsPosix(char const*, void (*)(void*), void*, bool*, grpc_core::Thread::Options const&)::'lambda'(void*)::__invoke(void*) /-S/contrib/libs/grpc/src/core/lib/gprpp/posix/thd.cc:117:9
#16 0x17acdf78 in asan_thread_start(void*) /-S/contrib/libs/clang18-rt/lib/asan/asan_interceptors.cpp:239:28
Indirect leak of 6174 byte(s) in 18 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c88988 in AllocZone /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:108:18
#4 0x18c88988 in Alloc /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.h:162:14
#5 0x18c88988 in grpc_core::Arena::AllocPooled(unsigned long, unsigned long, std::__y1::atomic<grpc_core::Arena::FreePoolNode*>*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:144:15
#6 0x18e17ea8 in std::__y1::unique_ptr<grpc_core::Message, grpc_core::Arena::PooledDeleter> grpc_core::Arena::MakePooled<grpc_core::Message>() /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.h:224:14
#7 0x18e1b01c in grpc_core::promise_filter_detail::BaseCallData::ReceiveMessage::WakeInsideCombiner(grpc_core::promise_filter_detail::BaseCallData::Flusher*, bool) /-S/contrib/libs/grpc/src/core/lib/channel/promise_based_filter.cc:850:45
#8 0x18e21480 in grpc_core::promise_filter_detail::ClientCallData::PollContext::Run() /-S/contrib/libs/grpc/src/core/lib/channel/promise_based_filter.cc:1046:33
#9 0x18e29fcc in grpc_core::promise_filter_detail::ClientCallData::WakeInsideCombiner(grpc_core::promise_filter_detail::BaseCallData::Flusher*) /-S/contrib/libs/grpc/src/core/lib/channel/promise_based_filter.cc:1856:30
#10 0x18e196c2 in grpc_core::promise_filter_detail::BaseCallData::ReceiveMessage::OnComplete(y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/lib/channel/promise_based_filter.cc:746:10
#11 0x18e3dd0e in operator() /-S/contrib/libs/grpc/src/core/lib/iomgr/closure.h:128:3
#12 0x18e3dd0e in grpc_closure grpc_core::MakeMemberClosure<grpc_core::promise_filter_detail::BaseCallData::ReceiveMessage, &grpc_core::promise_filter_detail::BaseCallData::ReceiveMessage::OnComplete(y_absl::lts_y_20240722::Status)>(grpc_core::promise_filter_detail::BaseCallData::ReceiveMessage*, grpc_core::DebugLocation)::'lambda'(void*, y_absl::lts_y_20240722::Status)::__invoke(void*, y_absl::lts_y_20240722::Status) /-S/contrib/libs/grpc/src/core/lib/iomgr/closure.h:128:3
#13 0x18c0be7e in exec_ctx_run /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:45:3
#14 0x18c0be7e in grpc_core::ExecCtx::Flush() /-S/contrib/libs/grpc/src/core/lib/iomgr/exec_ctx.cc:72:9
#15 0x18d503e4 in end_worker /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc
#16 0x18d503e4 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_epoll1_linux.cc:1049:3
#17 0x18d4c0a8 in pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/ev_posix.cc:249:7
#18 0x18d75ac8 in grpc_pollset_work(grpc_pollset*, grpc_pollset_worker**, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/iomgr/pollset.cc:48:10
#19 0x18d2ab37 in cq_next(grpc_completion_queue*, gpr_timespec, void*) /-S/contrib/libs/grpc/src/core/lib/surface/completion_queue.cc:1036:29
#20 0x198c8f7e in grpc::CompletionQueue::AsyncNextInternal(void**, bool*, gpr_timespec) /-S/contrib/libs/grpc/src/cpp/common/completion_queue_cc.cc:166:15
#21 0x1f5ea31f in Next /-S/contrib/libs/grpc/include/grpcpp/completion_queue.h:182:13
#22 0x1f5ea31f in NYdbGrpc::PullEvents(grpc::CompletionQueue*) /-S/ydb/library/grpc/client/grpc_client_low.cpp:182:18
#23 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#24 0x198de2be in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#25 0x198de2be in (anonymous namespace)::TThreadFactoryFuncObj::DoExecute() /-S/util/thread/factory.cpp:61:13
#26 0x198de80c in Execute /-S/util/thread/factory.h:15:13
#27 0x198de80c in (anonymous namespace)::TSystemThreadFactory::TPoolThread::ThreadProc(void*) /-S/util/thread/factory.cpp:36:41
#28 0x17e16e54 in (anonymous namespace)::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:244:20
#29 0x17acdf78 in asan_thread_start(void*) /-S/contrib/libs/clang18-rt/lib/asan/asan_interceptors.cpp:239:28
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x1759c698 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadBadCases::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1214:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x1759be8f in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadBadCases::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1198:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x17598133 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadNotCached::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1163:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x175ab735 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadCleanCache::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1328:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x175b448a in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadRestartPQRB::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1363:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x175be4f1 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadRestartTablet::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1400:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x17582baa in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadPreCached::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1130:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
Indirect leak of 5527 byte(s) in 1 object(s) allocated from:
#0 0x17ad042f in malloc /-S/contrib/libs/clang18-rt/lib/asan/asan_malloc_linux.cpp:68:3
#1 0x18bd6900 in gpr_malloc /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:32:7
#2 0x18bd6900 in gpr_malloc_aligned /-S/contrib/libs/grpc/src/core/lib/gpr/alloc.cc:63:13
#3 0x18c882e7 in ArenaStorage /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:42:10
#4 0x18c882e7 in grpc_core::Arena::CreateWithAlloc(unsigned long, unsigned long, grpc_event_engine::experimental::MemoryAllocator*) /-S/contrib/libs/grpc/src/core/lib/resource_quota/arena.cc:71:26
#5 0x18c3ea3a in grpc_core::FilterStackCall::Create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:819:46
#6 0x18c5cdd7 in grpc_call_create(grpc_call_create_args*, grpc_call**) /-S/contrib/libs/grpc/src/core/lib/surface/call.cc:3456:10
#7 0x18cf9432 in grpc_channel_create_call_internal(grpc_channel*, grpc_call*, unsigned int, grpc_completion_queue*, grpc_pollset_set*, grpc_core::Slice, std::__y1::optional<grpc_core::Slice>, grpc_core::Timestamp) /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:304:3
#8 0x18cfb755 in grpc_channel_create_registered_call /-S/contrib/libs/grpc/src/core/lib/surface/channel.cc:411:21
#9 0x198be38b in grpc::Channel::CreateCallInternal(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*, unsigned long) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:117:14
#10 0x198bed90 in grpc::Channel::CreateCall(grpc::internal::RpcMethod const&, grpc::ClientContext*, grpc::CompletionQueue*) /-S/contrib/libs/grpc/src/cpp/client/channel_cc.cc:160:10
#11 0x1a1337db in grpc::ClientReaderWriter<Ydb::Topic::StreamDirectReadMessage_FromClient, Ydb::Topic::StreamDirectReadMessage_FromServer>::ClientReaderWriter(grpc::ChannelInterface*, grpc::internal::RpcMethod const&, grpc::ClientContext*) /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:560:24
#12 0x1a0ff47a in Create /-S/contrib/libs/grpc/include/grpcpp/support/sync_stream.h:439:16
#13 0x1a0ff47a in Ydb::Topic::V1::TopicService::Stub::StreamDirectReadRaw(grpc::ClientContext*) /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.cc:94:10
#14 0x1758e535 in StreamDirectRead /-B/ydb/public/api/grpc/ydb_topic_v1.grpc.pb.h:404:160
#15 0x1758e535 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TDirectReadTestSetup::InitDirectSession(TBasicString<char, std::__y1::char_traits<char>> const&, Ydb::StatusIds_StatusCode, TBasicString<char, std::__y1::char_traits<char>> const&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1037:34
#16 0x1759fe68 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TTestCaseDirectReadStop::Execute_(NUnitTest::TTestContext&) /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:1259:15
#17 0x17851767 in operator() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#18 0x17851767 in __invoke<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:150:25
#19 0x17851767 in __call<(lambda at /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:225:5
#20 0x17851767 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:169:12
#21 0x17851767 in std::__y1::__function::__func<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:311:10
#22 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:428:12
#23 0x182b8648 in operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:981:10
#24 0x182b8648 in TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:525:20
#25 0x18289458 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:374:18
#26 0x17850755 in NKikimr::NPersQueueTests::NTestSuiteTPersQueueTest::TCurrentTest::Execute() /-S/ydb/services/persqueue_v1/persqueue_ut.cpp:134:1
#27 0x1828ad25 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:495:19
#28 0x182b2fec in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
#29 0x7f652e6ffd8f (/lib/x86_64-linux-gnu/libc.so.6+0x29d8f) (BuildId: 490fef8403240c91833978d494d39e537409b92e)
<...>
See full leaks in logs