diff --git a/src/test/java/component/CanBePrefixTest.java b/src/test/java/component/CanBePrefixTest.java new file mode 100644 index 0000000..fd54c1d --- /dev/null +++ b/src/test/java/component/CanBePrefixTest.java @@ -0,0 +1,69 @@ +package component; + + +import encoding.*; +import org.junit.Test; +import packet.Interest; +import packet.PacketException; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 15:25 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class CanBePrefixTest { + + int MaxPacketSize = 8800; + + @Test + public void TestCanBePrefix_GetCanBePrefix() { + CanBePrefix can = new CanBePrefix(); +// System.out.println(can.getCanBePrefix()); + assertFalse(can.getCanBePrefix()); + can.setCanBePrefix(true); +// System.out.println(can.getCanBePrefix()); +// System.out.println(can.isInitial()); + assertEquals(can.getCanBePrefix(),can.isInitial()); + } + + @Test + public void TestCanBePrefix_WireEncode() throws ComponentException, BlockException, EncoderException { + CanBePrefix can = new CanBePrefix(); + assertFalse(can.getCanBePrefix()); + can.setCanBePrefix(true); + assertEquals(can.getCanBePrefix(),can.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + can.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println(buf); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println(block); + } + + @Test + public void TestCanBePrefix_WireDecode() throws EncoderException, ComponentException, BlockException, PacketException { + CanBePrefix can = new CanBePrefix(); + assertFalse(can.getCanBePrefix()); + can.setCanBePrefix(true); + assertEquals(can.getCanBePrefix(),can.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + can.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("interest buf:"+buf); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("interest block:"+block); + + InterestLifeTime interest1 = new InterestLifeTime(); + interest1.wireDecode(block); + System.out.println("interest1:"+can.getCanBePrefix()); + System.out.println("interest1:"+can.isInitial()); + } +} diff --git a/src/test/java/component/CongestionMarkTest.java b/src/test/java/component/CongestionMarkTest.java new file mode 100644 index 0000000..3573f27 --- /dev/null +++ b/src/test/java/component/CongestionMarkTest.java @@ -0,0 +1,68 @@ +package component; + +import encoding.*; +import org.junit.Test; +import packet.Interest; +import packet.PacketException; + +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 15:47 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ + +public class CongestionMarkTest { + int MaxPacketSize = 8800; + @Test + public void TestCongestionMark_GetCongestionLevel() { + CongestionMark congestionMark = new CongestionMark(); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + congestionMark.setCongestionLevel(1248355635356896986L); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + System.out.println("interest:"+congestionMark.isInitial()); + } + + @Test + public void TestCongestionMark_WireEncode() throws EncoderException, ComponentException, BlockException { + CongestionMark congestionMark = new CongestionMark(); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + congestionMark.setCongestionLevel(1248355635356896986L); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + System.out.println("interest:"+congestionMark.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + congestionMark.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("CongestionMark buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("CongestionMark block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + } + + @Test + public void TestCongestionMark_WireDecode() throws EncoderException, ComponentException, BlockException, PacketException { + CongestionMark congestionMark = new CongestionMark(); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + congestionMark.setCongestionLevel(1248355635356896986L); + System.out.println("interest:"+congestionMark.getCongestionLevel()); + System.out.println("interest:"+congestionMark.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + congestionMark.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("CongestionMark buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("CongestionMark block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + InterestLifeTime interest1 = new InterestLifeTime(); + interest1.wireDecode(block); + System.out.println("interest1:" + congestionMark.getCongestionLevel()); + System.out.println("interest1:" + congestionMark.isInitial()); + } +} diff --git a/src/test/java/component/FreshnessPeriodTest.java b/src/test/java/component/FreshnessPeriodTest.java new file mode 100644 index 0000000..9adabb3 --- /dev/null +++ b/src/test/java/component/FreshnessPeriodTest.java @@ -0,0 +1,67 @@ +package component; + +import encoding.*; +import org.junit.Test; + +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 16:07 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ + +public class FreshnessPeriodTest { + int MaxPacketSize = 8800; + @Test + public void getFreshnessPeriod() { + FreshnessPeriod fresh = new FreshnessPeriod(); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + fresh.setFreshnessPeriod(1234848876468746468L); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + System.out.println("interest:"+fresh.isInitial()); + } + + @Test + public void TestFreshnessPeriod_WireEncode() throws EncoderException, ComponentException, BlockException { + FreshnessPeriod fresh = new FreshnessPeriod(); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + fresh.setFreshnessPeriod(1234848876468746468L); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + System.out.println("interest:"+fresh.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + fresh.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("FreshnessPeriod buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("FreshnessPeriod block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + } + + @Test + public void TestFreshnessPeriod_WireDecode() throws EncoderException, ComponentException, BlockException { + FreshnessPeriod fresh = new FreshnessPeriod(); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + fresh.setFreshnessPeriod(1234848876468746468L); + System.out.println("interest:"+fresh.getFreshnessPeriod()); + System.out.println("interest:"+fresh.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + fresh.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("FreshnessPeriod buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("FreshnessPeriod block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + + InterestLifeTime interest1 = new InterestLifeTime(); + interest1.wireDecode(block); + System.out.println("interest1:"+fresh.getFreshnessPeriod()); + System.out.println("interest1:"+fresh.isInitial()); + } +} diff --git a/src/test/java/component/HopLimitTest.java b/src/test/java/component/HopLimitTest.java new file mode 100644 index 0000000..5e8f277 --- /dev/null +++ b/src/test/java/component/HopLimitTest.java @@ -0,0 +1,67 @@ +package component; + +import encoding.*; +import org.junit.Test; + +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 16:09 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ + +public class HopLimitTest { + int MaxPacketSize = 8800; + @Test + public void TestHopLimit_GetHopLimit() { + HopLimit hop = new HopLimit(); + System.out.println("interest；"+hop.getHopLimit()); + hop.setHopLimit(1234848876468746468L); + assertEquals(hop.getHopLimit(),1234848876468746468L); + assertTrue(hop.isInitial()); + } + + @Test + public void TestHopLimit_WireEncode() throws ComponentException, EncoderException, BlockException { + HopLimit hop = new HopLimit(); + System.out.println("interest；"+hop.getHopLimit()); + hop.setHopLimit(1234848876468746468L); + assertEquals(hop.getHopLimit(),1234848876468746468L); + assertTrue(hop.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + hop.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("HopLimit buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("HopLimit block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + } + + @Test + public void TestHopLimit_WireDecode() throws EncoderException, ComponentException, BlockException { + HopLimit hop = new HopLimit(); + System.out.println("interest；"+hop.getHopLimit()); + hop.setHopLimit(1234848876468746468L); + assertEquals(hop.getHopLimit(),1234848876468746468L); + assertTrue(hop.isInitial()); + + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + hop.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("HopLimit buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("HopLimit block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + + InterestLifeTime interest1 = new InterestLifeTime(); + interest1.wireDecode(block); + System.out.println("interest1: "+hop.getHopLimit()); + System.out.println("interest1: "+hop.isInitial()); + } +} diff --git a/src/test/java/component/MustBeRefreshTest.java b/src/test/java/component/MustBeRefreshTest.java new file mode 100644 index 0000000..4b5d05e --- /dev/null +++ b/src/test/java/component/MustBeRefreshTest.java @@ -0,0 +1,81 @@ +package component; +import encoding.*; +import org.junit.Test; + +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 16:09 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ + +public class MustBeRefreshTest { + int MaxPacketSize = 8800; + @Test + public void TestMustBeRefresh_GetMustBeRefresh(){ + MustBeRefresh must = new MustBeRefresh(); + assertFalse(must.getMustBeRefresh()); + } + + @Test + public void TestMustBeRefresh_SetMustBeRefresh(){ + MustBeRefresh must = new MustBeRefresh(); + assertFalse(must.getMustBeRefresh()); + must.setMustBeRefresh(true); + assertTrue(must.getMustBeRefresh()); + must.setMustBeRefresh(false); + assertFalse(must.getMustBeRefresh()); + } + + @Test + public void TestMustBeRefresh_WireEncode() throws EncoderException, ComponentException { + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + MustBeRefresh must = new MustBeRefresh(); + + must.setMustBeRefresh(true); + must.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("MustBeRefresh buf:"+ Arrays.toString(buf)); + + must.setMustBeRefresh(false); + must.wireEncode(encoder); + byte[] buf1 = encoder.getBuffer(); + System.out.println("MustBeRefresh buf1"+Arrays.toString(buf1)); + assertArrayEquals(buf1,buf); + +// must.setMustBeRefresh(true); +// must.wireEncode(encoder); +// byte[] buf2 = encoder.getBuffer(); +// System.out.println("buf2"+buf2); +// assertArrayEquals(buf2,buf); + } + + @Test + public void TestMustBeRefresh_WireDecode() throws EncoderException, ComponentException, BlockException { + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + MustBeRefresh must = new MustBeRefresh(); + + must.setMustBeRefresh(true); + must.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("buf"+buf); + + must.setMustBeRefresh(false); + must.wireEncode(encoder); + buf = encoder.getBuffer(); + System.out.println("buf"+buf); + + Block block = Block.createBlockByBuffer(buf, false); + MustBeRefresh must1 = new MustBeRefresh(); + must1.wireDecode(block); + System.out.println("must1:"+must1.getMustBeRefresh()+must1.isInitial()); + } + +} diff --git a/src/test/java/component/NonceTest.java b/src/test/java/component/NonceTest.java new file mode 100644 index 0000000..935b0f1 --- /dev/null +++ b/src/test/java/component/NonceTest.java @@ -0,0 +1,74 @@ +package component; + +import encoding.*; +import org.junit.Test; + +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 16:09 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class NonceTest { + int MaxPacketSize = 8800; + @Test + public void TestNonce_GetNonce() { + } + + @Test + public void TestNonce_SetNonce() { + Nonce nonce = new Nonce(); +// nonce.setNonce(18446744073709551615L); + nonce.setNonce(0); + System.out.println("nonce:"+nonce.getNonce()); + } + + @Test + public void TestNonce_RefreshNonce() { + Nonce nonce = new Nonce(); + nonce.setNonce(1844674407370955161L); + nonce.setNonce(0); + System.out.println("nonce:"+nonce.getNonce()); + nonce.refreshNonce();; + for (int i = 0; i < 5; i++) { + nonce.refreshNonce();; + System.out.println("nonce"+nonce.getNonce()); + } + } + + @Test + public void TestNonce_WireEncode() throws EncoderException, ComponentException { + Nonce nonce = new Nonce(); + nonce.refreshNonce(); + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + int n = nonce.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println(n); + System.out.println("Nonce buf:"+ Arrays.toString(buf)); + } + + @Test + public void TestNonce_WireDecode() throws EncoderException, ComponentException, BlockException { + Nonce nonce = new Nonce(); + nonce.refreshNonce(); + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + int n = nonce.wireEncode(encoder); + System.out.println("nonce:"+n); + byte[] buf = encoder.getBuffer(); + System.out.println("Nonce buf:"+ Arrays.toString(buf)); + + Block block = Block.createBlockByBuffer(buf, false); + boolean err = nonce.wireDecode(block); + System.out.println("Nonce block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); +// System.out.println("nonce1:"+nonce); + System.out.println(err); + + } +} diff --git a/src/test/java/component/TTLTest.java b/src/test/java/component/TTLTest.java new file mode 100644 index 0000000..ea09803 --- /dev/null +++ b/src/test/java/component/TTLTest.java @@ -0,0 +1,63 @@ +package component; + +import encoding.*; +import org.junit.Test; + +import java.sql.Array; +import java.util.Arrays; + +import static org.junit.Assert.*; + +/* + * @Author: feng Zhao + * @Description: + * @Version: 1.0.0 + * @Date: 14:32 2021/3/25 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class TTLTest { + + int MaxPacketSize = 8800; + + @Test + public void TestCreateTTLByBlock() throws EncoderException, ComponentException, BlockException { + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + TTL ttl = new TTL(); + ttl.setTtl(15346343413545L); + ttl.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + Block block = Block.createBlockByBuffer(buf, false); + TTL newttl = new TTL(); + newttl.buildTTLByBlock(block); + assertEquals(newttl.ttl(),15346343413545L); + } + + @Test + public void TestTTL_WireEncode() throws EncoderException, ComponentException, BlockException { + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + TTL ttl = new TTL(); + ttl.setTtl(15346343413545L); + ttl.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + Block block = Block.createBlockByBuffer(buf, false); + System.out.println("TTL buf:"+ Arrays.toString(buf)); + System.out.println("TTL block: "+block.getType()+","+block.getLength()+","+Arrays.toString(block.getValue())); + } + + @Test + public void TestTTL_WireDecode() throws EncoderException, ComponentException, BlockException { + Encoder encoder = new Encoder(); + encoder.encoderReset(new SizeT(MaxPacketSize), new SizeT(0)); + TTL ttl = new TTL(); + ttl.setTtl(15346343413545L); + ttl.wireEncode(encoder); + byte[] buf = encoder.getBuffer(); + System.out.println("TTL buf:"+ Arrays.toString(buf)); + Block block = Block.createBlockByBuffer(buf, false); + TTL newttl1 = new TTL(); + newttl1.wireDecode(block); + assertEquals(newttl1.ttl(),15346343413545L); + } +}