anchor.diff:      case checkout_worker(State) of
           retry_later ->
               Queue = State#tcp_state.froms,
  -            {noreply, State#tcp_state{froms = queue:in({From, Transaction}, Queue)}};
  +            Len = State#tcp_state.froms_len,
  +            {noreply, State#tcp_state{froms = queue:in({From, Transaction}, froms_len = Len + 1, Queue)}};
   
           {ok, Worker, NewState} ->
               Reply = Transaction(Worker),
  
positive.code: 
  checkin_worker(Worker, State) ->
      Froms = State#tcp_state.froms,
      case queue:out(Froms) of
          %% NOTE We have an ongoing transaction which has to be carried out...
          {{value, {From, Transaction}}, NewFroms} when is_function(Transaction, 1) ->
              %% FIXME This shouldn't run here as it may clog the entire connector up.
              %% NOTE This is currently unused as it is too slow.
              gen_server:reply(From, Transaction(Worker)),
              checkin_worker(Worker, State#tcp_state{froms = NewFroms});
  
          %% NOTE ...or an ongoing checkout request...
          {{value, {From, Timer}}, NewFroms} ->
              erlang:cancel_timer(Timer),
              gen_server:reply(From, {ok, Worker}),
              {ok, State#tcp_state{froms = NewFroms}};
  
          %% NOTE ...or we're good to go.
          {empty, Froms} ->
  
negative.code:           listener,
            pool_name,
            froms,
            froms_len,
            workers,
            workers_queue
           }).
  