package alice.topology.manager.reconnection;

import java.io.IOException;
import java.net.Socket;
import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;
import alice.topology.HostMessage;

public class ReceiveError extends CodeSegment {
	public Receiver reportInfo = ids.create(CommandType.TAKE);
	
	public ReceiveError(){
		reportInfo.setKey("_ERROR");
	}
	
	@Override
	public void run() {		
		HostMessage message = reportInfo.asClass(HostMessage.class);
		try {
			System.out.println("Receive Error "+ message.port);
			Socket socket = new Socket(message.name, message.port);
			socket.close();
			System.out.println("alive "+message.port);
		} catch (IOException e) {
			System.out.println("Receive Error "+ message.port);
			new CheckABSName(message);
			return;
		}
		new ReceiveError();
	}

}