anchor.diff:          {undefined,_} ->
               T0 = os:timestamp(),
               Msg = frame(
  -                Token,
                   logplex_syslog_utils:overflow_msg(Lost,T0)
               ),
               {[Msg, Body0],Count0+1};
           {{T0,Dropped},_} ->
               Msg = frame(
  -                Token,
                   logplex_syslog_utils:overflow_msg(Dropped+Lost,T0)
               ),
               {[Msg, Body0],Count0+1}
  
positive.code:      set_reconnect_timer(NewState)}.
  
  %% @private
  ready_to_send(State = #state{buf = Buf, drain_tok=Token,
                               out_q = Q}) ->
      case queue:out(Q) of
          {empty, Q} ->
              logplex_drain_buffer:set_active(Buf, target_bytes(),
                                              framing_fun(Token)),
              {next_state, connected, State};
          {{value, Frame}, Q2} ->
              try_send(Frame, State#state{out_q = Q2})
  
negative.code:                                     full_host_iolist(URI),
                                      uri_ref(URI)).
  
  rfc5424({Facility, Severity, Time, Source, Process, Msg}) ->
      logplex_syslog_utils:rfc5424(Facility, Severity, Time, "host",
                                   Source, Process, undefined, Msg).
  
  frame(LogTuple) ->
      logplex_syslog_utils:frame(rfc5424(LogTuple)).
  
  framing_fun() ->
      fun ({loss_indication, _N, _When}) ->
              skip;
          ({msg, MData}) ->
              {frame, frame(MData)}
      end.
  
  -spec target_bytes() -> pos_integer().
  