Mercurial > hg > Database > Alice
diff src/main/java/alice/daemon/MulticastConnection.java @ 419:aefbe41fcf12 dispose
change tab to space
author | sugi |
---|---|
date | Tue, 15 Jul 2014 16:00:22 +0900 |
parents | 60eee1fb0fd3 |
children | 2f2623484b77 |
line wrap: on
line diff
--- a/src/main/java/alice/daemon/MulticastConnection.java Tue Jul 15 06:15:53 2014 +0900 +++ b/src/main/java/alice/daemon/MulticastConnection.java Tue Jul 15 16:00:22 2014 +0900 @@ -9,45 +9,45 @@ import alice.datasegment.Command; public class MulticastConnection extends Connection { - private DatagramChannel dc; - private SocketAddress sAddr; + private DatagramChannel dc; + private SocketAddress sAddr; - public MulticastConnection(DatagramChannel d, SocketAddress s) { - dc = d; - sAddr = s; - } + public MulticastConnection(DatagramChannel d, SocketAddress s) { + dc = d; + sAddr = s; + } - // may need to add infomation who send on ds. - @Override - public synchronized void write(Command cmd){ - CommandMessage cmdMsg = cmd.convert(); - ByteBuffer buffer; - try { - buffer = ByteBuffer.wrap(SingletonMessage.getInstance().write(cmdMsg)); - while (buffer.hasRemaining()){ - dc.send(buffer, sAddr); - } - } catch (IOException e) { - e.printStackTrace(); - } + // may need to add infomation who send on ds. + @Override + public synchronized void write(Command cmd){ + CommandMessage cmdMsg = cmd.convert(); + ByteBuffer buffer; + try { + buffer = ByteBuffer.wrap(SingletonMessage.getInstance().write(cmdMsg)); + while (buffer.hasRemaining()){ + dc.send(buffer, sAddr); + } + } catch (IOException e) { + e.printStackTrace(); + } - } + } - @Override - public void close(){ - try { - dc.close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - - public void receive(ByteBuffer receiveData){ - try { - dc.receive(receiveData); - } catch (IOException e) { - e.printStackTrace(); - } - } + @Override + public void close(){ + try { + dc.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + + public void receive(ByteBuffer receiveData){ + try { + dc.receive(receiveData); + } catch (IOException e) { + e.printStackTrace(); + } + } }