Mercurial > hg > Database > Alice

annotate src/alice/daemon/AcceptThread.java @ 30:b5a21baf0b07

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
implements RingTopology
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 17 Jan 2012 16:13:03 +0900
parents 98ab26e09a98
children 498d1d2524d3
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
1 package alice.daemon;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
2
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
3 import java.io.IOException;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
4 import java.net.ServerSocket;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
5 import java.net.Socket;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
6
16
433e601a8e28 network bug fix
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
7 import org.apache.log4j.Logger;
433e601a8e28 network bug fix
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
8
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
9 import alice.datasegment.DataSegment;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
10
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
11 public class AcceptThread extends Thread {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
13 private ServerSocket ss;
16
433e601a8e28 network bug fix
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
14 private Logger log = Logger.getLogger(AcceptThread.class);
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
15 public int counter = 0;
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
16
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
17 public AcceptThread(ServerSocket ss, String name) {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
18 super(name);
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
19 this.ss = ss;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
20 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
21
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
22 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
23 public void run() {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
24 while (true) {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
25 try {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
26 Socket socket = ss.accept();
16
433e601a8e28 network bug fix
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
27 log.info("Accept " + socket.getInetAddress().getHostName() + ":" + socket.getPort());
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
28 Connection connection = new Connection(socket);
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
29 String key = "accept" + counter;
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
30 IncomingTcpConnection incoming =
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
31 new IncomingTcpConnection(connection, DataSegment.get("local"), key);
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
32 incoming.start();
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
33 DataSegment.setAccept(key, incoming);
13
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
34 new OutboundTcpConnection(connection).start();
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
35 counter++;
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
36 } catch (IOException e) {
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
37 e.printStackTrace();
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
38 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
39 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
40 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
41
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
42 }