anchor.diff:      QOSP = proplists:get_value(queue_overflow_suspend_period, Options),
       %% initialize gauge for spawned cast workers
       undefined = put(?async_workers, 0),
  +    %% initialize internal counters
  +    undefined = put(?max_processes_reached, 0),
  +    undefined = put(?max_messages_reached, 0),
       {ok,
        #state{socket = Socket,
               ready = false, %% will wait for 'ready' signal
  
positive.code: 
  %% gauge for spawned workers for cast requests
  -define(async_workers, async_workers).
  
  %% ----------------------------------------------------------------------
  %% Erlang interface definitions
  
negative.code:                   ok
            end),
      _MonRef = monitor(process, Pid),
      increment_counter(?async_workers).
  
  %% @doc Lookup SeqNum by RequestRef and remove it from the
  %% registry.
  