*/
public void addSone(Sone sone) {
if (localSones.add(sone)) {
- SoneInserter soneInserter = new SoneInserter(sone);
+ SoneInserter soneInserter = new SoneInserter(freenetInterface, sone);
soneInserter.start();
soneInserters.put(sone, soneInserter);
}
try {
logger.log(Level.FINEST, "Creating new Sone “%s” at %s (%s)…", new Object[] { name, finalRequestUri, finalInsertUri });
sone = new Sone(UUID.randomUUID(), name, new FreenetURI(finalRequestUri), new FreenetURI(finalInsertUri));
+ /* set modification counter to 1 so it is inserted immediately. */
+ sone.setModificationCounter(1);
addSone(sone);
} catch (MalformedURLException mue1) {
throw new SoneException(Type.INVALID_URI);
*/
@Override
protected void serviceStop() {
+ /* stop all Sone inserters. */
+ for (SoneInserter soneInserter : soneInserters.values()) {
+ soneInserter.stop();
+ }
saveConfiguration();
}
String id = configuration.getStringValue("Sone/Name." + soneName + "/ID").getValue(null);
String insertUri = configuration.getStringValue("Sone/Name." + soneName + "/InsertURI").getValue(null);
String requestUri = configuration.getStringValue("Sone/Name." + soneName + "/RequestURI").getValue(null);
+ long modificationCounter = configuration.getLongValue("Sone/Name." + soneName + "/ModificationCounter").getValue((long) 0);
try {
- addSone(new Sone(UUID.fromString(id), soneName, new FreenetURI(requestUri), new FreenetURI(insertUri)));
+ Sone sone = new Sone(UUID.fromString(id), soneName, new FreenetURI(requestUri), new FreenetURI(insertUri));
+ sone.setModificationCounter(modificationCounter);
+ addSone(sone);
} catch (MalformedURLException mue1) {
logger.log(Level.WARNING, "Could not create Sone from requestUri (“" + requestUri + "”) and insertUri (“" + insertUri + "”)!", mue1);
}
configuration.getStringValue("Sone/Name." + sone.getName() + "/ID").setValue(sone.getId());
configuration.getStringValue("Sone/Name." + sone.getName() + "/RequestURI").setValue(sone.getRequestUri().toString());
configuration.getStringValue("Sone/Name." + sone.getName() + "/InsertURI").setValue(sone.getInsertUri().toString());
+ configuration.getLongValue("Sone/Name." + sone.getName() + "/ModificationCounter").setValue(sone.getModificationCounter());
}
} catch (ConfigurationException ce1) {
logger.log(Level.WARNING, "Could not store configuration!", ce1);