sdis1819-t7g06

package Channel;

import Message.*;

import Peers.Peer;

import java.io.IOException;

import java.io.Serializable;

import java.net.*;

import java.util.concurrent.TimeUnit;

public class Channel implements Runnable, Serializable {

    Peer peer;

    MulticastSocket socket;

    int port;

    InetAddress address;

    public Channel(String address, int port, Peer peer) throws IOException {

        this.port = port;

        try {

            this.address = InetAddress.getByName(address);

            socket = new MulticastSocket(port); // sockets

            socket.joinGroup(this.address);

            socket.setTimeToLive(1);

            this.peer = peer;

        } catch (UnknownHostException e) {

        }

    }

    public void send(Message message) { //ou a mensagem e constrói aqui?

        try {

            byte[] mes = message.messagePacket();

            DatagramPacket data = new DatagramPacket(mes, mes.length, this.address, this.port);

            System.out.println("Sending " + message.getType().toString() + " Packet");

            socket.send(data);

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void run() {

        while (true) {

            try {

                byte[] buffer = new byte[65000];

                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

                socket.receive(packet);

                //lançar thread que trabalha a mensagem

                peer.getThreadPool().execute(new WorkMessage(packet, peer));

//                new Thread(new WorkMessage(packet, peer)).start();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

}