Use local Sone with the Sone inserters.
authorDavid ‘Bombe’ Roden <bombe@pterodactylus.net>
Wed, 3 Dec 2014 05:30:29 +0000 (06:30 +0100)
committerDavid ‘Bombe’ Roden <bombe@pterodactylus.net>
Wed, 3 Dec 2014 05:30:29 +0000 (06:30 +0100)
src/main/java/net/pterodactylus/sone/core/Core.java

index ba2b15c..2d23de3 100644 (file)
@@ -152,7 +152,7 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
 
        /** Sone inserters. */
        /* synchronize access on this on sones. */
-       private final Map<Sone, SoneInserter> soneInserters = new HashMap<Sone, SoneInserter>();
+       private final Map<LocalSone, SoneInserter> soneInserters = new HashMap<LocalSone, SoneInserter>();
 
        /** Sone rescuers. */
        /* synchronize access on this on sones. */
@@ -614,7 +614,7 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
                        return null;
                }
                logger.info(String.format("Adding Sone from OwnIdentity: %s", ownIdentity));
-               Sone sone = database.registerLocalSone(ownIdentity);
+               LocalSone sone = database.registerLocalSone(ownIdentity);
                SoneInserter soneInserter = new SoneInserter(this, eventBus, freenetInterface, ownIdentity.getId());
                eventBus.register(soneInserter);
                synchronized (soneInserters) {
@@ -1250,7 +1250,7 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
        public void serviceStop() {
                localElementTicker.shutdownNow();
                synchronized (soneInserters) {
-                       for (Entry<Sone, SoneInserter> soneInserter : soneInserters.entrySet()) {
+                       for (Entry<LocalSone, SoneInserter> soneInserter : soneInserters.entrySet()) {
                                soneInserter.getValue().stop();
                        }
                }