RemoteEditor/REPSessionManager: rep/handler/Editor.java comparison

comparison rep/handler/Editor.java @ 483:c792a1ebc0ff

new merge (again...)

author	one
date	Sat, 16 Oct 2010 20:48:38 +0900
parents	200166a494e9
children	7420dea70dd7

comparison

equal deleted inserted replaced

-:200166a494e9
+:c792a1ebc0ff
 		case REPCMD_MERGE_MARK:
 			if (command.eid == REP.MERGE_EID.id){
 				//マージコマンドが返ってきた
 				if(checkMergeConflict(command)){
 					//マージ中にエディタからの割り込みがあった場合
-					getMergeAgain(this);
+					getMergeAgain();
 				}
 				checkEndMerge();
 				return;
 			}
 			if (command.eid == eid){
 				return;
 			}
 			//他のエディタからの編集コマンド
 			transReceiveCmd(next,command);
+			if (mergeMode==MergeMode.Direct)
-			sendEditorCommand(command);
+				startMerge(command);
+			else
+				sendEditorCommand(command);
 			return;
 		default:
 			assert(false);
 		}
 	}
 	private void userEditorCommand(REPCommand command) {
 		//エディタからの新たな編集コマンド
+		if (mergeMode==MergeMode.Direct)
+			truncateSentList(command);
 		if (next==this) return; // singleton case
 		transSendCmd(command);
 		sendEditorCommand(command);
 		return;
 	}
 //		}
 //		assert(count==0);
 //	}
 	/**
+	 * truncate sentList and unMergedCmds
+	 */
+	private void truncateSentList(REPCommand command) {
+	}
+	/**
 	 * Sending to Editor and waiting Queue
 	 *                                  +--------+
 	 *      send() --> write() -> | Editor | -> handle() -> manager()
 	 *                                  +--------+
 	 *      waitingQueue
 			command.string=null;
 		}
 		next.send(command);
 	}
-	public  List<REPCommand> getSentList() {
-		return sentList;
-	}
-	public void setSentList(LinkedList<REPCommand> list) {
-		sentList = list;
-	}
 	/**
 	 * 一周して来たcommandの処理。
 	 *
 	 * 　　INSERT/DELETEを受け取った時に、sentListに登録
 	 *    INSERT_ACK/DELETE_ACKが来たら一周。そこで、Mergeする。
 	 * 途中から参加した場合、自分が受けとってないcommandのACKが先に来ることが
 	 * ある。それは、無視して良い。
 	 * @param command
 	 */
 	void checkReturnedCommand(REPCommand command) {
+		if (mergeMode!=MergeMode.Direct)
+			startMerge(command);
+	}
+	void startMerge(REPCommand command) {
 		ServerMainLoop.logger.writeLog("Editor"+eid+": startMerge "+command);
 		preMergeCommand = new REPCommand(command);
 		// merge は必須だが、EditorのCommand実装をテストするには邪魔なので、off に出来るようにする。
 		if (mergeMode==MergeMode.NoMerge) {
 			checkQuit();
 		merging = true;
 		// Session Manager 側で、このeditorへの他のeditorからの
 		// 入力を止めて、merge にそなえる。merge は、eidtor 側から
 		// ACKが来てから始まる。
 	}
 	/**
 	 * sentList と ack を見比べて、正しい順序で来たかどうかを調べる。途中参加したEditorの場合は、Ackは
 	 * 無視して良い。
 	 * @param command
 	 * @return
 		if (quit_2!=null) checkQuit();
 	}
 	private void endMerge() {
-		sortedEditCmds = null;
-		LinkedList<REPCommand>u = new LinkedList<REPCommand>();
-		boolean flag=true;
-		for(REPCommand command:unMergedCmds) {
-			if (command.cmd==REP.REPCMD_MERGE_MARK) {
-				flag = false;
-			}
-			if (flag) u.addLast(command);
-		}
-		unMergedCmds = u;
 		REPCommand mergeEnd = new REPCommand(REP.SMCMD_END_MERGE,sid,eid,seq(),0,"");
 		sendToEditor(mergeEnd);
+		if (mergeMode==MergeMode.Direct) {
+			sendEditorCommand(preMergeCommand);
+			preMergeCommand = null;
+			return ;
+		}
+		sortedEditCmds = null;
+		truncateUnMergedCmds();
 		checkAck(preMergeCommand);
 		if (preMergeCommand.eid==eid) {
 			if (mergeMode==MergeMode.Early) {
 				sendAck(preMergeCommand);
 			}
 			ServerMainLoop.logger.writeLog("Editor"+eid+": send preMergeCommand "+preMergeCommand);
 			next.send(preMergeCommand);
 		}
 		// sentList.clear();
 		preMergeCommand = null;
+	}
+	public void truncateUnMergedCmds() {
+		LinkedList<REPCommand>u = new LinkedList<REPCommand>();
+		boolean flag=true;
+		for(REPCommand command:unMergedCmds) {
+			if (command.cmd==REP.REPCMD_MERGE_MARK) {
+				flag = false;
+			}
+			if (flag) u.addLast(command);
+		}
+		unMergedCmds = u;
 	}
 	private void sendAck(REPCommand command) {
 		REPCommand keep = new REPCommand(command);
 		// First Phase End, send ACK
 		case SMCMD_START_MERGE_ACK:
 		{
 			// マージの処理と次のエディタへコマンドを送信する処理
 			mergeAck();
-			if (!merge(this, preMergeCommand)) {
+			if (!merge(preMergeCommand)) {
 				// nothing to do, send END_MERGE
 				checkEndMerge();
 			}
 			break;
 		}
 	 * is returned.　At this
 	 * stage my writeQueue is empty, our editor is waiting for me.
 	 * Start merge process.
 	 * @param cmd
 	 */
-	public boolean merge(Editor editor, REPCommand prev){
+	public boolean merge(REPCommand prev){
 		logger.writeLog("beforeMerge"+eid+":"+unMergedCmds);
 		LinkedList<REPCommand> output = new LinkedList<REPCommand>();
 		LinkedList<REPCommand> newSentList = new LinkedList<REPCommand>();
 		// merge queue上にあるコマンドを全部undoコマンドするのと同時に
 		// sort したコマンド列を生成する
 		for( REPCommand cmd0 : unMergedCmds) {
 			output.addLast( createUndo(cmd0) );
 		}
 		sortedEditCmds = new TreeSet<REPCommand>(new REPCommandComparator(1));
-		logger.writeLog("sentList"+eid+":"+editor.getSentList());
+		logger.writeLog("sentList"+eid+":"+sentList);
-		for( REPCommand cmd0 : editor.getSentList()) {
+		for( REPCommand cmd0 : sentList ) {
 			if (cmd0.cmd==REP.REPCMD_INSERT || cmd0.cmd==REP.REPCMD_DELETE) {
 					sortedEditCmds.add(cmd0);
 			}
 		}
 		output.addAll(sortedEditCmds);
-		output.addLast(new REPCommand(REP.REPCMD_MERGE_MARK,0, editor.getSID(), REP.MERGE_EID.id, editor.seq(), ""));
+		output.addLast(new REPCommand(REP.REPCMD_MERGE_MARK,0,sid, REP.MERGE_EID.id, seq(), ""));
 		logger.writeLog("sortedMerge"+eid+":"+sortedEditCmds);
 		// unMerged command のdeleteのundo string は、この時点で使えない。
 		// Editor 側から送り返して来たものを使う必要がある。
 		unMergedCmds.clear();
+		sentList = newSentList;
 		logger.writeLog("outputMerge"+eid+":"+output);
-		editor.setSentList(newSentList);
+		return optimizedSend(this,output);
-		return optimizedSend(editor,output);
 	}
 	/**
 	 * Sent optimized merged command list
 	 * @param editor
 			merge_mode=false;
 		}
 		return mergeAgain;
 	}
-	public void getMergeAgain(Editor editor) {
+	public void getMergeAgain() {
 		if (sentMergedList.size()>0) return; //  wait for previous merge completion
 		LinkedList<REPCommand> returnCommand = new LinkedList<REPCommand>();
 		for(REPCommand command : unMergedCmds) {
 			if (command.cmd==REP.REPCMD_INSERT||command.cmd==REP.REPCMD_DELETE)
 				returnCommand.add(createUndo(command));
 		}
 		returnCommand.addAll(sortedEditCmds);
-		returnCommand.addLast(new REPCommand(REP.REPCMD_MERGE_MARK,0, editor.getSID(), REP.MERGE_EID.id, editor.seq(), ""));
+		returnCommand.addLast(new REPCommand(REP.REPCMD_MERGE_MARK,0, sid, REP.MERGE_EID.id, seq(), ""));
-		returnCommand.addAll(editor.getSentList());
+		returnCommand.addAll(sentList);
 		unMergedCmds.clear();
 		logger.writeLog("MergeAgain "+eid+" ret="+returnCommand.size());
 		mergeAgain = false;
-		optimizedSend(editor, returnCommand);
+		optimizedSend(this, returnCommand);
 	}
 //
 //	public boolean isFinished() {
 //		if(unMergedCmds.size() > 0) return false;
 //		if(sentMergedList.size() > 0) return false;

Mercurial > hg > RemoteEditor > REPSessionManager

comparison rep/handler/Editor.java @ 483:c792a1ebc0ff