diff options
| author | ilnaz <ilnaz@ydb.tech> | 2022-09-23 15:58:05 +0300 |
|---|---|---|
| committer | ilnaz <ilnaz@ydb.tech> | 2022-09-23 15:58:05 +0300 |
| commit | 1cedeebe24143a428fbc39266284b6ab5d1529f4 (patch) | |
| tree | 4ee6fe421c15acb9e727fdc08705ee4c617735fb | |
| parent | ae5c206d0c9eabe1b14e297b044dfd2becc96f01 (diff) | |
| download | ydb-1cedeebe24143a428fbc39266284b6ab5d1529f4.tar.gz | |
Check PendingQuotaRequest
| -rw-r--r-- | ydb/services/persqueue_v1/actors/write_session_actor.ipp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/services/persqueue_v1/actors/write_session_actor.ipp b/ydb/services/persqueue_v1/actors/write_session_actor.ipp index 617c1e8ffc4..44e7bd76107 100644 --- a/ydb/services/persqueue_v1/actors/write_session_actor.ipp +++ b/ydb/services/persqueue_v1/actors/write_session_actor.ipp @@ -1246,7 +1246,7 @@ void TWriteSessionActor<UseMigrationProtocol>::PrepareRequest(THolder<TEvWrite>& PendingQuotaRequest = std::move(PendingRequest); } } else { - if (SentRequests.size() < MAX_RESERVE_REQUESTS_INFLIGHT) { + if (!PendingQuotaRequest && SentRequests.size() < MAX_RESERVE_REQUESTS_INFLIGHT) { SendRequest(std::move(PendingRequest), ctx); } } |