diff options
| author | Nikolay Shestakov <tesseract@ydb.tech> | 2024-07-30 11:56:05 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-30 11:56:05 +0500 |
| commit | c0f561e76f3b2dbc80435cfdf3346abb43d07587 (patch) | |
| tree | a570e4e0213f814228a9e445da200452a6f2ede6 | |
| parent | 4b64a058a398d17eae6dc6e53852849ba4e17a82 (diff) | |
| download | ydb-c0f561e76f3b2dbc80435cfdf3346abb43d07587.tar.gz | |
do not send request to PartitionActor after finishing of reading (#7214)
| -rw-r--r-- | ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp index 9f21d2bbb6d..07b5b589908 100644 --- a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp +++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp @@ -2419,6 +2419,10 @@ void TPartitionActor::InitLockPartition(const TActorContext& ctx) { void TPartitionActor::WaitDataInPartition(const TActorContext& ctx) { + if (ReadingFinishedSent) { + return; + } + if (WaitDataInfly.size() > 1) { //already got 2 requests inflight return; } |