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