anchor.diff:          empty ->
               {next_state, ready_to_send, State};
           not_empty ->
  -            PktSize = logplex_app:config(tcp_drain_target_bytes,
  -                                         ?TARGET_SEND_SIZE),
  +            PktSize = target_send_size(),
               {Data, N, NewBuf} =
                   buffer_to_pkts(Buf, PktSize, DrainTok),
               Ref = erlang:start_timer(?SEND_TIMEOUT, self(), ?SEND_TIMEOUT_MSG),
  
positive.code: 
  -export([start_link/5
           ,resize_msg_buffer/2
          ]).
  
  -export([valid_uri/1
  
negative.code:     {next_state, StateName, State}.
  
  %% @private
  handle_sync_event({set_target_send_size, Size}, _From, StateName,
                    State = #state{})
    when is_integer(Size), Size > 0 ->
      put(target_send_size, Size),
      {reply, {ok, Size}, StateName, State};
  handle_sync_event({resize_msg_buffer, NewSize}, _From, StateName,
                    State = #state{buf = Buf})
    when is_integer(NewSize), NewSize > 0 ->
  