# HG changeset patch # User pin # Date 1193977272 -32400 # Node ID 09316c8a674a63b1cf9de2ac57e8761242a230de # Parent 2d4c2c19d2d071f07204099f8826644011ac6c55 *** empty log message *** diff -r 2d4c2c19d2d0 -r 09316c8a674a rep/SessionManager.java --- a/rep/SessionManager.java Tue Oct 30 15:52:02 2007 +0900 +++ b/rep/SessionManager.java Fri Nov 02 13:21:12 2007 +0900 @@ -1,6 +1,7 @@ package rep; import java.io.IOException; +import java.net.InetAddress; import java.net.InetSocketAddress; import java.nio.channels.SelectableChannel; import java.nio.channels.SelectionKey; @@ -118,10 +119,12 @@ int eid = sessionlist.getNumberOfEditor(); //eidを取得 sessionmanagerGUI.setComboEditor(eid, channel); //ComboBoxにEditorを追加 repCmd.setEID(eid); //eidを決定して、 - repCmd.setCMD(repCmd.cmd + 1); //ACKを返す + //repCmd.setCMD(repCmd.cmd + 1); //ACKを返す + repCmd.setCMD(REP.SMCMD_JOIN_ACK); repCmd.string = sessionlist.getSessionList(); //Session一覧を REPPacketSend repSend = new REPPacketSend(channel); //Editor側へ送信 repSend.send(repCmd); + join_ack(channel, repCmd); break; case REP.SMCMD_JOIN_ACK: @@ -154,6 +157,7 @@ smList.add(channel); //SessionManagerのリストへ追加 repCmd.setCMD(repCmd.cmd + 1); REPPacketSend repSend4 = new REPPacketSend(channel); + sm_join_ack(channel); repSend4.send(repCmd); //ACK break; case REP.SMCMD_SM_JOIN_ACK: @@ -179,6 +183,16 @@ } } + private void sm_join_ack(SocketChannel channel) { + InetAddress address = channel.socket().getInetAddress(); + System.out.println(address); + } + + private void join_ack(SocketChannel channel, REPCommand repCmd) { + String dis_host = channel.socket().getRemoteSocketAddress().toString(); + System.out.println(dis_host); + } + public static void main(String[] args) throws InterruptedException, IOException { int port = 8766;