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

chore: raise pipeline squashing limit (#2095)

Browse source 
Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>
This commit is contained in:
Vladislav 2023-10-31 00:33:32 +03:00 • committed by GitHub
parent 8a65aec805
commit b403416be0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/facade/dragonfly_connection.cc
View file

@ -48,7 +48,7 @@ ABSL_FLAG(uint64_t, pipeline_queue_limit, 1ULL << 27, // 128MB
ABSL_FLAG(bool, no_tls_on_admin_port, false, "Allow non-tls connections on admin port"); ABSL_FLAG(bool, no_tls_on_admin_port, false, "Allow non-tls connections on admin port");
ABSL_FLAG(uint64_t, pipeline_squash, 5, ABSL_FLAG(uint64_t, pipeline_squash, 10,
"Number of queued pipelined commands above which squashing is enabled, 0 means disabled"); "Number of queued pipelined commands above which squashing is enabled, 0 means disabled");
// When changing this constant, also update `test_large_cmd` test in connection_test.py. // When changing this constant, also update `test_large_cmd` test in connection_test.py.

3
src/server/multi_command_squasher.cc
View file

@ -49,12 +49,13 @@ MultiCommandSquasher::ShardExecInfo& MultiCommandSquasher::PrepareShardInfo(Shar
if (sharded_.empty()) if (sharded_.empty())
sharded_.resize(shard_set->size()); sharded_.resize(shard_set->size());
// See header top for atomic/non-atomic difference
auto& sinfo = sharded_[sid]; auto& sinfo = sharded_[sid];
if (!sinfo.local_tx) { if (!sinfo.local_tx) {
if (IsAtomic()) { if (IsAtomic()) {
sinfo.local_tx = new Transaction{cntx_->transaction, sid}; sinfo.local_tx = new Transaction{cntx_->transaction, sid};
} else { } else {
// Non-atomic squashing does not use the transactional framework for fan out, so local
// transactions have to be fully standalone, check locks and release them immediately.
sinfo.local_tx = new Transaction{base_cid_}; sinfo.local_tx = new Transaction{base_cid_};
sinfo.local_tx->StartMultiNonAtomic(); sinfo.local_tx->StartMultiNonAtomic();
} }