view src/main/java/alice/daemon/AliceDaemon.java @ 641:646f705e65b1

setkey on remote
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 31 Dec 2017 01:08:52 +0900
parents 86b39f5bf1d7
children
line wrap: on
line source

package alice.daemon;

import java.io.FileWriter;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.nio.channels.ServerSocketChannel;

import org.apache.log4j.Logger;
//import org.apache.log4j.PatternLayout;
//import org.apache.log4j.WriterAppender;

public class AliceDaemon {

    private Config conf;
    private AcceptThread acceptThread;
    private Logger log = Logger.getLogger(AliceDaemon.class);

    public AliceDaemon(Config conf) {
        this.conf = conf;
        //setLogger();
    }

//    private void setLogger() {
//        Logger root = Logger.getRootLogger();
//        if (conf.level != null)
//            root.setLevel(conf.level);
//        if (conf.logFile == null)
//            return;
//        PatternLayout layout = new PatternLayout();
//        layout.setConversionPattern("%d %-5p %c - %m [%t] (%F:%L)%n");
//        try {
//            FileWriter writer = new FileWriter(conf.logFile);
//            WriterAppender writerAppender = new WriterAppender(layout, writer);
//            root.removeAllAppenders();
//            root.addAppender(writerAppender);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        log.info("configured");
//    }

    public void listen() {
        try {
            ServerSocketChannel ssChannel = ServerSocketChannel.open();
            ServerSocket ss = ssChannel.socket();
            ss.setReuseAddress(true);

            // listen on any address ipv4/ipv6
            InetSocketAddress a = new InetSocketAddress("::", conf.localPort);

            log.info("AliceDaemon.listen: bind to " + a);
            ss.bind(a);
            acceptThread = new AcceptThread(ss, "ACCEPT" + conf.localPort);
            acceptThread.start();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}