package christie.daemon;

import christie.codegear.CodeGearManager;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class AcceptThread extends Thread {

    private ServerSocket ss;
    public int counter = 0;
    public CodeGearManager cgm;

    public AcceptThread(ServerSocket ss, String name, CodeGearManager cgm) {
        super(name);
        this.ss = ss;
        this.cgm = cgm;
    }

    @Override
    public void run() {
        while (true) {
            try {
                Socket socket = null;
                socket = ss.accept();
                socket.setTcpNoDelay(true);
                System.out.println("Accept " + socket.getInetAddress().getHostName() + ":" + socket.getPort());
                Connection connection = new Connection(socket, cgm);
                String key = "accept" + counter;
                IncomingTcpConnection in =
                        new IncomingTcpConnection(connection);
                in.setName(connection.getInfoString()+"-IncomingTcp");
                in.start();
                cgm.setAccept(key, in);
                OutboundTcpConnection out = new OutboundTcpConnection(connection);
                out.setName(connection.getInfoString()+"-OutboundTcp");
                out.start();
                counter++;
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}