OLD:
 @Override
    public Iterator<Tuple<NodeId>> find(NodeId... ids)
    {
        Tuple<NodeId> tuple = Tuple.create(ids) ;
        startRead() ;
        try {
            return find(tuple) ; // **public call
        } finally { finishRead() ; }
    }


SHOULD BE:

  @Override
    public Iterator<Tuple<NodeId>> find(NodeId... ids)
    {
        Tuple<NodeId> tuple = Tuple.create(ids) ;
        try {
            startRead() ;
            return find(tuple) ; // **public call
        } finally { finishRead() ; }
    }


Lines 151 to 159.
Rational the startRead can increment the counter in the policy and then throw a concurrent modification exception, this needs to be matched in that case by the finishRead()

Jeremy

Reply via email to