Mercurial > hg > RemoteEditor > REPSessionManager
view rep/Editor.java @ 326:b1a6acf0b8a9
*** empty log message ***
author | kono |
---|---|
date | Sat, 11 Oct 2008 19:04:38 +0900 |
parents | be0831086e63 |
children | 7b6dede07f4a |
line wrap: on
line source
package rep; import java.util.LinkedList; import java.util.List; import rep.channel.REPSocketChannel; import rep.handler.PacketSet; import rep.optimizers.*; import rep.translator.Translator; import rep.translator.TranslatorImpl; public class Editor extends Forwarder { private Translator translator; private List<REPCommand> sentList = new LinkedList<REPCommand>(); // REPCommands we are going to send to the next editor //private REPCommand quit2 = null; private SessionManager manager; private REPCommand quit2=null; public Editor(SessionManager manager,boolean doOptimize,int editorNo){ super(manager); this.manager = manager; eid = editorNo; REPCommandOptimizer optimizer; if (doOptimize) optimizer = new DeleteInsertOptimizer(); //タカノがつくったおぷてぃまいざ else optimizer = new NullOptimizer(); //なにもしないけどOptimizer. translator = new TranslatorImpl(eid,optimizer); } public Editor(SessionManager manager,int editorNo, REPSocketChannel<REPCommand> channel){ this(manager,false,editorNo); this.channel = channel; } public void translate(Editor nextEditor, REPCommand command){ if(command.eid == nextEditor.getEID()){ nextEditor.checkReturnedCommand(command); } else if(command.eid == eid){ //エディタからの新たな編集コマンド sentList.add(command); assert(sentList.size()<limit); translator.transSendCmd(command); nextEditor.send(command); return; }else if(command.eid == REP.MERGE_EID.id){ //マージコマンドが返ってきた if(translator.checkMergeConflict(command)){ //マージ中にエディタからの割り込みがあった場合 translator.getMergeAgain(this); } endMerge(); }else{ //他のエディタからの編集コマンド if(!isMerging()) { translator.transReceiveCmd(nextEditor,command); return; } manager.addWaitingCommand(new PacketSet(getChannel(), this, command)); } return; } boolean merge(REPCommand command) { REPCommand prev = translator.prev(); if(prev==null) return false; assert(prev.eid==command.eid); //マージして送信 return translator.catchOwnCommand(this); } void checkReturnedCommand(REPCommand command) { REPCommand prev = sentList.remove(0); if (prev==null || prev.seq != command.seq) { String err = "Editor.checkReturnedCommand() : command = " + command + " prev="; err += prev==null?"null":prev.toString(); assert(false); } // START_MERGE を送る REPCommand cmd = new REPCommand(REP.SMCMD_START_MERGE,command.sid,REP.SM_EID.id,seq(),0,""); send(cmd); // Session Manager 側で、このeditorへの他のeditorからの // 入力を止めて、merge にそなえる。merge は、eidtor 側から // ACKが来てから始まる。 translator.startMerge(cmd); return; } @Override public void setQuit2(REPCommand cmd) { if (!checkQuit()) quit2 = cmd; // do not send quit2 until we received all pending // command } @Override public void setEID(int eid) { this.eid = eid; translator.setEid(eid); } public String toString(){ return ("Editor eid="+eid+" sid="+sid+" " + host + ":" + file); } public boolean isMerging() { return translator.isMerging(); } void endMerge() { if(translator.isMerging()) return; REPCommand mergeEnd = new REPCommand(REP.SMCMD_END_MERGE,eid,sid,seq(),0,""); send(mergeEnd); if (quit2!=null) checkQuit(); } private boolean checkQuit() { if (sentList.size()==0&&!isMerging()) { send(quit2); manager.remove(this); return true; } return false; } @Override public boolean manage(REPCommand receivedCommand) { switch(receivedCommand.cmd){ // Editor Command case REPCMD_DELETE: case REPCMD_INSERT: case REPCMD_NOP: { translate((Editor)next, receivedCommand); break; } case SMCMD_START_MERGE_ACK: { // マージの処理と次のエディタへコマンドを送信する処理 translator.mergeAck(); if (!merge(receivedCommand)) { // nothing to do, send END_MERGE endMerge(); } break; } case SMCMD_QUIT: { next.send(receivedCommand); break; } case SMCMD_QUIT_2: { Forwarder editor1 = getNextForwarder(); // don't send quit2 to the editor until all pending // merge is processed. editor1.setQuit2(receivedCommand); break; } default: return false; } return true; } }