Synchronization of the read and write order for compactified topics #22557
Conversation
|
🟢 |
|
⚪ |
|
⚪ |
| if (!RequestsInflight && WaitingInflightRequests.empty() && (ExclusiveLockState == EExclusiveLockState::EAcquiring)) { | ||
| ExclusiveLockState = EExclusiveLockState::EAcquired; | ||
| ReplyExclusiveLockAcquired(ExclusiveLockRequester); | ||
| } | ||
| } | ||
|
|
||
| void TPartitionQuoterBase::ProcessInflightQueue() { | ||
| auto now = ActorContext().Now(); | ||
| while (!WaitingInflightRequests.empty() && RequestsInflight < MaxInflightRequests) { |
There was a problem hiding this comment.
Не надо ли тут проверить еще и стейт лока, что он Released?
|
|
||
| void TPartitionQuoterBase::HandleReleaseExclusiveLock(TEvPQ::TEvReleaseExclusiveLock::TPtr& ev, const TActorContext& ctx) | ||
| { | ||
| ExclusiveLockState = EExclusiveLockState::EReleased; |
There was a problem hiding this comment.
Y_VERIFY если стейт EReleased
Changelog entry
Added a synchronization primitive. Shared read, exclusive write.
Changelog category
Description for reviewers
...