Set minimum keys for always get

So that there is a natural pre-load stage up to a minumum database size

Author: martinsumner

examples/riakc_nhs.config

@@ -15,7 +15,7 @@
 %% For alwaysget operations what is:
 %% - the maximum number of keys per worker (max number of keys = this * concurrent)
 %% - whether the inserts should be in key_order, or whether the order should be skewed by a 1 byte hash at the head of the key
-{alwaysget, {600000, skew_order}}.
+{alwaysget, {600000, 1, skew_order}}.
 
 {pb_ips, [{127,0,0,1}]}.
 {http_ips, [{127,0,0,1}]}.

examples/riakc_nhs_clinicals.config

@@ -15,7 +15,7 @@
 %% For alwaysget operations what is:
 %% - the maximum number of keys per worker (max number of keys = this * concurrent)
 %% - whether the inserts should be in key_order, or whether the order should be skewed by a 1 byte hash at the head of the key
-{alwaysget, {400000, skew_order}}.
+{alwaysget, {400000, 50000, skew_order}}.
 
 {pb_ips, [{127,0,0,1}]}.
 {http_ips, [{127,0,0,1}]}.

src/basho_bench_driver_nhs.erl

@@ -40,6 +40,7 @@
                 http_timeout,
                 fold_timeout,
                 alwaysget_perworker_maxkeycount = 1 :: integer(),
+                alwayshet_perworker_minkeycount = 1 :: integer(),
                 alwaysget_keyorder = key_order :: key_order|skew_order,
                 postcodeq_count = 0 :: integer(),
                 postcodeq_sum = 0 :: integer(),
@@ -118,7 +119,8 @@ new(Id) ->
                                                     PBTargetPort,
                                                     Id]),
 
-    {AGMaxKC, AGKeyOrder} = basho_bench_config:get(alwaysget, {1, key_order}),
+    {AGMaxKC, AGMinKC, AGKeyOrder} = 
+        basho_bench_config:get(alwaysget, {1, 1, key_order}),
 
     case riakc_pb_socket:start_link(PBTargetIp, PBTargetPort) of
         {ok, Pid} ->
@@ -137,6 +139,7 @@ new(Id) ->
                unique_key_count = 1,
                alwaysget_key_count = 0,
                alwaysget_perworker_maxkeycount = AGMaxKC,
+               alwayshet_perworker_minkeycount = AGMinKC,
                alwaysget_keyorder = AGKeyOrder
             }};
         {error, Reason2} ->
@@ -163,19 +166,26 @@ run(alwaysget_pb, _KeyGen, _ValueGen, State) ->
     Pid = State#state.pb_pid,
     Bucket = State#state.recordBucket,
     AGKC = State#state.alwaysget_key_count,
-    KeyInt = eightytwenty_keycount(AGKC),    
-    Key = generate_uniquekey(KeyInt, State#state.rand_keyid, 
-                                State#state.alwaysget_keyorder),
+    case AGKC > State#state.alwayshet_perworker_minkeycount of 
+        true ->
 
-    case {riakc_pb_socket:get(Pid, Bucket, Key, State#state.pb_timeout), KeyInt} of
-        {{ok, _Obj}, _} ->
-            {ok, State};
-        {{error, notfound}, 1} ->
-            lager:info("Not Found with KeyInt of ~w AGKC ~w", [KeyInt, AGKC]),
-            {ok, State};
-        {{error, Reason}, _KeyInt} ->
-            % not_found is not OK
-            {error, Reason, State}
+            KeyInt = eightytwenty_keycount(AGKC),    
+            Key = generate_uniquekey(KeyInt, State#state.rand_keyid, 
+                                        State#state.alwaysget_keyorder),
+
+            case riakc_pb_socket:get(Pid, 
+                                        Bucket, Key, 
+                                        State#state.pb_timeout) of
+                {ok, _Obj} ->
+                    {ok, State};
+                {error, Reason} ->
+                    % not_found is not OK
+                    {error, Reason, State}
+            end;
+
+        false ->
+            {silent, State}
+        
     end;
 
 run(alwaysget_updatewith2i, _KeyGen, ValueGen, State) ->