Mercurial > hg > Database > Alice
annotate src/alice/daemon/AliceDaemon.java @ 240:d9c9076d6b47
no use SEDA in IncomingTcpConnection
| author | sugi |
|---|---|
| date | Tue, 09 Apr 2013 11:26:17 +0900 |
| parents | d50cddf64396 |
| children | b90d03c6cb00 |
| rev | line source |
|---|---|
| 12 | 1 package alice.daemon; |
| 2 | |
| 39 | 3 import java.io.FileWriter; |
| 12 | 4 import java.io.IOException; |
| 182 | 5 import java.net.InetAddress; |
| 12 | 6 import java.net.InetSocketAddress; |
| 7 import java.net.ServerSocket; | |
| 8 import java.nio.channels.ServerSocketChannel; | |
| 9 | |
| 39 | 10 import org.apache.log4j.Logger; |
| 11 import org.apache.log4j.PatternLayout; | |
| 12 import org.apache.log4j.WriterAppender; | |
| 13 | |
| 12 | 14 public class AliceDaemon { |
| 15 | |
| 16 private Config conf; | |
| 17 private AcceptThread acceptThread; | |
| 39 | 18 private Logger log = Logger.getLogger(AliceDaemon.class); |
| 12 | 19 |
|
14
e3f1b21718b0
implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
12
diff
changeset
|
20 public AliceDaemon(Config conf) { |
|
e3f1b21718b0
implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
12
diff
changeset
|
21 this.conf = conf; |
| 39 | 22 setLogger(); |
| 23 } | |
| 24 | |
| 25 private void setLogger() { | |
| 26 Logger root = Logger.getRootLogger(); | |
| 27 if (conf.level != null) | |
| 28 root.setLevel(conf.level); | |
| 29 if (conf.logFile == null) | |
| 30 return; | |
| 31 PatternLayout layout = new PatternLayout(); | |
| 32 layout.setConversionPattern("%d %-5p %c - %m [%t] (%F:%L)%n"); | |
| 33 try { | |
| 34 FileWriter writer = new FileWriter(conf.logFile); | |
| 35 WriterAppender writerAppender = new WriterAppender(layout, writer); | |
| 36 root.removeAllAppenders(); | |
| 37 root.addAppender(writerAppender); | |
| 38 } catch (IOException e) { | |
| 39 e.printStackTrace(); | |
| 40 } | |
| 41 log.info("configurated"); | |
| 12 | 42 } |
| 43 | |
| 44 public void listen() { | |
| 45 try { | |
| 46 ServerSocketChannel ssChannel = ServerSocketChannel.open(); | |
| 47 ServerSocket ss = ssChannel.socket(); | |
| 48 ss.setReuseAddress(true); | |
| 63 | 49 |
| 182 | 50 //InetSocketAddress a = new InetSocketAddress("::", conf.localPort); |
| 51 InetSocketAddress a = new InetSocketAddress(InetAddress.getLocalHost(), conf.localPort); | |
| 52 //System.out.println(a); | |
| 173 | 53 ss.bind(a); |
|
22
2ca2d961a8d2
implements outline of TopologyManager
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
14
diff
changeset
|
54 acceptThread = new AcceptThread(ss, "ACCEPT" + conf.localPort); |
| 12 | 55 acceptThread.start(); |
| 56 } catch (IOException e) { | |
| 57 e.printStackTrace(); | |
| 58 } | |
| 59 | |
| 60 } | |
| 61 } |