Mercurial > hg > RemoteEditor > REPSessionManager

changeset 227:cbd67817e9cd

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author pin
date Sun, 31 Aug 2008 13:55:39 +0900
parents e4ed00c82422
children e6c7a56ff7f1
files rep/RPanel.java rep/SelectButtonEvent.java rep/Session.java rep/SessionList.java rep/SessionManager.java test/sematest/PutTester.java
diffstat 6 files changed, 43 insertions(+), 34 deletions(-) [+]
line wrap: on
line diff
--- a/rep/RPanel.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/rep/RPanel.java	Sun Aug 31 13:55:39 2008 +0900
@@ -22,7 +22,7 @@
 	 * 
 	 */
 	private static final long serialVersionUID = 1L;
-	private JButton button;
+	private JButton connectButton;
 	private JTextField textField;
 	private String host;
 	private JLabel label;
@@ -45,12 +45,12 @@
 	private String s_eid;
 	private String e_eid;
 	private String e_socketchannel;
-	private JButton buttonSelect;
+	private JButton selectButton;
 	//private SessionManager manager;
 	private SessionManagerEventListener listener;
 
 	public RPanel() {
-		button = new JButton("Connect");
+		connectButton = new JButton("Connect");
 		textField = new JTextField("firefly.cr.ie.u-ryukyu.ac.jp");
 		textArea = new JTextArea();
 		label = new JLabel("test");
@@ -58,10 +58,10 @@
 		s_sp = new JScrollPane(session_table);
 		editor_table = new JTable(e_tableModel);
 		e_sp = new JScrollPane(editor_table);
-		buttonSelect = new JButton("Select");
+		selectButton = new JButton("Select");
 		
 		
-		button.setBounds(160, 5, 100, 20);
+		connectButton.setBounds(160, 5, 100, 20);
 		textField.setBounds(5, 5, 150, 20);
 		textArea.setEditable(false);
 		textArea.setLineWrap(false);
@@ -70,28 +70,31 @@
         s_sp.setBounds(5,30,400,100);
         e_sp.setPreferredSize(new Dimension(200, 200));
         e_sp.setBounds(5,140,400,100);
-		buttonSelect.setBounds(450, 180, 100, 20);
+		selectButton.setBounds(450, 180, 100, 20);
 				
 
 		this.setLayout(null);
 		this.add(textField);
-		this.add( button);
+		this.add( connectButton);
 		this.add(label);
         this.add(s_sp);
         this.add(e_sp);
-		this.add(buttonSelect);
+		this.add(selectButton);
 
-		button.addActionListener(this);
-		buttonSelect.addActionListener(this);
+		connectButton.addActionListener(this);
+		selectButton.addActionListener(this);
 
 	}
 
 	public void actionPerformed(ActionEvent event) {
-		if (event.getSource() == button) {
+		if (event.getSource() == connectButton) {
 			host = textField.getText();
 			listener.buttonPressed(new ConnectButtonEvent(listener, host));
-		}else if(event.getSource() == buttonSelect){
-			listener.buttonPressed(new SelectButtonEvent<REPCommand>((EditorPlus<REPCommand>) e_list.get(editor_table.getSelectedRow()),
+			
+		}else if(event.getSource() == selectButton){
+			System.out.println("RPanel.actionPerformed():editorSelectedRow = " + editor_table.getSelectedRow());
+			listener.buttonPressed(
+					new SelectButtonEvent<REPCommand>((EditorPlus<REPCommand>) e_list.get(editor_table.getSelectedRow()),
 					(SessionPlus)s_list.get(session_table.getSelectedRow()), listener));
 		}
 	}
@@ -139,6 +142,7 @@
 	protected void setTableEditor(LinkedList<Editor> list) {
 		e_tableModel.setRowCount(0);
 		for(Editor editor : list){
+			System.out.println(editor.getChannel());
 			setTableEditor(editor.getEID(), editor.getChannel());
 		}
 	}
--- a/rep/SelectButtonEvent.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/rep/SelectButtonEvent.java	Sun Aug 31 13:55:39 2008 +0900
@@ -9,10 +9,10 @@
 	private int eid;
 	private SessionManager manager;
 
-	public SelectButtonEvent(EditorPlus<P> plus, SessionPlus plus2, SessionManagerEventListener listener) {
-		this.editorChannel = plus.getChannel();
-		this.eid = plus.getEID();
-		this.sid = plus2.getSID();
+	public SelectButtonEvent(EditorPlus<P> editor, SessionPlus session, SessionManagerEventListener listener) {
+		this.editorChannel = editor.getChannel();
+		this.eid = editor.getEID();
+		this.sid = session.getSID();
 		this.manager = (SessionManager)listener;
 	}
 
--- a/rep/Session.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/rep/Session.java	Sun Aug 31 13:55:39 2008 +0900
@@ -13,10 +13,9 @@
 	private LinkedList<REPNode> routingTable = new LinkedList<REPNode>();
 	private boolean isOwner = false;
 	
-	public Session(int sessionID, String string, REPSocketChannel<REPCommand> channel) {
-		masterEditor = new Editor(sessionID, channel);
-		this.sessionID = sessionID;
-		this.sessionName = string;
+	public Session(int sid, String name, Editor editor) {
+		this(sid, editor);
+		sessionName = name;
 	}
 	public Session(Editor editor) {
 		masterEditor = editor;
@@ -53,8 +52,8 @@
 		editor.setEID(eid);
 		editorList.add(editor);
 	}
-	public void setSID(int sessionID2) {
-		sessionID = sessionID2;
+	public void setSID(int sid) {
+		sessionID = sid;
 	}
 	public void addToRoutingTable(Editor editor) {
 		routingTable.add(new REPNode(editor));
--- a/rep/SessionList.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/rep/SessionList.java	Sun Aug 31 13:55:39 2008 +0900
@@ -44,7 +44,7 @@
 	public int addSession(REPSocketChannel<REPCommand> channel, String string) {
 		sessionID++;
 //		session3.put(sessionID, new Session(sessionID, string, channel));
-		sessionLinkedList.add(new Session(sessionID, string, channel));
+//		sessionLinkedList.add(new Session(sessionID, string, channel));
 		return sessionID; 
 		
 	}
@@ -126,7 +126,7 @@
 	}
 
 	public void addSession(REPSocketChannel<REPCommand> channel, String string, int i) {
-		tmpSessionList.add(new Session(0, string, channel));
+//		tmpSessionList.add(new Session(0, string, channel));
 	}
 
 //	public String getXML() {
--- a/rep/SessionManager.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/rep/SessionManager.java	Sun Aug 31 13:55:39 2008 +0900
@@ -166,15 +166,15 @@
 		{
 			//エディタのリストに追加
 			Editor editor = new Editor(editorList.size(), channel);
-			editorList.add(editor);
+			//editorList.add(editor);
 
 			//Sessionを生成
 			int sid = sessionList.size();
 			editor = new Editor(0, channel);
 			editor.setHost(myHost);
-			Session session = new Session(sid, editor);
+			Session session = new Session(sid, receivedCommand.string, editor);
 			session.hasOwner(true);
-			sessionList.add(new Session(sid, editor));
+			sessionList.add(session);
 
 			guiUpdate();
 
@@ -542,19 +542,25 @@
 		REPSocketChannel<REPCommand> channel = event.getEditorChannel();
 		int sid = event.getSID();
 		Session session = getSession(sid);
-		//selector.wakeup();
+		
+		Editor editor = getEditor(channel);
+		if(editor == null){
+			System.out.println("SessionManager.selectSession():editor = " + editor);
+			return;
+		}
+
+		session.addEditor(editor);
+		
+		System.out.println(session.hasOwner());
 		if(session.hasOwner()){
-			Editor editor = new Editor(channel);
-			session.addEditor(new Editor(channel));
 			REPCommand sendCommand = new REPCommand();
 			sendCommand.setCMD(REP.SMCMD_JOIN_ACK);
 			sendCommand.setEID(editor.getEID());
 			sendCommand.setSID(sid);
 			channel.write(sendCommand);
 		}else {
-			REPSocketChannel<REPCommand> editorChannel = event.getEditorChannel();
 			sid = event.getSID();
-			Editor editor = new Editor(editorChannel);
+			editor = new Editor(channel);
 			editor.setHost(myHost);
 			session = getSession(sid);
 			session.addEditor(editor);
--- a/test/sematest/PutTester.java	Sun Aug 31 13:33:33 2008 +0900
+++ b/test/sematest/PutTester.java	Sun Aug 31 13:55:39 2008 +0900
@@ -17,7 +17,7 @@
 
 		REPCommand command = new REPCommand();
 		command.setCMD(REP.SMCMD_PUT);
-		command.setString("put test");
+		command.setString("PutTest.txt");
 		channel.write(command);
 		
 		channel.read();