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