diff options
| author | alexbogo <alexbogo@ydb.tech> | 2023-02-09 15:39:05 +0300 |
|---|---|---|
| committer | alexbogo <alexbogo@ydb.tech> | 2023-02-09 15:39:05 +0300 |
| commit | ad3cde6d734e3ee4d68743d94849307c437d6c99 (patch) | |
| tree | 0300a102c81c3eae6849dd551ee8c61f32dddeae | |
| parent | 41ed181a9e4d11cb6831c7113716e0d2df124fcd (diff) | |
| download | ydb-ad3cde6d734e3ee4d68743d94849307c437d6c99.tar.gz | |
fix deadlock in test TPersQueueNewSchemeCacheTest::TestReadAtTimestamp
init
| -rw-r--r-- | ydb/services/persqueue_v1/persqueue_new_schemecache_ut.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/ydb/services/persqueue_v1/persqueue_new_schemecache_ut.cpp b/ydb/services/persqueue_v1/persqueue_new_schemecache_ut.cpp index dc32613cfb0..04f587f78a8 100644 --- a/ydb/services/persqueue_v1/persqueue_new_schemecache_ut.cpp +++ b/ydb/services/persqueue_v1/persqueue_new_schemecache_ut.cpp @@ -255,11 +255,6 @@ namespace NKikimr::NPersQueueTests { } messagesReceived = msg.GetOffset() + 1; } - if (messagesReceived >= maxMessagesCount) { - Cerr << "Closing session. Got " << messagesReceived << " messages" << Endl; - reader->Close(TDuration::Seconds(0)); - Cerr << "Session closed" << Endl; - } }, false); reader = CreateReader(*ydbDriver, settings); @@ -267,6 +262,9 @@ namespace NKikimr::NPersQueueTests { Cout.Flush(); while (messagesReceived < maxMessagesCount) Sleep(TDuration::MilliSeconds(10)); + Cerr << "Closing session. Got " << messagesReceived << " messages" << Endl; + reader->Close(TDuration::Seconds(0)); + Cerr << "Session closed" << Endl; if (tsIt == 0) { for (ui32 i = 0; i < ts.size(); ++i) { |