mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

chore(blocking): Remove faulty DCHECK (#2898)

Browse source 
* chore(blocking): Remove faulty DCHECK

---------

Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>
This commit is contained in:
Vladislav 2024-04-12 22:11:47 +03:00 • committed by GitHub
parent 9bed3390d7
commit 0693846d9b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/server/transaction.cc
View file

@ -1200,7 +1200,12 @@ size_t Transaction::ReverseArgIndex(ShardId shard_id, size_t arg_index) const {
OpStatus Transaction::WaitOnWatch(const time_point& tp, WaitKeysProvider wkeys_provider,
KeyReadyChecker krc, bool* block_flag, bool* pause_flag) {
DCHECK(!blocking_barrier_.IsClaimed()); // Blocking barrier can't be re-used
if (blocking_barrier_.IsClaimed()) { // Might have been cancelled ahead by a dropping connection
Conclude();
return OpStatus::CANCELLED;
}
DCHECK(!IsAtomicMulti()); // blocking inside MULTI is not allowed
// Register keys on active shards blocking controllers and mark shard state as suspended.
auto cb = [&](Transaction* t, EngineShard* shard) {