anchor.diff:                    end,
               case post(Msg, S, ID) of
                   ok ->
  +                    logplex_stats:incr({drain_delivered, ID}),
                       post_buffer(tcp_good(State#state{buf=NewBuf}));
                   {error, Reason} ->
                       ?ERR("drain_id=~p channel_id=~p dest=~s at=post err=gen_tcp data=~p",
  
positive.code:             Msg = case Item of
                        {msg, M} -> M;
                        {loss_indication, N, When} ->
                            ?INFO("drain_id=~p channel_id=~p dest=~s at=loss"
                                  " dropped=~p since=~s",
                                  log_info(State, [N, logplex_syslog_utils:datetime(When)])),
  
negative.code:     {noreply, State}.
  
  %% @private
  handle_info({post, Msg}, State = #state{sock = undefined,
                                          id = Token,
                                          buf = Buf})
    when is_tuple(Msg) ->
      logplex_stats:incr({drain_buffered, Token}),
      NewBuf = logplex_drain_buffer:push(Msg, Buf),
      {noreply, State#state{buf=NewBuf}};
  
  