|
0
|
1 package rep;
|
|
|
2
|
|
|
3 import java.io.IOException;
|
|
|
4 import java.net.InetSocketAddress;
|
|
11
|
5 import java.net.SocketAddress;
|
|
2
|
6 import java.nio.channels.SelectableChannel;
|
|
0
|
7 import java.nio.channels.SelectionKey;
|
|
|
8 import java.nio.channels.Selector;
|
|
|
9 import java.nio.channels.ServerSocketChannel;
|
|
|
10 import java.nio.channels.SocketChannel;
|
|
15
|
11 import java.util.StringTokenizer;
|
|
0
|
12
|
|
1
|
13 //+-------+--------+--------+-------+--------+---------+------+
|
|
|
14 //| cmd | session| editor | seqid | lineno | textsiz | text |
|
|
|
15 //| | id | id | | | | |
|
|
|
16 //+-------+--------+--------+-------+--------+---------+------+
|
|
|
17 //o-------header section (network order)-------------o
|
|
|
18 /*int cmd; // command
|
|
|
19 int sid; // session ID
|
|
|
20 int eid; // editor ID
|
|
|
21 int seqno; // Sequence number
|
|
|
22 int lineno; // line number
|
|
|
23 int textsize; // textsize
|
|
|
24 byte[] text;*/
|
|
|
25
|
|
8
|
26 public class SessionManager implements ConnectionListener, REPActionListener{
|
|
0
|
27
|
|
|
28
|
|
|
29 private SessionList sessionlist;
|
|
5
|
30 //SocketChannel sessionchannel;
|
|
2
|
31 private SessionManagerGUI sessionmanagerGUI;
|
|
|
32 private Selector selector;
|
|
7
|
33 private SessionManagerList smList;
|
|
17
|
34 private String myHost;
|
|
21
|
35 private boolean isMaster = true;
|
|
23
|
36 private EditorList editorList;
|
|
6
|
37 //private SocketChannel sessionchannel;
|
|
7
|
38 //private boolean co;
|
|
2
|
39 public SessionManager(int port) {
|
|
|
40 sessionmanagerGUI = new SessionManagerGUI();
|
|
|
41 }
|
|
|
42
|
|
|
43 public void openSelector() throws IOException{
|
|
|
44 selector = Selector.open();
|
|
|
45 }
|
|
0
|
46
|
|
|
47 public void sessionManagerNet(int port) throws InterruptedException, IOException {
|
|
|
48 /**
|
|
|
49 * @param args
|
|
|
50 * @throws IOException
|
|
|
51 * @throws InterruptedException
|
|
|
52 * @throws IOException
|
|
|
53 * @throws InterruptedException
|
|
|
54 */
|
|
2
|
55 System.out.println("sessionManagerNet()");
|
|
|
56
|
|
0
|
57 ServerSocketChannel ssc = ServerSocketChannel.open();
|
|
9
|
58 ssc.configureBlocking(false); //should be true
|
|
0
|
59 ssc.socket().bind(new InetSocketAddress(port));
|
|
|
60 ssc.register(selector, SelectionKey.OP_ACCEPT);
|
|
6
|
61
|
|
|
62
|
|
0
|
63 sessionlist = new SessionList();
|
|
7
|
64 smList = new SessionManagerList();
|
|
23
|
65 editorList = new EditorList();
|
|
0
|
66
|
|
|
67 while(true){
|
|
|
68 selector.select();
|
|
|
69 for(SelectionKey key : selector.selectedKeys()){
|
|
|
70 if(key.isAcceptable()){
|
|
28
|
71 /*** serverChannelはenableになったSelectionKeyのchannel ***/
|
|
|
72 ServerSocketChannel serverChannel = (ServerSocketChannel)key.channel();
|
|
9
|
73 /*** EditorChannel を用いない記述 ***/
|
|
28
|
74 SocketChannel channel = serverChannel.accept(); //keyからchannelを取って、accept
|
|
2
|
75 registerChannel (selector, channel, SelectionKey.OP_READ);
|
|
0
|
76 channel = null;
|
|
9
|
77
|
|
|
78 /*** EditorChannel を用いた記述 ****/
|
|
|
79 //EditorChannel echannel = (EditorChannel) ssc.accept();
|
|
|
80 //echannel.setIO();
|
|
|
81 //registerChannel(selector, echannel, SelectionKey.OP_READ);
|
|
|
82 //echannel = null;
|
|
|
83
|
|
|
84 /*** SelectableEditorChannel ***/
|
|
|
85 //SocketChannel channel = ssc.accept();
|
|
|
86 //SelectableEditorChannel echannel2 = new SelectableEditorChannel(channel);
|
|
|
87 //registerChannel(selector, echannel2, SelectionKey.OP_READ);
|
|
|
88 //channel = null;
|
|
|
89 //echannel2 = null;
|
|
|
90
|
|
6
|
91 }else if(key.isReadable()){
|
|
9
|
92
|
|
|
93 /*** EditorChannel を用いない記述 ***/
|
|
0
|
94 SocketChannel channel = (SocketChannel)key.channel();
|
|
9
|
95 REPPacketReceive repRec = new REPPacketReceive(channel); //getPacket(), putPacket() にする。
|
|
28
|
96 repRec.setkey(key);
|
|
0
|
97 REPCommand repCom = repRec.unpack();
|
|
|
98 manager(channel, repCom);
|
|
9
|
99
|
|
|
100 /*** EditorChannel を用いた記述 ****/
|
|
|
101 //EditorChannel echannel = (EditorChannel) key.channel();
|
|
|
102 //REPCommand command = echannel.getPacket();
|
|
|
103 //manager(echannel, command);
|
|
|
104
|
|
6
|
105 }else if(key.isConnectable()){
|
|
|
106 System.out.println("Connectable");
|
|
21
|
107 }
|
|
0
|
108 }
|
|
|
109 }
|
|
|
110 }
|
|
1
|
111
|
|
2
|
112 private synchronized void registerChannel(Selector selector, SelectableChannel channel, int ops) throws IOException {
|
|
|
113 if(channel == null) {
|
|
|
114 return;
|
|
|
115 }
|
|
9
|
116 //System.out.println("registerChannel()");
|
|
2
|
117 channel.configureBlocking(false);
|
|
6
|
118 selector.wakeup();
|
|
2
|
119 channel.register(selector, ops);
|
|
|
120 }
|
|
|
121
|
|
0
|
122 private void manager(SocketChannel channel, REPCommand repCmd) {
|
|
|
123 if(repCmd == null) return;
|
|
|
124 switch(repCmd.cmd){
|
|
|
125 case REP.SMCMD_JOIN:
|
|
21
|
126 if(isMaster){
|
|
23
|
127 int eid = editorList.addEditor(channel, repCmd);
|
|
|
128 repCmd.setEID(eid);
|
|
|
129 editorList.sendJoinAck(channel, repCmd);
|
|
26
|
130 sessionmanagerGUI.setComboEditor(eid, channel);
|
|
21
|
131 }else{
|
|
23
|
132 editorList.addEditor(channel);
|
|
22
|
133 smList.sendJoin(repCmd);
|
|
30
|
134 //sessionmanagerGUI.setComboEditor(repCmd.eid, channel);
|
|
21
|
135 }
|
|
31
|
136
|
|
|
137 /*** 各エディタのテスト用 ***/
|
|
|
138 repCmd.setCMD(REP.SMCMD_JOIN_ACK);
|
|
|
139 REPPacketSend sendJoinAckTest = new REPPacketSend(channel);
|
|
|
140 sendJoinAckTest.send(repCmd);
|
|
|
141
|
|
0
|
142 break;
|
|
1
|
143 case REP.SMCMD_JOIN_ACK:
|
|
31
|
144 // editorList.setEID(repCmd);
|
|
|
145 // editorList.sendJoinAck(repCmd);
|
|
|
146 // sessionmanagerGUI.setComboEditor(repCmd.eid, channel);
|
|
1
|
147 break;
|
|
31
|
148
|
|
0
|
149 case REP.SMCMD_PUT:
|
|
31
|
150 if(repCmd.string.length() == 0){
|
|
|
151 sessionlist.addEditor(channel, 0, 0);
|
|
|
152 }else if(repCmd.string.length() > 0){
|
|
|
153 int sid = sessionlist.addSession(channel, repCmd.string);
|
|
|
154 sessionlist.addEditor(channel, sid, 0);
|
|
|
155 }
|
|
|
156
|
|
|
157 /*** 各エディタのテスト用 ***/
|
|
|
158 repCmd.setCMD(REP.SMCMD_PUT_ACK);
|
|
|
159 REPPacketSend sendPutAckTest = new REPPacketSend(channel);
|
|
|
160 sendPutAckTest.send(repCmd);
|
|
|
161
|
|
1
|
162 break;
|
|
9
|
163 // case REP.SMCMD_PUT_ACK:
|
|
|
164 // break;
|
|
31
|
165
|
|
0
|
166 case REP.SMCMD_SELECT:
|
|
8
|
167 sessionlist.addEditor(channel, repCmd.sid, repCmd); //sessionlistへ追加
|
|
0
|
168 repCmd.setCMD(repCmd.cmd + 1);
|
|
|
169 REPPacketSend repSend3 = new REPPacketSend(channel);
|
|
9
|
170 repSend3.send(repCmd); //ACKを返す
|
|
8
|
171 break;
|
|
|
172 case REP.SMCMD_SELECT_ACK:
|
|
|
173 break;
|
|
1
|
174 case REP.SMCMD_SESSION:
|
|
|
175 break;
|
|
8
|
176 case REP.SMCMD_SM_JOIN:
|
|
31
|
177 //this.isMaster = true;
|
|
|
178 //myHost = repCmd.host;
|
|
|
179 if(isMaster){
|
|
|
180 //REPPacketSend send = new REPPacketSend(channel);
|
|
|
181 repCmd.setCMD(REP.SMCMD_SM_JOIN_ACK);
|
|
|
182 smList.sendSessionList(sessionlist, repCmd);
|
|
|
183 }
|
|
21
|
184 sendSessionManagerJoinAck(channel, repCmd);
|
|
8
|
185 break;
|
|
|
186 case REP.SMCMD_SM_JOIN_ACK:
|
|
21
|
187 this.isMaster = false;
|
|
18
|
188 myHost = repCmd.host;
|
|
24
|
189 //smList.add(channel); //SessionManagerのリストへ追加
|
|
6
|
190 break;
|
|
8
|
191 case REP.SMCMD_UPDATE:
|
|
9
|
192 int sessionID2 = sessionlist.addSession(channel, repCmd.string); //Sessionを作成
|
|
|
193 sessionlist.addEditor(channel, sessionID2, repCmd);
|
|
|
194 sessionmanagerGUI.setComboSession(sessionID2, repCmd.string); //ComboBoxにSessionを追加
|
|
|
195 break;
|
|
|
196 case REP.SMCMD_UPDATE_ACK:
|
|
1
|
197 break;
|
|
3
|
198 case REP.REPCMD_READ:
|
|
17
|
199 //sessionlist.sendCmd(channel, repCmd);
|
|
3
|
200 break;
|
|
0
|
201 default:
|
|
9
|
202 //sessionlist.sendCmd(channel, repCmd);
|
|
|
203 sessionlist.sendToNextEditor(channel, repCmd);
|
|
0
|
204 break;
|
|
|
205
|
|
|
206 }
|
|
|
207 }
|
|
|
208
|
|
22
|
209 // private void sendJoin(REPCommand repCmd) {
|
|
|
210 // smList.sendJoin(repCmd);
|
|
|
211 // }
|
|
21
|
212
|
|
|
213 private void sendSessionManagerJoinAck(SocketChannel channel, REPCommand repCmd) {
|
|
16
|
214 String socketstring = getSocketString(channel);
|
|
|
215 System.out.println(socketstring);
|
|
12
|
216 smList.add(channel); //SessionManagerのリストへ追加
|
|
|
217 repCmd.setCMD(REP.SMCMD_SM_JOIN_ACK);
|
|
16
|
218 repCmd.setString(repCmd.string + ":" + socketstring);
|
|
12
|
219 REPPacketSend repSend4 = new REPPacketSend(channel);
|
|
|
220 repSend4.send(repCmd); //ACK
|
|
10
|
221 }
|
|
21
|
222
|
|
|
223 private void sendJoinAck(REPCommand repCmd) {
|
|
|
224
|
|
|
225 }
|
|
10
|
226
|
|
21
|
227 private void sendJoinAck(SocketChannel channel, REPCommand repCmd) {
|
|
23
|
228 //int eid = sessionlist.getNumberOfEditor(); //eidを取得
|
|
|
229 int eid = editorList.addEditor(channel, repCmd);
|
|
17
|
230 sessionmanagerGUI.setComboEditor(eid, channel); //ComboBoxにEditorを追加
|
|
|
231 repCmd.setEID(eid); //eidを決定して、
|
|
|
232 repCmd.setCMD(REP.SMCMD_JOIN_ACK);
|
|
|
233 repCmd.string = sessionlist.getSessionList(); //Session一覧を
|
|
|
234
|
|
|
235 String string = getSocketString(channel);
|
|
|
236 StringTokenizer stn = new StringTokenizer(string, ":");
|
|
|
237 String host = stn.nextToken();
|
|
|
238 String port = stn.nextToken();
|
|
|
239 repCmd.setString(repCmd.string + ":" + myHost + ":" + port);
|
|
|
240
|
|
|
241 REPPacketSend repSend = new REPPacketSend(channel); //Editor側へ送信
|
|
|
242 repSend.send(repCmd);
|
|
10
|
243 }
|
|
|
244
|
|
0
|
245 public static void main(String[] args) throws InterruptedException, IOException {
|
|
6
|
246 int port = 8766;
|
|
1
|
247
|
|
0
|
248 if(args.length == 1){
|
|
|
249 port = Integer.parseInt(args[1]);
|
|
|
250 }
|
|
|
251 SessionManager sm = new SessionManager(port);
|
|
2
|
252 sm.openSelector();
|
|
|
253 sm.openWindow();
|
|
0
|
254 sm.sessionManagerNet(port);
|
|
|
255 }
|
|
|
256
|
|
2
|
257 private void openWindow() {
|
|
|
258 Thread th = new Thread( sessionmanagerGUI );
|
|
|
259 th.start();
|
|
|
260 System.out.println(sessionmanagerGUI.toString());
|
|
|
261 sessionmanagerGUI.addConnectionListener(this);
|
|
8
|
262 sessionmanagerGUI.addREPActionListener(this);
|
|
2
|
263 }
|
|
|
264
|
|
|
265 private void connectSession(String host) {
|
|
6
|
266 int port = 8766;
|
|
|
267 //SocketChannel sessionchannel;
|
|
2
|
268 //int port = Integer.parseInt(args[2]);
|
|
1
|
269 InetSocketAddress addr = new InetSocketAddress(host, port);
|
|
|
270 try {
|
|
6
|
271 SocketChannel sessionchannel = SocketChannel.open();
|
|
1
|
272 sessionchannel.configureBlocking(true);
|
|
|
273 sessionchannel.connect(addr);
|
|
6
|
274 REPPacketSend send = new REPPacketSend(sessionchannel);
|
|
|
275 while(!sessionchannel.finishConnect()){
|
|
|
276 System.out.print(".");
|
|
|
277 }
|
|
|
278 System.out.println("");
|
|
2
|
279 registerChannel(selector, sessionchannel, SelectionKey.OP_READ);
|
|
24
|
280 //REPCommand sm_join_com = REPCommand.SMCMD_SESSION_JOIN;
|
|
|
281 //String socketString = getSocketString(sessionchannel);
|
|
|
282 //sm_join_com.setString(sm_join_com.string + ":" + socketString);
|
|
6
|
283 send.send(REPCommand.SMCMD_SESSION_JOIN);
|
|
7
|
284 smList.add(sessionchannel);
|
|
31
|
285 smList.setMaster(sessionchannel);
|
|
1
|
286 }catch (IOException e) {
|
|
|
287 e.printStackTrace();
|
|
|
288 }
|
|
|
289 }
|
|
2
|
290
|
|
15
|
291 private String getSocketString(SocketChannel sessionchannel) {
|
|
14
|
292 SocketAddress socket = sessionchannel.socket().getRemoteSocketAddress();
|
|
15
|
293 //String inetAddressString = sessionchannel.socket().getInetAddress().toString();
|
|
|
294 StringTokenizer stn = new StringTokenizer(socket.toString(), "/");
|
|
|
295 String socketString = null;
|
|
|
296 while(stn.hasMoreTokens()){
|
|
|
297 socketString = stn.nextToken();
|
|
16
|
298 //System.out.println(socketString);
|
|
15
|
299 }
|
|
|
300 return socketString;
|
|
14
|
301 }
|
|
|
302
|
|
2
|
303 public void connectionOccured(ConnectionEvent event) {
|
|
|
304 connectSession(event.getHost());
|
|
|
305 }
|
|
8
|
306
|
|
|
307 public void ActionOccured(REPActionEvent event) {
|
|
|
308 System.out.println("Action!");
|
|
|
309 SocketChannel editorChannel = event.getEditorChannel();
|
|
|
310 int sid = event.getSID();
|
|
|
311 int eid = event.getEID();
|
|
|
312 sessionlist.addEditor(editorChannel, sid, eid);
|
|
|
313 REPPacketSend send = new REPPacketSend(editorChannel);
|
|
|
314 send.send(new REPCommand(REP.SMCMD_SELECT_ACK, sid, eid, 0,0,0,""));
|
|
|
315 sessionlist.sendSelect(sid);
|
|
|
316 }
|
|
0
|
317 }
|
