RemoteEditor/REPSessionManager: rep/SessionManager.java comparison

comparison rep/SessionManager.java @ 382:4b87f89b3afd

REP Session Manager (Java version) new structure

author	one@firefly.cr.ie.u-ryukyu.ac.jp
date	Mon, 10 Nov 2008 22:07:45 +0900
parents	c78569ab5fce
children	bcdf5476b8e4

comparison

equal deleted inserted replaced

-:65fdb3dc1885
+:4b87f89b3afd
 import rep.channel.REPLogger;
 import rep.channel.REPServerSocketChannel;
 import rep.channel.REPSocketChannel;
-import rep.handler.PacketSet;
+import rep.gui.CloseButtonEvent;
-import rep.handler.REPHandler;
+import rep.gui.DoGUIUpdate;
+import rep.gui.SelectButtonEvent;
+import rep.gui.SessionManagerEvent;
+import rep.gui.SessionManagerEventListener;
+import rep.gui.SessionManagerGUI;
+import rep.gui.SessionManagerGUIimpl;
+import rep.handler.Dispatcher;
+import rep.handler.Editor;
+import rep.handler.REPNode;
+import rep.handler.FirstConnector;
+import rep.handler.Forwarder;
 import rep.channel.REPSelector;
 import rep.xml.SessionXMLDecoder;
 import rep.xml.SessionXMLEncoder;
 import rep.channel.REPSelectionKey;
 	private List<PacketSet> waitingCommandInMerge;
 	// Command from gui. Synchronization is required.
 	private BlockingQueue<SessionManagerEvent> waitingEventQueue
 		= new LinkedBlockingQueue<SessionManagerEvent>();;
 	// host name of this server. One of connecting SocketChannel's hostname
-	String myHost;
+	public String myHost;
 	// Single threaded write queueu. To avoid dead lock with too many writes.
 	private LinkedList<PacketSet> writeQueue = new LinkedList<PacketSet>();
 	private int receive_port;
 	private int parent_port;
 	static final int DEFAULT_PORT = 8766;
 	// globalSessionID = SessionManagerID * MAXID + localSessionID
 	private static final int MAXID = 10000;
 	SessionXMLDecoder decoder = new SessionXMLDecoder();
 	SessionXMLEncoder encoder = new SessionXMLEncoder();
 	// SocketChannel for our parent. At most one parent is allowed.
-	private Forwarder sm_join_channel;
+	private REPNode sm_join_channel;
 	// Routing table for session and session manager.
 	private RoutingTable routingTable = new RoutingTable(this);
 	private SessionManagerEvent execAfterConnect = null;;
 	public static void main(String[] args) throws InterruptedException, IOException {
 		ssc.configureBlocking(false);       // Selector requires this
 		ssc.socket().setReuseAddress(true);	//reuse address 必須
 		//getAllByNameで取れた全てのアドレスに対してbindする
 		ssc.socket().bind(new InetSocketAddress(port));
 		ssc.register(selector, SelectionKey.OP_ACCEPT,
-				new Forwarder(this));
+				new Dispatcher(this));  // FirstConnector?
 		sessionList = new SessionList();
 		smList = new SessionManagerList();
 		editorList = new EditorList();
 		waitingCommandInMerge = new LinkedList<PacketSet>();
 	 */
 	private void checkWaitingCommandInMerge() {
 		List<PacketSet> w = waitingCommandInMerge;
 		waitingCommandInMerge = new LinkedList<PacketSet>();
 		for(PacketSet p: w) {
-			Editor e = p.getEditor();
+			REPNode e = p.getEditor();
 			if(e.isMerging()) { // still merging do nothing
 				waitingCommandInMerge.add(p);
 			} else {
 				try {
 					if (sessionManage(e, p.command)) { // we don't need this
 	/*
 	 * Close a channel in case of exception or close.
 	 */
 	private void close(REPSocketChannel<REPCommand> channel) {
 		REPSelectionKey<REPCommand>key = channel.keyFor1(selector);
-		REPHandler handler = (REPHandler)key.attachment();
+		REPNode handler = (REPNode)key.attachment();
 		key.cancel();
 		handler.cancel(channel);
 		// we have to remove session/enditor
 	}
 				/*
 				 * Incoming packets are handled by a various forwarder.
 				 * A hadler throw IOException() in case of a trouble to
 				 * close the channel.
 				 */
-				REPHandler handler = (REPHandler)(key.attachment());
+				REPNode handler = (REPNode)key.attachment();
 				try {
 					handler.handle(key);
 				} catch (IOException e) {
 					key.cancel();
 					handler.cancel(key.channel1());
 				}
 			}
 		}
 	}
-	void registerChannel(REPSocketChannel<REPCommand> channel,Forwarder handler) throws IOException {
+	public void registerChannel(REPSocketChannel<REPCommand> channel,REPNode handler) throws IOException {
 		if(channel == null) {
 			return;
 		}
 		handler.setChannel(channel);
 		channel.configureBlocking(false);
 		removeChannel(sm_join_channel);
 		sm_join_channel=null;
 	}
-	private void removeChannel(Forwarder channel) {
+	private void removeChannel(REPNode channel) {
 		REPSelectionKey<REPCommand> key = channel.channel.keyFor1(selector);
 		key.cancel();
 		try {
 			channel.channel.close1();
 		} catch (IOException e) {
 	void updateGUI() {
 		//リストのコピーをGUIに渡す
 		LinkedList<Session> sList = new LinkedList<Session>(sessionList.values());
-		LinkedList<Editor> eList;
+		LinkedList<REPNode> eList;
 		if (false) {
 			// local editor only
-			eList = new LinkedList<Editor>();
+			eList = new LinkedList<REPNode>();
-			for(Editor e:editorList.values()) {
+			for(REPNode e:editorList.values()) {
 				if (getSMID(e.eid)==smList.sessionManagerID()) {
 					eList.add(e);
 				}
 			}
 		} else {
-			eList = new LinkedList<Editor>(editorList.values());
+			eList = new LinkedList<REPNode>(editorList.values());
 		}
 		//GUIに反映
 		Runnable doRun = new DoGUIUpdate(sList, eList, gui);
 		gui.invokeLater(doRun);
 	}
-	void setMyHostName(String localHostName) {
+	public void setMyHostName(String localHostName) {
 		myHost = localHostName + receive_port;
 		setHostToEditor(myHost);
 	}
 	private void setHostToEditor(String myHost2) {
-		for(Editor editor : editorList.values()){
+		for(REPNode editor : editorList.values()){
 			if (editor.channel!=null)
 				editor.setHost(myHost2);
 		}
 	}
 		InetSocketAddress addr = new InetSocketAddress(host, port);
 		try {
 			REPSocketChannel<REPCommand> sessionchannel = REPSocketChannel.<REPCommand>create(new REPCommandPacker());
 			sessionchannel.connect(addr);
 			while(!sessionchannel.finishConnect());
-			Forwarder sm = new FirstConnector(this);
+			REPNode sm = new FirstConnector(this);
 			registerChannel(sessionchannel, sm);
 			sm_join(sm);
 		}catch (IOException e) {
 		}
 	}
 	/**
 	 * channel に SMCMD_SM_JOIN command を送る。
 	 * @param channel
 	 */
-	private void sm_join(Forwarder channel){
+	private void sm_join(REPNode channel){
 		sm_join_channel = channel;
 		//SM_JOINコマンドを生成。
 		REPCommand command = new REPCommand();
 		command.setCMD(REP.SMCMD_SM_JOIN);
 		command.setEID(-1);   // request Parent SessionManagerID
 	 */
 	public void selectSession(SelectButtonEvent event) throws IOException {
 		int sid = event.getSID();
 		Session session = sessionList.get(sid);
 		if (session==null) throw new IOException();
-		Editor editor = (Editor)event.getEditor();
+		REPNode editor = event.getEditor();
 		if (editor.hasSession()) return;
 		// assert(getSMID(editor.eid)==smList.sessionManagerID());
 		// assert(editor.channel!=null);
 		editor.setSID(sid); // mark as selected
 		selectSession0(sid, session, editor.getEID(), editor);
 	}
-	private void selectSession0(int sid, Session session, int eid, Editor editor) {
+	private void selectSession0(int sid, Session session, int eid, REPNode editor) {
 		if (editor.isDirect()&&editor.getEID()==eid) {
 			selectSession(sid, session, editor.getEID(), editor);
 		} else {
 			// we don't have this editor, search the editor first.
-			Forwarder next = routingTable.toSessionManager(getSMID(eid));
+			REPNode next = routingTable.toSessionManager(getSMID(eid));
 			// pass the select command to the next path.
 			REPCommand command = new REPCommand();
 			command.setCMD(REP.SMCMD_SELECT0);
 			command.setSID(sid);
 			command.setEID(eid);
 	/*
 	 * Select Session Protocol handler
 	 *    called from GUI or incoming SMCMD_SELECT command.
 	 */
-	private void selectSession(int sid, Session session, int eid, Forwarder editor) {
+	private void selectSession(int sid, Session session, int eid, REPNode editor) {
 		if(session.hasOwner()){
 			// we have selected session.
 			REPCommand sendCommand = new REPCommand();
 			if (editor.isDirect()&&editor.getEID()==eid) {
 				// Found directly connected joined editor. Send join_ack().
 			forwardSelect(sid, session, eid, editor);
 		}
 	}
 	private void forwardSelect(int sid, Session session, int eid,
-			Forwarder editor) {
+			REPNode editor) {
-		Forwarder next;
+		REPNode next;
 		// session searching continue...
 		next = routingTable.toSessionManager(getSMID(sid));
 		// make a forwarding channel here
-		Forwarder f = createSessionDispatcher(sid, next);
+		REPNode f = createSessionForwarder(sid, next);
 		session.setFirstForwarder(f);
 		session.addForwarder(editor);
 		// pass the select command to the next path.
 		REPCommand command = new REPCommand();
 		command.setCMD(REP.SMCMD_SELECT);
 		command.setEID(eid);
 		command.setString(editor.getHost());
 		next.send(command);
 	}
-	private Forwarder createSessionDispatcher(int sid, Forwarder editor) {
+	private REPNode createSessionForwarder(int sid, REPNode editor) {
-		Forwarder f = new Editor(this, false, makeID(editorList.newEid()));
+		REPNode f = new Forwarder(this);
+		f.setEID(makeID(editorList.newEid()));
 		f.setChannel(editor.channel); // incoming channel
 		f.setHost(myHost);
 		f.setSID(sid);
 		return f;
 	}
 	/*
 	 * Create new editor in this sessin manager. A dummy editor
 	 * is created also.
 	 */
-	public Editor newEditor(REPSocketChannel<REPCommand> channel) {
+	public REPNode newEditor(REPSocketChannel<REPCommand> channel) {
 		int eid =  makeID(editorList.newEid());
-		Editor editor = new Editor(this, eid, channel);
+		REPNode editor = new Editor(this, eid, channel);
 		editorList.add(editor);
 		return editor;
 	}
 	/*
 	 * Create new session.
 	 */
-	public Session newSession(Forwarder master) {
+	public Session newSession(REPNode master) {
 		int sid= makeID(sessionList.newSessionID());
 		Session session = new Session(sid, master);
 		sessionList.put(sid, session);
 		return session;
 	}
 	public int getPort() {
 		return receive_port;
 	}
-	boolean sessionManage(Forwarder forwarder, REPCommand command) throws ClosedChannelException,
+	public boolean sessionManage(REPNode forwarder, REPCommand command) throws ClosedChannelException,
 			IOException {
 		switch(command.cmd){
 		// Session Manager Command
 		case SMCMD_SELECT0:
 			/*
 			 * finding joining editor, do not make the path.
 			 */
-			Forwarder editor  = editorList.get(command.eid);
+			REPNode editor  = editorList.get(command.eid);
 			if (editor==null|| !editor.isDirect()) {
-				Forwarder next = routingTable.toSessionManager(getSMID(command.eid));
+				REPNode next = routingTable.toSessionManager(getSMID(command.eid));
 				next.send(command);
 				break;
 			}
 			// we've found the editor, fall thru.
 		case SMCMD_SELECT:
 				session = new Session(command.sid, command.string,null);
 				sessionList.put(command.sid,session);
 			}
 			// Do not directly addForwarder(forwarder). It may be
 			// shared among sessions.
-			Forwarder f = createSessionDispatcher(command.sid, forwarder);
+			REPNode f = createSessionForwarder(command.sid, forwarder);
 			session.addForwarder(f); // f.next is set up here.
 			selectSession(command.sid, session, command.eid, forwarder);
 		}
 			break;
 		case SMCMD_SELECT_ACK:
 			return false;
 		}
 		return true;
 	}
-	private void registSessionManager(Forwarder forwarder, REPCommand command) {
+	private void registSessionManager(REPNode forwarder, REPCommand command) {
-		Forwarder sm;
+		REPNode sm;
 		int psid = command.eid;
 		if (forwarder.sid!=-1) {
 		// すでに channelはSessionManager Idを持っていて、
 		//　direct link ではないので、
 		// channel を持たないForwarderとして登録する
 	/*
 	 * 指定されたeditorがlocalにあるかどうかを調べる。なければ、他に送る。戻って何回も探すことが
 	 * あり得るので、よろしくない。
 	 */
-	private void searchSelectedEditor(REPCommand command, Forwarder editor) {
+	private void searchSelectedEditor(REPCommand command, REPNode editor) {
 		for(;editor.isDirect();editor = editor.getNextForwarder()) {
 			if (editor.getEID()==command.eid) {
 				// select したeditor を見つけた
 				command.cmd=REP.SMCMD_JOIN_ACK;
 				editor.send(command);
 	/**
 	 * Register Editor to our editorList. No connection is made.
 	 * @param forwarder     Editor to be add
 	 * @param command
 	 */
-	public void registEditor(Forwarder forwarder,REPCommand command) {
+	public void registEditor(REPNode forwarder,REPCommand command) {
 		// make ack for PUT/JOIN. Do not send this to the editor,
 		// before select. After select, ack is sent to the editor.
-		Editor editor;
+		REPNode editor;
 		if (getSMID(command.eid)==smList.sessionManagerID()) {
 			if (forwarder.isDirect()) {
 				editor = (Editor)forwarder;
 			} else
 				return;
 	public void afterConnect() {
 		if (execAfterConnect!=null) execAfterConnect.exec(this);
 		execAfterConnect = null;
 	}
-	public void setParent(Forwarder fw) {
+	public void setParent(REPNode fw) {
 		smList.setParent(fw);
 	}
 	public String toString() {
 		int myId = 0;
 		if (smList!=null) myId = smList.sessionManagerID();
 		return "rep.SessionManager-"+myId+"@"+myHost+":"+receive_port;
 	}
+	public void addWaitingSessionManager(REPNode fw, REPCommand command) {
+		smList.addWaitingSessionManager(fw, command) ;
+	}
 }

Mercurial > hg > RemoteEditor > REPSessionManager

comparison rep/SessionManager.java @ 382:4b87f89b3afd