Mercurial > hg > RemoteEditor > REPSessionManager

changeset 58:fca7217dab1e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author pin
date Fri, 16 Nov 2007 14:28:07 +0900
parents 29ab0b82988a
children 27ba673f4024
files rep/SessionManager.java rep/SessionManagerList.java
diffstat 2 files changed, 8 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/rep/SessionManager.java	Fri Nov 16 14:09:35 2007 +0900
+++ b/rep/SessionManager.java	Fri Nov 16 14:28:07 2007 +0900
@@ -215,8 +215,13 @@
 			Editor editor1 = new Editor(channel);
 			//editor1.setHost(decoder.getHost());
 			//editor1.setPort(decoder.getPort());
-			
-			smList.sendToMaster(repCmd);
+			if(isMaster){
+				repCmd.setCMD(REP.SMCMD_UPDATE_ACK);
+				smList.sendToSlave(repCmd);
+			}else{
+				repCmd.setCMD(REP.SMCMD_UPDATE);
+				smList.sendToMaster(repCmd);
+			}
 			break;
 			
 		case REP.SMCMD_UPDATE_ACK:
--- a/rep/SessionManagerList.java	Fri Nov 16 14:09:35 2007 +0900
+++ b/rep/SessionManagerList.java	Fri Nov 16 14:28:07 2007 +0900
@@ -70,6 +70,7 @@
 
 	public void sendToSlave(REPCommand repCmd) {
 		for(SocketChannel channel : list){
+			if(channel.equals(master)) continue;
 			REPPacketSend send = new REPPacketSend(channel);
 			send.send(repCmd);
 		}