1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00

fix(server): Fix early reply from DEBUG POPULATE (#1441)

Fixes #1424
This commit is contained in:
Chaka 2023-06-22 14:48:27 +03:00 committed by GitHub
parent 08b46db28a
commit 6205871d35
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -410,7 +410,7 @@ void DebugCmd::PopulateRangeFiber(uint64_t from, uint64_t num_of_keys,
}
}
ess.RunBlockingInParallel([&](EngineShard* shard) {
ess.AwaitRunningOnShardQueue([&](EngineShard* shard) {
DoPopulateBatch(options.prefix, options.val_size, options.populate_random_values, params,
ps[shard->shard_id()]);
});