anchor.diff:  %% @private
   init([ReqId,Bucket,Timeout,ClientType,ErrorTolerance,Client]) ->
       {ok, Ring} = riak_core_ring_manager:get_my_ring(),
  -    Bloom = bloom:sbf(10000000,ErrorTolerance),
  +    {ok, Bloom} = ebloom:new(10000000,ErrorTolerance,ReqId),
       StateData = #state{client=Client, client_type=ClientType, timeout=Timeout,
                          bloom=Bloom, req_id=ReqId, bucket=Bucket, ring=Ring},
       {ok,initialize,StateData,0}.
  
positive.code:     reduce_pls(StateData).
  
  waiting_kl({kl, Keys, Idx, ReqId},
             StateData0=#state{pls=PLS,vns=VNS0,wait_pls=WPL0,bloom=Bloom0,
                              req_id=ReqId,client=Client,timeout=Timeout,
                              bucket=Bucket,client_type=ClientType}) ->
      Bloom = process_keys(Keys,Bucket,ClientType,Bloom0,ReqId,Client),
      WPL = [{W_Idx,W_Node,W_PL} || {W_Idx,W_Node,W_PL} <- WPL0, W_Idx /= Idx],
      WNs = [W_Node || {W_Idx,W_Node,_W_PL} <- WPL0, W_Idx =:= Idx],
      Node = case WNs of
  
negative.code:         _ -> undefined
      end,
      VNS = sets:add_element({Idx,Node},VNS0),
      StateData = StateData0#state{wait_pls=WPL,vns=VNS},
      case PLS of
          [] ->
              case WPL of
  