package alice.daemon;

import alice.datasegment.Command;

public class OutboundTcpConnection extends Thread {

    public Connection connection;

    public OutboundTcpConnection(Connection connection) {
        this.connection = connection;
    }

    /**
     * pipeline thread for transmission
     */
    public void run() {
        while (true) {
            try {
                Command cmd = connection.sendQueue.take();
                switch (cmd.type) {
                case CLOSE:
                    connection.close();
                    return;
                case FINISH:
                    System.exit(0);
                    return;
                default:
                    break;
                }
                connection.write(cmd);//ここでconvert()がよばれてる
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}