aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/gnunet/util/Service.java
diff options
context:
space:
mode:
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 }