1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.directory.mitosis.service.protocol.codec;
21
22
23 import org.apache.directory.mitosis.common.CSNVector;
24 import org.apache.directory.mitosis.common.DefaultCSN;
25 import org.apache.directory.mitosis.service.protocol.Constants;
26 import org.apache.directory.mitosis.service.protocol.codec.BeginLogEntriesAckMessageDecoder;
27 import org.apache.directory.mitosis.service.protocol.codec.BeginLogEntriesAckMessageEncoder;
28 import org.apache.directory.mitosis.service.protocol.message.BeginLogEntriesAckMessage;
29
30
31 public class BeginLogEntriesAckMessageCodecTest extends AbstractMessageCodecTest
32 {
33
34 private static final CSNVector PURGE_VECTOR = new CSNVector();
35 private static final CSNVector UPDATE_VECTOR = new CSNVector();
36
37 static
38 {
39 PURGE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() - 400, "replica0", 3456 ) );
40 PURGE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() - 300, "replica1", 9012 ) );
41 PURGE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() - 200, "replica2", 5678 ) );
42 PURGE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() - 100, "replica3", 1234 ) );
43
44 UPDATE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() + 000, "replica0", 1234 ) );
45 UPDATE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() + 100, "replica1", 5678 ) );
46 UPDATE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() + 200, "replica2", 9012 ) );
47 UPDATE_VECTOR.setCSN( new DefaultCSN( System.currentTimeMillis() + 300, "replica3", 3456 ) );
48 }
49
50
51 public BeginLogEntriesAckMessageCodecTest()
52 {
53 super( new BeginLogEntriesAckMessage( 1234, Constants.OK, PURGE_VECTOR, UPDATE_VECTOR ),
54 new BeginLogEntriesAckMessageEncoder(), new BeginLogEntriesAckMessageDecoder() );
55 }
56 }