diff options
author | Florian Dold <florian.dold@gmail.com> | 2013-10-08 21:22:43 +0000 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2013-10-08 21:22:43 +0000 |
commit | 5b4933f12a3eadedf84e6adf00e1c1ac15924f6d (patch) | |
tree | 5824cf1236dbdbca515cc7d1f5f7bce1ee3eba6b /src/main/java/org/gnunet/util/Service.java | |
parent | a8c1c65a00dce604ff829dfe10568cd06c8f8bda (diff) | |
download | gnunet-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.java | 3 |
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; | |||
30 | import java.net.SocketAddress; | 30 | import java.net.SocketAddress; |
31 | import java.nio.ByteBuffer; | 31 | import java.nio.ByteBuffer; |
32 | import java.nio.channels.Pipe; | 32 | import java.nio.channels.Pipe; |
33 | import java.nio.channels.SelectionKey; | ||
33 | import java.util.LinkedList; | 34 | import 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 | } |