anchor.diff:      gb_trees:map(fun(_, {_, MSet}) ->
                            mstore:close(MSet)
                    end, MStore),
  -    lager:error("[~p] io server terminated: ~p", [self(), Reason]),
  +    case Reason of
  +        shutdown ->
  +            ok;
  +        _ ->
  +            lager:error("[~p] io server terminated: ~p", [self(), Reason])
  +    end,
       case S#state.reader_pool of
           undefined ->
               ok;
  
positive.code: 
  
  handle_cast({inform, Bucket}, State) ->
      lager:info("[~p] io node informed about: ~p", [Bucket]),
      {_, State1} = get_or_create_set(Bucket, State),
      {noreply, State1};
  
  
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{})
  