package alice.daemon;

import java.io.IOException;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;

import alice.datasegment.Command;

public class MulticastConnection extends Connection {
    private DatagramChannel dc;
    private SocketAddress sAddr;

    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){
        ByteBuffer buffer = cmd.convert();
        try {
            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();
        }
    }

}