import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;


public class Envoyer extends Thread {
	  Discussion discussion;
	  
	  Envoyer(Discussion discussion) {
	    this.discussion = discussion;
	    setDaemon(true);
	  }

	  public void run() {
	    try {
	      InetAddress adresse = discussion.adresse;
	      int port = discussion.port;
	      DatagramSocket socketEnvoi = new DatagramSocket();
	      DatagramPacket paquet;
	      byte[] tampon; 
	      String message;
	      BufferedReader entree = new BufferedReader
		(new InputStreamReader(System.in));
	      do
		{
	      System.out.print("Envoi VERS " + discussion.adresse.getCanonicalHostName()+" : ");
		  message = entree.readLine();
		  tampon = message.getBytes();
		  paquet = new DatagramPacket(tampon, tampon.length, adresse, port);
		  socketEnvoi.send(paquet);
		}
	      while(!message.equals("fin"));
	    }
	    catch(IOException exc) {}
	    
	    discussion.fini = true;
	    
	    synchronized(discussion) {
	      discussion.notify();
	    }
	  }
	}