Skip to content

Commit 6c39e22

Browse files
committed
Intermediate changes
commit_hash:f6c369e4b7825439c70c9263ad32680b6161df7c
1 parent 2084bac commit 6c39e22

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

yt/yt/core/rpc/unittests/rpc_ut.cpp

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -789,6 +789,10 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
789789
{
790790
MaybeInitLatch();
791791

792+
auto testId = TGuid::Create();
793+
794+
Cerr << Format("Start of the RequestQueueSizeLimit test (Id: %v)", testId) << '\n';
795+
792796
std::vector<TFuture<void>> futures;
793797
std::vector<TTestProxy> proxies;
794798

@@ -801,7 +805,9 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
801805

802806
for (int i = 0; i <= 30; ++i) {
803807
auto req = proxies[i].LatchedCall();
804-
futures.push_back(req->Invoke().AsVoid());
808+
futures.push_back(req->Invoke().AsVoid().Apply(BIND([i, testId] (const TError& error) {
809+
Cerr << NYT::Format("Request %v finished (Id: %v, Error: %v)", i, testId, error) << '\n';
810+
})));
805811
}
806812

807813
Sleep(TDuration::MilliSeconds(400));
@@ -816,6 +822,8 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
816822
EXPECT_TRUE(AllSucceeded(std::move(futures)).Get().IsOK());
817823

818824
ResetLatch();
825+
826+
Cerr << Format("End of the RequestQueueSizeLimit test (Id: %v)", testId) << '\n';
819827
}
820828

821829
TYPED_TEST(TNotGrpcTest, RequesMemoryPressureException)

0 commit comments

Comments
 (0)