anchor.diff:      %% Terminate message to Count instance managers
       TerminateFunc = fun() -> 
           %% Get a pid and send a terminate request to it
  -        Pid = pg2:get_closest_pid(request_pool),
  +        Pid = pg2_ext:get_next_pid(request_pool),
           Pid ! terminate,
           %% Remove this instance manager from the pool
  -        pg2:leave(request_pool, Pid)
  +        pg2_ext:leave(request_pool, Pid)
       end,
       [TerminateFunc || _ <- lists:seq(1, Count)]. 
   
  
positive.code: 			Requester ! {self(), Result},
              instance_manager_loop(RackPid, {busy, []}, WaitThreshold, _RubyCmd, {RequestCount+1, _MaxRequests});
  		terminate -> 
              pg2:get_closest_pid(request_pool) ! terminate,
  			instance_manager_loop(RackPid, {clogged, []}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests})
      end;
  instance_manager_loop(RackPid, {clogged, [_TimerRef | QueuedRequests]}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests}) ->
      %% Send all requests queued in RequestList to be handled
      %% by the backup request pool of ruby instances.
      [pg2:get_closest_pid(request_pool) ! QueuedRequestData || QueuedRequestData <- lists:reverse(QueuedRequests)],
  
      receive
  		{Requester, {request, Req}} -> 
              pg2:get_closest_pid(request_pool) ! {Requester, {request, Req}},
  			instance_manager_loop(RackPid, {clogged, []}, WaitThreshold, _RubyCmd, {RequestCount, _MaxRequests});
  		{RackPid, Requester, Result} -> 
              %% Received response from current request.
  
negative.code:     RequestPoolSize = list_to_integer(proplists:get_value("request_pool_size", SConf#sconf.opaque, 10)),
  
  	%% Create a process group for the request pool
  	pg2_ext:create(request_pool),
  
      %% Spawn process to add instance managers for ruby instances
      spawn(?MODULE, add_instance_managers, [RequestPoolSize, SConf]),
  