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

annotate rep/handler/Editor.java @ 385:1fca50ce3508

first-working-version

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

rev	line source
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	1 package rep.handler;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	2
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	3 import java.io.IOException;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	4 import java.util.LinkedList;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	5 import java.util.List;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	6
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	7 import rep.PacketSet;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	8 import rep.REP;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	9 import rep.REPCommand;
384 bcdf5476b8e4 restructured-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 383 diff changeset	10 import rep.ServerMainLoop;
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	11 import rep.SessionManager;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	12 import rep.channel.REPSelectionKey;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	13 import rep.channel.REPSocketChannel;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	14 import rep.optimizers.*;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	15
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	16 public class Editor extends Forwarder {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	17
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	18 private Translator translator;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	19 private List<REPCommand> sentList = new LinkedList<REPCommand>();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	20 // REPCommands we are going to send to the next editor
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	21 //private REPCommand quit2 = null;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	22 private SessionManager manager;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	23 private REPCommand quit2=null;
385 1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	24 static final boolean doOptimize = true;
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	25
385 1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	26 public Editor(SessionManager manager,int editorNo){
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	27 super(manager);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	28 this.manager = manager;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	29 eid = editorNo;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	30 REPCommandOptimizer optimizer;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	31 if (doOptimize) optimizer = new DeleteInsertOptimizer(); //タカノがつくったおぷてぃまいざ
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	32 else optimizer = new NullOptimizer(); //なにもしないけどOptimizer.
383 6d48db302b07 r20081022 one@firefly.cr.ie.u-ryukyu.ac.jp parents: 382 diff changeset	33 translator = new Translator(eid,optimizer);
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	34
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	35 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	36
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	37 public Editor(SessionManager manager,int editorNo, REPSocketChannel<REPCommand> channel){
385 1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	38 this(manager,editorNo);
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	39 this.channel = channel;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	40 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	41
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	42 public void translate(REPCommand command){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	43
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	44 if(command.eid == eid){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	45 //エディタからの新たな編集コマンド
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	46 if (next==this) return; // singleton case
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	47 translator.transSendCmd(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	48 sentList.add(new REPCommand(command));
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	49 assert(sentList.size()<limit);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	50 next.send(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	51 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	52 } else if(command.eid == REP.MERGE_EID.id){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	53 //マージコマンドが返ってきた
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	54 if(translator.checkMergeConflict(command)){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	55 //マージ中にエディタからの割り込みがあった場合
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	56 translator.getMergeAgain(this);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	57 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	58 checkEndMerge();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	59 } else if(command.eid == next.getEID()){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	60 // 次のEditorで一周するコマンドが来た
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	61 if(next==this) return; // singleton case
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	62 // これは、distributed case では、うまくいかないので、送り先のforwarder で処理する。
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	63 if (next.isDirect())
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	64 ((Editor) next).checkReturnedCommand(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	65 else
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	66 next.send(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	67 } else {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	68 //他のエディタからの編集コマンド
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	69 assert (command.eid!=REP.MERGE_EID.id && command.eid!=eid );
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	70 if (manager.hasWaitingCommand(channel)) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	71 // We cannot do this operation before watingCommandQueue.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	72 manager.addWaitingCommand(new PacketSet(channel, this, command));
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	73 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	74 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	75 if(!isMerging()) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	76 translator.transReceiveCmd(next,command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	77 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	78 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	79 manager.addWaitingCommand(new PacketSet(getChannel(), this, new REPCommand(command)));
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	80 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	81 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	82 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	83
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	84 boolean merge(REPCommand command) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	85 //マージして送信
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	86 return translator.catchOwnCommand(this);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	87 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	88
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	89 void checkReturnedCommand(REPCommand command) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	90 REPCommand prev = sentList.remove(0);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	91 if (prev==null \|\| prev.seq != command.seq \|\| prev.eid!=command.eid) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	92 String err = "Editor.checkReturnedCommand() : command = " + command + " prev=";
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	93 err += prev==null?"null":prev.toString();
384 bcdf5476b8e4 restructured-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 383 diff changeset	94 ServerMainLoop.logger.writeLog(err);
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	95 assert(false);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	96 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	97
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	98 // START_MERGE を送る
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	99 // 送らないで良い場合もある?
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	100 REPCommand cmd = new REPCommand(REP.SMCMD_START_MERGE,command.sid,REP.SM_EID.id,seq(),0,"");
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	101 send(cmd);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	102 // Session Manager 側で、このeditorへの他のeditorからの
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	103 // 入力を止めて、merge にそなえる。merge は、eidtor 側から
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	104 // ACKが来てから始まる。
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	105 translator.startMerge(cmd);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	106 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	107 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	108
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	109 @Override
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	110 public void setQuit2(REPCommand cmd) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	111 quit2 = cmd;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	112 checkQuit();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	113 // do not send quit2 until we received all pending
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	114 // command
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	115 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	116
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	117 @Override
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	118 public void setEID(int eid) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	119 this.eid = eid;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	120 translator.setEid(eid);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	121 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	122
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	123 public String toString(){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	124 return ("Editor eid="+eid+" sid="+sid+" " + host + ":" + file);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	125 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	126
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	127 public boolean isMerging() {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	128 return translator.isMerging();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	129 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	130
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	131
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	132
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	133 void checkEndMerge() {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	134 if(translator.isMerging()) return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	135 REPCommand mergeEnd = new REPCommand(REP.SMCMD_END_MERGE,eid,sid,seq(),0,"");
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	136 send(mergeEnd);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	137 if (quit2!=null) checkQuit();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	138 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	139
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	140 private boolean checkQuit() {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	141 if (sentList.size()==0&&!isMerging()) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	142 send(quit2);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	143 quit2 = null;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	144 return true;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	145 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	146 return false;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	147 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	148
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	149 @Override
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	150 public boolean manage(REPCommand receivedCommand) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	151
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	152
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	153 switch(receivedCommand.cmd){
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	154 // Editor Command
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	155
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	156 case REPCMD_DELETE:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	157 case REPCMD_INSERT:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	158 case REPCMD_NOP:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	159 {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	160 translate(receivedCommand);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	161 break;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	162 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	163
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	164 case SMCMD_START_MERGE_ACK:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	165 {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	166 // マージの処理と次のエディタへコマンドを送信する処理
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	167 translator.mergeAck();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	168 if (!merge(receivedCommand)) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	169 // nothing to do, send END_MERGE
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	170 checkEndMerge();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	171 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	172 break;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	173 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	174 case SMCMD_QUIT:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	175 {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	176 next.send(receivedCommand);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	177 break;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	178 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	179 case SMCMD_QUIT_2:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	180 {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	181 // QUIT_2 is returned.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	182 if (receivedCommand.eid!=eid) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	183 // stop this editor unless this is the start, starter will stopped
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	184 // by QUIT_2_ACK
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	185 manager.remove(this);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	186 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	187 // don't send quit_2 directly to the editor until all pending
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	188 // merge is processed.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	189 // this does not work in distributed case.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	190 if (next.isDirect())
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	191 next.setQuit2(receivedCommand);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	192 else
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	193 next.send(receivedCommand);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	194 break;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	195 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	196 case SMCMD_QUIT_2_ACK:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	197 {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	198 manager.remove(this);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	199 break;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	200 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	201 default:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	202 return false;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	203 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	204 return true;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	205 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	206
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	207
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	208 @Override
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	209 public void handle(REPSelectionKey<REPCommand> key) throws IOException {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	210 REPSocketChannel<REPCommand> channel = key.channel1();
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	211 REPCommand command = channel.read();
384 bcdf5476b8e4 restructured-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 383 diff changeset	212 ServerMainLoop.logger.writeLog("REPHandlerImpl.handle() read : command = " + command +" from "+channel);
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	213 if (manager.sessionManage(this, command)) return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	214 manage(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	215 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	216
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	217 @Override
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	218 public void cancel(REPSocketChannel<REPCommand> socketChannel) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	219 manager.remove(socketChannel);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	220 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	221
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	222 public boolean isMaster() {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	223 return mode==REP.SMCMD_PUT;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	224 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	225
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	226 /* Handle special case first, usually these cases
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	227 * are handled in the next Editor in a session manager, but
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	228 * it is forwarded here.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	229 */
385 1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	230 public void forwardedCommandManage(REPCommand command) {
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	231 if (command.cmd==REP.SMCMD_QUIT_2) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	232 // we have to wait next editor's finishing before sending this.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	233 // this is odd, but the editor itself does not know it's merging
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	234 // state. Only this session manager knows it.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	235 setQuit2(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	236 } else if (command.eid==eid) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	237 // if we handle in editor.manage(), this editor cannot distinguish this
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	238 // and user input command from the editor.
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	239 switch(command.cmd) {
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	240 case REPCMD_DELETE:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	241 case REPCMD_INSERT:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	242 case REPCMD_NOP:
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	243 checkReturnedCommand(command);
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	244 return;
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	245 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	246 }
385 1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	247 send(command);
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	248 }
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	249
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	250 @Override
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	251 public void send(REPCommand command) {
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	252 assert(command!=null);
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	253 assert(channel!=null);
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	254 REPCommand c = new REPCommand(command);
1fca50ce3508 first-working-version one@firefly.cr.ie.u-ryukyu.ac.jp parents: 384 diff changeset	255 manager.addWriteQueue(new PacketSet(channel,null, c));
382 4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	256 }
4b87f89b3afd REP Session Manager (Java version) one@firefly.cr.ie.u-ryukyu.ac.jp parents: diff changeset	257 }

Mercurial > hg > RemoteEditor > REPSessionManager

annotate rep/handler/Editor.java @ 385:1fca50ce3508