anchor.diff:  -behaviour(gen_fsm).
   -define(SERVER, ?MODULE).
   -define(RECONNECT_MSG, reconnect).
  +-define(TARGET_SEND_SIZE, 4096).
   
   -include("logplex.hrl").
   -include("logplex_logging.hrl").
  
positive.code: %%     gproc:munreg(p, l, [{channel, ChannelId},
  %%                         drain_dest,
  %%                         drain_type]).
  
negative.code:     io_lib:format("~f", [US / 1000000]).
  
  
  %% @private
  %% @doc Send buffered messages.
  send(State = #state{sock = Sock}) ->
      {Data, NewState} = buffer_to_pkts(State),
      erlang:port_command(Sock, Data),
      {next_state, sending, NewState}.
  
  %% -spec buffer_status(#state{}) -> 'empty' | 'has_messages_to_send'.
  %% %% @private
  