From 987663481e99dcaa9a53e9d65243a359e892c991 Mon Sep 17 00:00:00 2001 From: mic Date: Fri, 22 Feb 2013 16:05:21 +0100 Subject: [PATCH] periodical lookup --- .../src/main/java/net/blogracy/WebServer.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/blogracy-web/src/main/java/net/blogracy/WebServer.java b/blogracy-web/src/main/java/net/blogracy/WebServer.java index 41647e8..1f25c7d 100644 --- a/blogracy-web/src/main/java/net/blogracy/WebServer.java +++ b/blogracy-web/src/main/java/net/blogracy/WebServer.java @@ -1,6 +1,7 @@ package net.blogracy; import net.blogracy.model.users.User; +import net.blogracy.controller.DistributedHashTable; import net.blogracy.controller.FileSharing; import net.blogracy.config.Configurations; import java.util.List; @@ -28,12 +29,17 @@ public static void main(String[] args) throws Exception int TOTAL_WAIT = 5 * 60 * 1000; // 5 minutes while (true) { - List friends = Configurations.getUserConfig().getFriends(); - int wait = TOTAL_WAIT / friends.size(); - for (User friend : friends) { - FileSharing.getFeed(friend.getHash().toString()); - Thread.currentThread().sleep(wait); - } + FileSharing sharing = FileSharing.getSingleton(); + String id = Configurations.getUserConfig().getUser().getHash().toString(); + sharing.addFeedEntry(id, "" + new java.util.Date(), null); + + List friends = Configurations.getUserConfig().getFriends(); + int wait = TOTAL_WAIT / friends.size(); + for (User friend : friends) { + DistributedHashTable.getSingleton().lookup(friend.getHash().toString()); + FileSharing.getFeed(friend.getHash().toString()); + Thread.currentThread().sleep(wait); + } } } }