diff options
Diffstat (limited to 'src/main/java/derms/net/runicast')
| -rw-r--r-- | src/main/java/derms/net/runicast/Connection.java | 12 |
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); |