aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/gnunet/util/Service.java
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2013-10-08 21:22:43 +0000
committerFlorian Dold <florian.dold@gmail.com>2013-10-08 21:22:43 +0000
commit5b4933f12a3eadedf84e6adf00e1c1ac15924f6d (patch)
tree5824cf1236dbdbca515cc7d1f5f7bce1ee3eba6b /src/main/java/org/gnunet/util/Service.java
parenta8c1c65a00dce604ff829dfe10568cd06c8f8bda (diff)
downloadgnunet-java-5b4933f12a3eadedf84e6adf00e1c1ac15924f6d.tar.gz
gnunet-java-5b4933f12a3eadedf84e6adf00e1c1ac15924f6d.zip
- identity service implemented
- started with arm implementation - removed locking from scheduler - separated TaskConfiguration and TaskIdentifier - implemented proper message stream tokenizer - work on voting
Diffstat (limited to 'src/main/java/org/gnunet/util/Service.java')
-rw-r--r--src/main/java/org/gnunet/util/Service.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main/java/org/gnunet/util/Service.java b/src/main/java/org/gnunet/util/Service.java
index d93e296..a150089 100644
--- a/src/main/java/org/gnunet/util/Service.java
+++ b/src/main/java/org/gnunet/util/Service.java
@@ -30,6 +30,7 @@ import java.net.InetSocketAddress;
30import java.net.SocketAddress; 30import java.net.SocketAddress;
31import java.nio.ByteBuffer; 31import java.nio.ByteBuffer;
32import java.nio.channels.Pipe; 32import java.nio.channels.Pipe;
33import java.nio.channels.SelectionKey;
33import java.util.LinkedList; 34import java.util.LinkedList;
34 35
35/** 36/**
@@ -107,7 +108,7 @@ public abstract class Service extends Program {
107 108
108 Scheduler.TaskConfiguration t = new Scheduler.TaskConfiguration(RelativeTime.FOREVER, 109 Scheduler.TaskConfiguration t = new Scheduler.TaskConfiguration(RelativeTime.FOREVER,
109 new SigpipeTask()); 110 new SigpipeTask());
110 t.selectRead(p.getSource()); 111 t.addSelectEvent(p.getSource(), SelectionKey.OP_READ);
111 sigpipeTask = t.schedule(); 112 sigpipeTask = t.schedule();
112 sigpipeChannel = p.getSource(); 113 sigpipeChannel = p.getSource();
113 } 114 }