anchor.diff:      case queue:out(Q) of
           {empty, Q} ->
               logplex_drain_buffer:set_active(Buf, target_bytes(),
  -                                            framing_fun()),
  +                                            fun ?MODULE:drain_buf_framing/1),
               {next_state, connected, State};
           {{value, Frame}, Q2} ->
               try_send(Frame, State#state{out_q = Q2})
  
positive.code:         ]).
  
  -export([user_agent/0
          ]).
  
  %% ------------------------------------------------------------------
  
negative.code: frame(LogTuple) ->
      logplex_syslog_utils:frame(rfc5424(LogTuple)).
  
  drain_buf_framing({loss_indication, _N, _When}) ->
      skip;
  drain_buf_framing({msg, MData}) ->
      {frame, frame(MData)}.
  
  -spec target_bytes() -> pos_integer().
  %% @private
  