Skip to content

Commit 88fadd7

Browse files
committed
Support worker counts in psi keygen
1 parent 289d4d2 commit 88fadd7

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/basho_bench_keygen.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,9 +91,11 @@ new({sequential_int, MaxKey}, Id)
9191
fun() -> sequential_int_generator(Ref, MaxKey, Id, DisableProgress) end;
9292
new({partitioned_sequential_int, MaxKey}, Id) ->
9393
new({partitioned_sequential_int, 0, MaxKey}, Id);
94-
new({partitioned_sequential_int, StartKey, NumKeys}, Id)
95-
when is_integer(StartKey), is_integer(NumKeys), NumKeys > 0 ->
94+
new({partitioned_sequential_int, StartKey, NumKeys}, Id) ->
9695
Workers = basho_bench_config:get(concurrent),
96+
new({partitioned_sequential_int, StartKey, NumKeys, Workers}, Id);
97+
new({partitioned_sequential_int, StartKey, NumKeys, Workers}, Id)
98+
when is_integer(StartKey), is_integer(NumKeys), NumKeys > 0 ->
9799
Range = NumKeys div Workers,
98100
MinValue = StartKey + Range * (Id - 1),
99101
MaxValue = StartKey +

0 commit comments

Comments
 (0)