anchor.diff:      timer:cancel(TRef),
       {noreply, State#state{timer = undefined}}.
   
  -
   handle_call(traffic_started, _From, #state{timer = TRef} = State) ->
       {reply, TRef =/= undefined, State}.
  -
   
   handle_info(traffic_more, #state{timer = _TRef} = State) ->
       send_traffic(?TGEN_POOL, ?TGEN_BUCKET),
  
positive.code: send_traffic(PoolName, BucketName) ->
      case catch(mc_pool:get_bucket(PoolName, BucketName)) of
          {'EXIT', _} ->
              ?debugVal({send_traffic, missing_bucket, PoolName, BucketName}),
              traffic_stop();
          {ok, Bucket} ->
              Addrs = mc_bucket:addrs(Bucket),
  
negative.code: -define(TGEN_POOL,     "default").
  -define(TGEN_BUCKET,   "test_application").
  -define(TGEN_SIZE,     1). % In MB
  
  %% gen_server callbacks
  
  -export([init/1, handle_call/3, handle_cast/2,
  