m-chrzan.xyz
aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/pl/edu/mimuw/cloudatlas/agent/modules')
-rw-r--r--src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/GossipGirlState.java2
-rw-r--r--src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/TimerScheduler.java2
2 files changed, 0 insertions, 4 deletions
diff --git a/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/GossipGirlState.java b/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/GossipGirlState.java
index 4709eb1..d5c404d 100644
--- a/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/GossipGirlState.java
+++ b/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/GossipGirlState.java
@@ -312,7 +312,6 @@ public class GossipGirlState {
}
break;
case WAIT_FOR_FIRST_INFO:
- // TODO: use offset to setup GTP
offset = message.getOffset();
setZonesToSend();
setQueriesToSend();
@@ -336,7 +335,6 @@ public class GossipGirlState {
public void gotQuery(QueryMessage message) {
switch (state) {
case WAIT_FOR_FIRST_INFO:
- // TODO: use offset to setup GTP
offset = message.getOffset();
setZonesToSend();
setQueriesToSend();
diff --git a/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/TimerScheduler.java b/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/TimerScheduler.java
index 68a9326..b9a68bd 100644
--- a/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/TimerScheduler.java
+++ b/src/main/java/pl/edu/mimuw/cloudatlas/agent/modules/TimerScheduler.java
@@ -13,7 +13,6 @@ import java.util.Timer;
* Handle used to attach tasks to schedule
* Tasks declared as inherited from TimerTask
*
- * TODO: add request id and custom time
*/
public class TimerScheduler extends Module {
private Timer timer;
@@ -37,7 +36,6 @@ public class TimerScheduler extends Module {
System.out.println("Task with delay " + msg.getDelay() + " scheduled");
}
- // TODO
public void removeTask(String requestId) {}
public void passMessageFromTask(AgentMessage msg) throws InterruptedException {