SDIS1819-T6G05-P2

package chord;

import chord.ChordManager;

import chord.ConnectionInfo;

import messages.MessageForwarder;

import messages.PingMessage;

import peer.Peer;

import java.net.InetAddress;

public class CheckPredecessor implements Runnable{

    public static boolean dead;

    private int timeout;

    public CheckPredecessor(int timeout){

        this.timeout = timeout;

    }

    @Override

    public void run(){

        synchronized(this){

            if (ChordManager.predecessor != null) {

                try {

                    MessageForwarder.sendMessage(new PingMessage(new ConnectionInfo(null, InetAddress.getLocalHost().getHostAddress(), Peer.port), ChordManager.predecessor.getIp(), ChordManager.predecessor.getPort()));

                    this.wait(timeout);

                } catch (Exception e) {

                    e.printStackTrace();

                }

                if (dead) {

                    ChordManager.predecessor = null;

                }

            }

        }

    }

}