anchor.diff:              ?INFO("drain_id=~p channel_id=~p dest=~s at=try_connect "
                     "attempt=success connect_time=~p",
                     log_info(State, [ltcy(ConnectStart, ConnectEnd)])),
  -            maybe_resize(Status, Buf),
               NewTimerState = start_close_timer(State),
               ready_to_send(NewTimerState#state{client=Pid, service=normal,
                                                 connect_time=ConnectEnd,
  
positive.code: 
  %% @private
  %% if we had failures, they should have been delivered with this frame
  sent_frame(#frame{msg_count=Count, loss_count=Lost}, State0=#state{drop_info=Drop}) ->
      State = State0#state{last_good_time=os:timestamp()},
      msg_stat(drain_delivered, Count, State),
      logplex_realtime:incr('drain.delivered', Count),
      case {Lost,Drop} of
  
negative.code: try_connect(State = #state{uri=Uri,
                             drain_id=DrainId,
                             channel_id=ChannelId,
                             client=undefined}) ->
      {Scheme, Host, Port} = connection_info(Uri),
      ConnectStart = os:timestamp(),
  