anchor.diff:  -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,
  
positive.code:     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),
  
negative.code: send_traffic(PoolName, BucketName) ->
      case catch(mc_pool:get_bucket(PoolName, BucketName)) of
          {'EXIT', _} ->
              traffic_stop();
          {ok, Bucket} ->
              Addrs = mc_bucket:addrs(Bucket),
  