anchor.diff:  
   
   handle_cast({inform, Bucket}, State) ->
  -    lager:info("[~p] io node informed about: ~p", [Bucket]),
  +    lager:info("io node binformed about: ~p", [Bucket]),
       {_, State1} = get_or_create_set(Bucket, State),
       {noreply, State1};
   
  
positive.code:     gb_trees:map(fun(_, {_, MSet}) ->
                           mstore:close(MSet)
                   end, MStore),
      lager:error("[~p] io server terminated: ~p", [self(), Reason]),
      case S#state.reader_pool of
          undefined ->
              ok;
  
negative.code:             lager:warning("[IO] Unknown metric: ~p/~p", [Bucket, Metric]),
              {{error, not_found}, State}
      end.
  
  -spec do_read(binary(), binary(), non_neg_integer(), pos_integer(), state()) ->
                       {bitstring(), state()}.
  do_read(Bucket, Metric, Time, Count, State = #state{})
  