Mercurial > hg > RemoteEditor > REPSessionManager
view test/mergertest/TestMerger.java @ 435:2b034d12170e
early sent list shortning. not yet worked.
author | one |
---|---|
date | Sat, 16 Jan 2010 18:02:26 +0900 |
parents | 1bb59652d89c |
children | 21cb16b7f3df |
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 boolean isMerging() { // TODO Auto-generated method stub return false; } @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; } }