Mercurial > hg > RemoteEditor > REPSessionManager
view test/mergertest/TestMerger.java @ 450:21cb16b7f3df
block message in Editor.write()
author | one |
---|---|
date | Thu, 23 Sep 2010 18:15:37 +0900 |
parents | 2b034d12170e |
children | c83af820eb62 |
line wrap: on
line source
package test.mergertest; import java.io.IOException; import java.util.LinkedList; import java.util.List; import rep.REP; import rep.REPCommand; import rep.Session; import rep.channel.REPSelectionKey; import rep.channel.REPSocketChannel; import rep.handler.REPNode; import rep.handler.Translator; import rep.optimizers.NullOptimizer; import test.editortest.Logger; public class TestMerger extends REPNode{ Translator trans; private int seq; private LinkedList<REPCommand> commandList; private LinkedList<REPCommand> othersCommandList; public static void main(String[] args){ TestMerger test = new TestMerger(); test.setCommands(); test.start(); } public TestMerger(){ eid = 1; sid = 1; trans = new Translator(eid, new NullOptimizer()); } private void setCommands() { commandList = new LinkedList<REPCommand>(); commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "AAAAA")); commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "BBBBB")); othersCommandList = new LinkedList<REPCommand>(); othersCommandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid+1, 1, 10, "CCCCC")); } private void start() { for(REPCommand command : commandList){ Logger.print(command); trans.transSendCmd(command); } for(REPCommand command : othersCommandList){ Logger.print(command); trans.transReceiveCmd(null, command); } for(int i = 0; i < commandList.size(); i++){ trans.catchOwnCommand(this,null); System.out.println(); } } @Override public void cancel(REPSocketChannel<REPCommand> channel1) { // TODO Auto-generated method stub } @Override public void checkWaitingCommandInMerge() { // TODO Auto-generated method stub } @Override public void forwardedCommandManage(REPCommand command) { // TODO Auto-generated method stub } @Override public String getLocalHostName() { // TODO Auto-generated method stub return null; } @Override public void handle(REPCommand command, REPSelectionKey<REPCommand> key) throws IOException { // TODO Auto-generated method stub } @Override public void joinAck(REPCommand sendCommand, int sid) { // TODO Auto-generated method stub } @Override public boolean manage(REPCommand command) { // TODO Auto-generated method stub return false; } @Override public void selectSession(REPCommand sendCommand, Session session) { // TODO Auto-generated method stub } @Override public void send(REPCommand command) { Logger.print(command); } @Override public void sendWithSeq(REPCommand command) { // TODO Auto-generated method stub } @Override public int seq() { // TODO Auto-generated method stub return seq++; } @Override public void setQuit2(REPCommand receivedCommand) { // TODO Auto-generated method stub } @Override public List<REPCommand> getSentList() { // TODO Auto-generated method stub return null; } @Override public void write(REPCommand command) { // TODO Auto-generated method stub } }