File tree Expand file tree Collapse file tree 3 files changed +87
-0
lines changed
framework/src/test/java/org/tron/common/overlay/discover/table Expand file tree Collapse file tree 3 files changed +87
-0
lines changed Original file line number Diff line number Diff line change
1
+ package org .tron .common .overlay .discover .table ;
2
+
3
+ import org .junit .Assert ;
4
+ import org .junit .Test ;
5
+ import org .tron .common .overlay .discover .node .Node ;
6
+
7
+ public class NodeEntryTest {
8
+
9
+ @ Test
10
+ public void test () throws InterruptedException {
11
+ Node node1 = Node .instanceOf ("127.0.0.1:10001" );
12
+ NodeEntry nodeEntry = new NodeEntry (node1 );
13
+ int distance = nodeEntry .getDistance ();
14
+ Assert .assertEquals (-256 , distance );
15
+
16
+ long lastModified = nodeEntry .getModified ();
17
+ //System.out.println(lastModified);
18
+ Thread .sleep (1 );
19
+ nodeEntry .touch ();
20
+ long nowModified = nodeEntry .getModified ();
21
+ //System.out.println(nowModified);
22
+ Assert .assertNotEquals (lastModified , nowModified );
23
+
24
+ Node node2 = Node .instanceOf ("127.0.0.1:10002" );
25
+ NodeEntry nodeEntry2 = new NodeEntry (node2 );
26
+ boolean isDif = nodeEntry .equals (nodeEntry2 );
27
+ Assert .assertTrue (isDif );
28
+ }
29
+ }
Original file line number Diff line number Diff line change
1
+ package org .tron .common .overlay .discover .table ;
2
+
3
+ import org .junit .Assert ;
4
+ import org .junit .Test ;
5
+ import org .tron .common .overlay .discover .node .Node ;
6
+
7
+ import java .util .List ;
8
+
9
+ public class NodeTableTest {
10
+ @ Test
11
+ public void test () {
12
+ Node node1 = Node .instanceOf ("127.0.0.1:10002" );
13
+ Node node2 = Node .instanceOf ("127.0.0.1:10003" );
14
+ Node node3 = Node .instanceOf ("127.0.0.2:10004" );
15
+ NodeTable table = new NodeTable (node1 );
16
+ Node nodeTemp = table .getNode ();
17
+ Assert .assertEquals (10002 , nodeTemp .getPort ());
18
+ Assert .assertEquals (0 , table .getNodesCount ());
19
+ Assert .assertEquals (0 , table .getBucketsCount ());
20
+
21
+ table .addNode (node2 );
22
+ table .addNode (node3 );
23
+ int bucketsCount = table .getBucketsCount ();
24
+ int nodeCount = table .getNodesCount ();
25
+ Assert .assertEquals (2 , nodeCount );
26
+ Assert .assertEquals (2 , bucketsCount );
27
+
28
+ boolean isExist = table .contains (node2 );
29
+ table .touchNode (node2 );
30
+ Assert .assertTrue (isExist );
31
+
32
+ byte [] targetId = Node .getNodeId ();
33
+ List <Node > nodeList = table .getClosestNodes (targetId );
34
+ Assert .assertTrue (nodeList .isEmpty ());
35
+ //Assert.assertTrue(true);
36
+ }
37
+ }
Original file line number Diff line number Diff line change
1
+ package org .tron .common .overlay .discover .table ;
2
+
3
+ import org .junit .Assert ;
4
+ import org .junit .Test ;
5
+ import org .tron .common .overlay .discover .node .Node ;
6
+
7
+ public class TimeComparatorTest {
8
+
9
+ @ Test
10
+ public void test () throws InterruptedException {
11
+ Node node1 = Node .instanceOf ("127.0.0.1:10001" );
12
+ NodeEntry ne1 = new NodeEntry (node1 );
13
+ Thread .sleep (1 );
14
+ Node node2 = Node .instanceOf ("127.0.0.1:10002" );
15
+ NodeEntry ne2 = new NodeEntry (node2 );
16
+ TimeComparator tc = new TimeComparator ();
17
+ int result = tc .compare (ne1 , ne2 );
18
+ Assert .assertEquals (1 , result );
19
+
20
+ }
21
+ }
You can’t perform that action at this time.
0 commit comments