Mercurial > hg > RemoteEditor > REPSessionManager

annotate rep/FirstConnector.java @ 365:c432755c3555

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
distributed session debug continue... SELECT/SELECT_ACK loop
author kono
date Mon, 20 Oct 2008 17:00:42 +0900
parents c965ef2b5fd6
children 1bde894edd83
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
1 package rep;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
2
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
3 import java.io.IOException;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
4
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
5 import rep.channel.REPSelectionKey;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
6 import rep.channel.REPSocketChannel;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
7
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
8 public class FirstConnector extends Forwarder {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
9
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
10 public FirstConnector(SessionManager manager) {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
11 super(manager);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
12 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
13
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
14 public void cancel(REPSocketChannel<REPCommand> socketChannel) {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
15 manager.remove(socketChannel);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
16 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
17
358
034acadc0cdc *** empty log message ***
kono
parents: 355
diff changeset
18 public void handle(REPSelectionKey<REPCommand> key) throws IOException {
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
19 /*
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
20 * 接続要求は、EditorかSlave Editorで、
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
21 * 　　　join, put, sm_join
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
22 * が来る。それ以外はエラー。master もありか?
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
23 * sm_join_ack
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
24 */
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
25 Forwarder fw;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
26 REPSocketChannel<REPCommand> channel = key.channel1();
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
27 REPCommand command = channel.read();
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
28 SessionManager.logger.writeLog("FirstConnector: command = " + command);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
29 switch(command.cmd) {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
30 case SMCMD_JOIN:
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
31 {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
32 //どのSessionにも属さないエディタをリストに追加
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
33 //エディタとchannelは1対1 (ではないかも)
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
34 //エディタが新しくputする場合は新しくソケットを作る
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
35 // 1対1でない場合は、multiplexerを挿めば良い
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
36 Editor editor = manager.newEditor(channel);
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
37 editor.setHost(manager.myHost);
360
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
38 command.eid = editor.eid;
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
39 command.sid = -1;
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
40 editor.setSID(-1);
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
41 fw = editor;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
42 break;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
43 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
44 case SMCMD_PUT:
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
45 {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
46 // 新しいeditorとsessionをここで作る。eid,sidは、
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
47 // session manager IDが付いているので、global unique
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
48 Editor editor = manager.newEditor(channel);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
49 Session session = manager.newSession(editor);
360
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
50 session.setName(command.string);
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
51 editor.setName(command.string);
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
52 editor.setSID(session.getSID());
360
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
53 command.eid = editor.eid;
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
54 command.sid = editor.sid;
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
55 fw = editor;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
56 break;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
57 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
58 case SMCMD_SM_JOIN:
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
59 {
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
60 fw = new Forwarder(manager);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
61 manager.smList.addWaitingSessionManager(fw, command);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
62 break;
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
63 }
365
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
64 case SMCMD_SM_JOIN_ACK:
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
65 manager.setSessionManagerID(command.sid);
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
66 manager.afterConnect();
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
67 fw = new Forwarder(manager);
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
68 manager.setParent(fw);
c432755c3555 distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents: 364
diff changeset
69 break;
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
70 default: throw new IOException();
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
71 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
72 //myHost を設定。
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
73 //立ち上げ時にやるとlocalhostしか取れない
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
74 if(manager.myHost == null) manager.setMyHostName(getLocalHostName());
360
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
75 fw.setHost(manager.myHost);
355
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
76 fw.setMode(command.cmd);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
77 manager.registerChannel(channel, fw);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
78 manager.sessionManage(fw, command);
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
79
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
80 }
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
81
98607350f7d1 *** empty log message ***
kono
parents:
diff changeset
82 }