Mercurial > hg > RemoteEditor > REPSessionManager

comparison test/editortest/TestMerger.java @ 419:7ff127c8ad64

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
(no commit message)
author one
date Tue, 20 Jan 2009 18:39:02 +0900
parents
children
comparison
equal deleted inserted replaced
418:d1bfcff0cdd2 419:7ff127c8ad64
1 package test.editortest;
2
3 import java.io.IOException;
4 import java.util.LinkedList;
5
6 import rep.REP;
7 import rep.REPCommand;
8 import rep.Session;
9 import rep.channel.REPSelectionKey;
10 import rep.channel.REPSocketChannel;
11 import rep.handler.REPNode;
12 import rep.handler.Translator;
13 import rep.optimizers.NullOptimizer;
14
15 public class TestMerger extends REPNode{
16 Translator trans;
17 private int seq;
18 private LinkedList<REPCommand> commandList;
19 private LinkedList<REPCommand> othersCommandList;
20
21 public static void main(String[] args){
22 TestMerger test = new TestMerger();
23 test.setCommands();
24 test.start();
25 }
26
27 public TestMerger(){
28 eid = 1;
29 sid = 1;
30 trans = new Translator(eid, new NullOptimizer());
31 }
32
33 private void setCommands() {
34 commandList = new LinkedList<REPCommand>();
35 commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "AAAAA"));
36 commandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid, seq++, 10, "BBBBB"));
37 othersCommandList = new LinkedList<REPCommand>();
38 othersCommandList.add(new REPCommand(REP.REPCMD_INSERT, sid, eid+1, seq++, 10, "CCCCC"));
39 }
40
41 private void start() {
42 for(REPCommand command : commandList){
43 trans.transSendCmd(command);
44 }
45 for(REPCommand command : othersCommandList){
46 trans.transSendCmd(command);
47 }
48 for(int i = 0; i < commandList.size(); i++){
49 trans.catchOwnCommand(this);
50 System.out.println();
51 }
52 }
53
54 @Override
55 public void cancel(REPSocketChannel<REPCommand> channel1) {
56 // TODO Auto-generated method stub
57
58 }
59
60 @Override
61 public void checkWaitingCommandInMerge() {
62 // TODO Auto-generated method stub
63
64 }
65
66 @Override
67 public void forwardedCommandManage(REPCommand command) {
68 // TODO Auto-generated method stub
69
70 }
71
72 @Override
73 public String getLocalHostName() {
74 // TODO Auto-generated method stub
75 return null;
76 }
77
78 @Override
79 public void handle(REPCommand command, REPSelectionKey<REPCommand> key)
80 throws IOException {
81 // TODO Auto-generated method stub
82
83 }
84
85 @Override
86 public boolean isMerging() {
87 // TODO Auto-generated method stub
88 return false;
89 }
90
91 @Override
92 public void joinAck(REPCommand sendCommand, int sid) {
93 // TODO Auto-generated method stub
94
95 }
96
97 @Override
98 public boolean manage(REPCommand command) {
99 // TODO Auto-generated method stub
100 return false;
101 }
102
103 @Override
104 public void selectSession(REPCommand sendCommand, Session session) {
105 // TODO Auto-generated method stub
106
107 }
108
109 @Override
110 public void send(REPCommand command) {
111 // TODO Auto-generated method stub
112 Logger.print(command);
113 }
114
115 @Override
116 public void sendWithSeq(REPCommand command) {
117 // TODO Auto-generated method stub
118
119 }
120
121 @Override
122 public int seq() {
123 // TODO Auto-generated method stub
124 return 0;
125 }
126
127 @Override
128 public void setQuit2(REPCommand receivedCommand) {
129 // TODO Auto-generated method stub
130
131 }
132 }