package alice.daemon;

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

import alice.datasegment.DataSegment;

public class AcceptThread extends Thread {

	private ServerSocket ss;

	public AcceptThread(ServerSocket ss, String name) {
		super(name);
		this.ss = ss;
	}
	
	@Override
	public void run() {
		while (true) {
			try {
				Socket socket = ss.accept();
				Connection connection = new Connection(socket);
				new IncomingTcpConnection(connection, DataSegment.get("local")).start();
				new OutboundTcpConnection(connection).start();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

}