anchor.diff:  %% @private
   handle_info({'EXIT', Pid, normal}, _StateName, #state{client=Pid}=StateData) ->
       {stop,normal,StateData};
  +handle_info({_ReqId, {ok, _Pid}}, StateName, StateData=#state{timeout=Timeout}) ->
  +    %% Received a message from a key lister node that 
  +    %% did not start up within the timeout. Just ignore
  +    %% the message and move on.
  +    {next_state, StateName, StateData, Timeout};
   handle_info(_Info, _StateName, StateData) ->
       {stop,badmsg,StateData}.
   
  
positive.code:     NewPLS = lists:append(PLS, [W_PL || {_W_Idx,_W_Node,W_PL} <- WPL]),
      reduce_pls(StateData#state{pls=NewPLS,wait_pls=[]}).
  
  finish(StateData=#state{req_id=ReqId,client=Client,client_type=ClientType}) ->
      case ClientType of
          mapred -> luke_flow:finish_inputs(Client);
          plain -> Client ! {ReqId, done}
      end,
      {stop,normal,StateData}.
  
  
negative.code:                                lists:zip(lists:seq(0,(length(PLS0)-1)), PLS0)),
      {_, PLS} = lists:unzip(LA1 ++ LA2),
      Simul_PLS = trunc(length(PLS) / N),
      Listers = start_listers(ReqId, Input, Timeout),
      StateData = StateData0#state{pls=PLS,simul_pls=Simul_PLS, listers=Listers,
                                   wait_pls=[],vns=sets:from_list([])},
      %% Make sure there are actually some nodes available
      %% to perform the key listing operations.
      case Listers of 
          [] ->
              %% No nodes are currently available so return
              %% an error back to the requesting party.
              finish(StateData);
          _ ->
              reduce_pls(StateData)
      end.
  
  waiting_kl({ReqId, {kl, _Idx, Keys}},
             StateData=#state{bloom=Bloom,
  