summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/runicast
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net/runicast')
-rw-r--r--src/main/java/derms/net/runicast/Connection.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/main/java/derms/net/runicast/Connection.java b/src/main/java/derms/net/runicast/Connection.java
index 534112a..4824c2a 100644
--- a/src/main/java/derms/net/runicast/Connection.java
+++ b/src/main/java/derms/net/runicast/Connection.java
@@ -71,12 +71,6 @@ public class Connection implements Runnable {
pool.execute(this);
}
- void sendCtl(Type type, int id, int ack) throws IOException {
- ControlMessage msg = new ControlMessage(type, id, ack);
- DatagramPacket pkt = Packet.encode(msg, raddr, rport);
- sock.send(pkt);
- }
-
@Override
public void run() {
for (;;) {
@@ -139,6 +133,12 @@ public class Connection implements Runnable {
}
}
+ private void sendCtl(Type type, int id, int ack) throws IOException {
+ ControlMessage msg = new ControlMessage(type, id, ack);
+ DatagramPacket pkt = Packet.encode(msg, raddr, rport);
+ sock.send(pkt);
+ }
+
private ControlMessage recvCtl(Duration timeout) throws IOException, SocketTimeoutException, ClassNotFoundException {
DatagramPacket pkt = new DatagramPacket(new byte[bufSize], bufSize);
sock.setSoTimeout(timeout);