diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/PersistentDataStore.java b/router/java/src/net/i2p/router/networkdb/kademlia/PersistentDataStore.java index df6a61237cefbfd419a4c41e6df319c2e4d7f8aa..6f89551e2f796a98ab9a28c15370fec22bbda622 100644 --- a/router/java/src/net/i2p/router/networkdb/kademlia/PersistentDataStore.java +++ b/router/java/src/net/i2p/router/networkdb/kademlia/PersistentDataStore.java @@ -193,9 +193,11 @@ class PersistentDataStore extends TransientDataStore { while (true) { // get a new iterator every time to get a random entry without // having concurrency issues or copying to a List or Array - Iterator<Hash> iter = _keys.keySet().iterator(); + Iterator<Map.Entry<Hash, DataStructure>> iter = _keys.entrySet().iterator(); try { - key = iter.next(); + Map.Entry<Hash, DataStructure> entry = iter.next(); + key = entry.getKey(); + data = entry.getValue(); iter.remove(); count++; } catch (NoSuchElementException nsee) { @@ -207,7 +209,6 @@ class PersistentDataStore extends TransientDataStore { } if (key != null) { - data = _keys.get(key); if (data != null) { write(key, data); data = null;