anchor.diff:      Port     = basho_bench_config:get(cassandra_port, 9160),
       Keyspace = basho_bench_config:get(cassandra_keyspace, "Keyspace1"),
       ColPath  = #columnPath { column_family = "Standard1", column = "col1" },
  +    ConLevel = basho_bench_config:get(cassandra_consistencylevel, 1),
   
       %% Choose the node using our ID as a modulus
       TargetHost = lists:nth((Id rem length(Hosts)+1), Hosts),
  
positive.code:         {ok, Client} ->
              {ok, #state { client = Client,
                            keyspace = Keyspace,
                            colpath = ColPath }};
          {error, Reason} ->
              ?FAIL_MSG("Failed to get a thrift_client for ~p: ~p\n", [TargetHost, Reason])
      end.
  
negative.code:     (Mega * 1000000) + Sec.
  
  
  run(get, KeyGen, _ValueGen,
      #state{keyspace=KeySpace, colpath=ColPath, conlevel=ConLevel}=State) ->
      Key = KeyGen(),
      Args = [KeySpace, Key, ColPath, ConLevel],
      case call(State, get, Args) of
          {ok, _} ->
              {ok, State};
          {notFoundException} ->
              %% DEBUG io:format("g(~p)",[Key]),
              io:format("g"),
              {ok, State};
          {'EXIT', {timeout, _}} ->
              {error, timeout, State};
          Error ->
              {error, Error, State}
      end;
  run(put, KeyGen, ValueGen,
      #state{keyspace=KeySpace, colpath=ColPath, conlevel=ConLevel}=State) ->
      Key = KeyGen(),
      Val = ValueGen(),
      TS = tstamp(),
      Args = [KeySpace, Key, ColPath, Val, TS, ConLevel],
      case call(State, insert, Args) of
          {ok, ok} ->
              {ok, State};
          {'EXIT', {timeout, _}} ->
              {error, timeout, State};
          Error ->
              {error, Error, State}
      end;
  run(delete, KeyGen, _ValueGen,
      #state{keyspace=KeySpace, colpath=ColPath, conlevel=ConLevel}=State) ->
      Key = KeyGen(),
      TS = 0, %% TBD: cannot specify a "known" timestamp value?
      Args = [KeySpace, Key, ColPath, TS, ConLevel],
      case call(State, remove, Args) of
          {ok, _} ->
              {ok, State};
          {notFoundException} ->
              %% DEBUG io:format("d(~p)",[Key]),
              io:format("d"),
              {ok, State};
          {'EXIT', {timeout, _}} ->
              {error, timeout, State};
          Error ->
              {error, Error, State}
      end.
  