Skip to content

Commit fda0d4c

Browse files
authored
Merge pull request tronprotocol#2709 from chengtx01/new_test
unit test about network discover table
2 parents bbf6a93 + 846f6d1 commit fda0d4c

File tree

3 files changed

+87
-0
lines changed

3 files changed

+87
-0
lines changed
Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
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+
@Test
9+
public void test() throws InterruptedException {
10+
Node node1 = Node.instanceOf("127.0.0.1:10001");
11+
NodeEntry nodeEntry = new NodeEntry(node1);
12+
int distance = nodeEntry.getDistance();
13+
Assert.assertEquals(-256, distance);
14+
15+
long lastModified = nodeEntry.getModified();
16+
//System.out.println(lastModified);
17+
Thread.sleep(1);
18+
nodeEntry.touch();
19+
long nowModified = nodeEntry.getModified();
20+
//System.out.println(nowModified);
21+
Assert.assertNotEquals(lastModified, nowModified);
22+
23+
Node node2 = Node.instanceOf("127.0.0.1:10002");
24+
NodeEntry nodeEntry2 = new NodeEntry(node2);
25+
boolean isDif = nodeEntry.equals(nodeEntry2);
26+
Assert.assertTrue(isDif);
27+
}
28+
29+
}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
package org.tron.common.overlay.discover.table;
2+
3+
import java.util.List;
4+
import org.junit.Assert;
5+
import org.junit.Test;
6+
import org.tron.common.overlay.discover.node.Node;
7+
8+
public class NodeTableTest {
9+
@Test
10+
public void test() {
11+
Node node1 = Node.instanceOf("127.0.0.1:10002");
12+
13+
NodeTable table = new NodeTable(node1);
14+
Node nodeTemp = table.getNode();
15+
Assert.assertEquals(10002, nodeTemp.getPort());
16+
Assert.assertEquals(0, table.getNodesCount());
17+
Assert.assertEquals(0, table.getBucketsCount());
18+
19+
Node node2 = Node.instanceOf("127.0.0.1:10003");
20+
Node node3 = Node.instanceOf("127.0.0.2:10004");
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+
}
Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
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+
}

0 commit comments

Comments
 (0)