anchor.diff:         State#state.queue_overflow_suspend_period,
          get_queue_overflow_suspend_period(State)},
         {counters,
  -       [{?max_processes_reached, get(?max_processes_reached)},
  -        {?max_messages_reached, get(?max_messages_reached)}]},
  +       [{?request_input, get(?request_input)},
  +        {?cast_input, get(?cast_input)},
  +        {?max_processes_reached, get(?max_processes_reached)},
  +        {?max_messages_reached, get(?max_messages_reached)},
  +        {?suspend_sent, get(?suspend_sent)}]},
         {options, State#state.options}
        ],
        State};
  
positive.code: -spec handle_data_from_net(State :: #state{}, Data :: binary()) ->
                                    ok | stop.
  handle_data_from_net(State, ?PACKET_REQUEST(SeqNum, DeadLine, Request)) ->
      RequestRef = make_ref(),
      case register_request_from_network(State, SeqNum, RequestRef, DeadLine) of
          ok ->
  
negative.code:                    State#state.socket,
                     ?PACKET_FLOW_CONTROL_SUSPEND(Millis)) of
                  ok ->
                      increment_counter(?suspend_sent);
                  {error, _Reason} ->
                      stop
              end
  