import java.io.*;

import java.net.*;

 

public class aggiornaCoordinatore extends Thread

{

  private String nome_coordinatore=new String();

  final int Porta_com=1188;

  private String lista_file[]=new String[60];

 

  public aggiornaCoordinatore(String s,String[] ls)

  {

    nome_coordinatore=s;

    lista_file=ls;

  }

 

  public void run()

  {

     String messaggio=new String();

     try

     {

       System.out.println("aggiornamento partito");

       Socket sock_com=new Socket(nome_coordinatore,Porta_com);

       ObjectInputStream ois=new ObjectInputStream(sock_com.getInputStream());

       ObjectOutputStream oos=new ObjectOutputStream(sock_com.getOutputStream());

       oos.writeObject("aggiornamento");

       oos.flush();

       oos.writeObject(lista_file);

       oos.flush();

       messaggio=(String)ois.readObject();

      ///System.out.println(messaggio);

       oos.close();

       ois.close();

       sock_com.close();

       System.out.println("aggiornamento terminato"); 

     }

    catch(Exception e)

     {

       System.out.println("impossibile aggiornare il coordinatore");

     }

  }

 

}