class Commit extends Entry {
private long seqnumtrans;
private Set<KeyValue> keyValueUpdateSet = null;
- private Set<KeyValue> liveValues = null;
public Commit(Slot slot, long _seqnumtrans, Set<KeyValue> _keyValueUpdateSet) {
seqnumtrans = _seqnumtrans;
keyValueUpdateSet = new HashSet<KeyValue>();
- liveValues = new HashSet<KeyValue>();
for (KeyValue kv : _keyValueUpdateSet) {
KeyValue kvCopy = kv.getCopy();
keyValueUpdateSet.add(kvCopy);
- liveValues.add(kvCopy);
}
}
return;
for (KeyValue kv1 : kvSet) {
- for (Iterator<KeyValue> i = liveValues.iterator(); i.hasNext();) {
+ for (Iterator<KeyValue> i = keyValueUpdateSet.iterator(); i.hasNext();) {
KeyValue kv2 = i.next();
if (kv1.getKey() == kv2.getKey()) {
- liveValues.remove(kv2);
+ keyValueUpdateSet.remove(kv2);
break;
}
}
}
- if (liveValues.size() == 0)
+ if (keyValueUpdateSet.size() == 0)
this.setDead();
}
}
\ No newline at end of file