anchor.diff:                                                         avail_tokens = NewAvailTokens},
               ?xdcr_debug("number of total tokens changes from ~p to ~p, "
                           "number of available tokens changes from  ~p to ~p, reported by replicator: ~p",
  -                       [TotalTokens, NewTokens, AvailTokens, NewAvailTokens,Pid]),
  +                        [TotalTokens, NewTokens, AvailTokens, NewAvailTokens,Pid]),
   
               %% schedule more jobs if we have more available tokens
               NewState = if
  
positive.code: %% if fails to call is_done/1 but dies, this module will notice and clean it up.
  %% If the process fails to call is_done/1 but runs forever, it's concurrency
  %% turn will last forever preventing other processes from their turns.
  %
  %% Each process is granted a turn in the order it calls send_back_when_can_go/2
  
  -module(concurrency_throttle).
  
negative.code:                 [Pid, TargetNode, NewCount, TotalTokens]),
  
      NewState = State#concurrency_throttle_state{
                   avail_tokens = NewCount,
                   monitor_dict = NewMonDict,
                   target_load = NewTargetLoad,
                   active_pool = NewActivePool},
  
      {reply, ok, update_status_to_parent(NewState)};
  
  