Skip to content

Commit 346d9de

Browse files
authored
Merge pull request #45 from cloudant/cloudant-update-partitioned-sequential-int-keygen
Support worker counts in psi keygen
2 parents 289d4d2 + 88fadd7 commit 346d9de

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)