anchor.diff:  terminate(_Reason, _State)     -> ok.
   code_change(_OldVsn, State, _) -> {ok, State}.
   
  -
   handle_cast(traffic_start, #state{timer = undefined} = State) ->
       bucket_make(?TGEN_POOL, ?TGEN_BUCKET),
       timer:sleep(2000), % Wait a couple seconds to avoid spammy auth errors
  
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:     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),
  