|
92
|
1 package fdl.test.debug2;
|
|
|
2
|
|
|
3 import java.io.IOException;
|
|
|
4
|
|
|
5 import fdl.FDLindaServ;
|
|
|
6 import fdl.MetaLinda;
|
|
|
7 import fdl.MetaEngine;
|
|
|
8
|
|
|
9 /**
|
|
|
10 * FDLindaNode
|
|
|
11 *
|
|
|
12 * @author Kazuki Akamine
|
|
|
13 *
|
|
|
14 * Federated Linda の Topology Node
|
|
|
15 * 接続する機能までを実装 MetaEngine は外部から提供される
|
|
|
16 *
|
|
|
17 */
|
|
|
18
|
|
|
19 public class FDLindaNode extends FDLindaServ {
|
|
|
20 // Fields
|
|
|
21 private MetaLinda ml;
|
|
|
22 public static final int DEFAULTPORT = 10000;
|
|
|
23 private static String manager;
|
|
|
24 private final static String usageString
|
|
|
25 = "Usage: FDLindaNode -manager SERVERNAME:PORT";
|
|
|
26
|
|
|
27 // Constructor
|
|
|
28 public FDLindaNode(int port) throws IOException {
|
|
|
29 super(port);
|
|
|
30 this.ml = new MetaLinda(tupleSpace, this);
|
|
|
31 }
|
|
|
32
|
|
|
33 @Override public void mainLoop() {
|
|
97
|
34 me.mainLoop(ml);
|
|
92
|
35 }
|
|
|
36 public void setMetaEngine(MetaEngine me) {
|
|
|
37 this.me = me;
|
|
|
38 }
|
|
|
39 public MetaLinda getMetaLinda() {
|
|
|
40 return ml;
|
|
|
41 }
|
|
|
42
|
|
|
43 // main routine
|
|
|
44 public static void main(String[] args) {
|
|
|
45 int port = DEFAULTPORT;
|
|
|
46 for (int i = 0; i < args.length; i++) {
|
|
|
47 if ("-manager".equals(args[i])) {
|
|
|
48 manager = args[++i];
|
|
|
49 } else if ("-p".equals(args[i])) {
|
|
|
50 port = new Integer(args[++i]).intValue();
|
|
|
51 } else {
|
|
|
52 System.err.println(usageString);
|
|
|
53 }
|
|
|
54 }
|
|
|
55
|
|
|
56 String[] managerData = manager.split(":");
|
|
|
57 String managerHostName = managerData[0];
|
|
|
58 int managerPort;
|
|
|
59 if (managerData.length > 1) {
|
|
|
60 managerPort = new Integer(managerData[1]).intValue();
|
|
|
61 } else {
|
|
|
62 managerPort = DEFAULTPORT;
|
|
|
63 }
|
|
|
64
|
|
|
65 try {
|
|
|
66 FDLindaNode node = new FDLindaNode(DEFAULTPORT);
|
|
|
67 MetaEngine me = new MetaProtocolEngine(port, node.getMetaLinda(), managerHostName, managerPort);
|
|
|
68 node.setMetaEngine(me);
|
|
|
69 node.mainLoop();
|
|
|
70 } catch (IOException e) {
|
|
|
71 e.printStackTrace();
|
|
|
72 }
|
|
|
73 }
|
|
|
74
|
|
|
75 }
|
