From 3f1c1e12e8080f8d27de5493aa5359d0f22e6556 Mon Sep 17 00:00:00 2001 From: zhaofeng233 Date: Mon, 29 Mar 2021 14:05:38 +0800 Subject: [PATCH] =?UTF-8?q?component=E9=83=A8=E5=88=86=E6=96=B9=E6=B3=95?= =?UTF-8?q?=E6=B5=8B=E8=AF=95=EF=BC=8C=E5=87=BA=E7=8E=B0=E9=A6=96=E4=B8=AA?= =?UTF-8?q?byte=E4=B8=BA=E8=B4=9F=E6=95=B0=E7=9A=84=E6=83=85=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/test/java/component/CanBePrefixTest.java | 69 ++++++++++++++++ .../java/component/CongestionMarkTest.java | 68 ++++++++++++++++ .../java/component/FreshnessPeriodTest.java | 67 +++++++++++++++ src/test/java/component/HopLimitTest.java | 67 +++++++++++++++ .../java/component/MustBeRefreshTest.java | 81 +++++++++++++++++++ src/test/java/component/NonceTest.java | 74 +++++++++++++++++ src/test/java/component/TTLTest.java | 63 +++++++++++++++ 7 files changed, 489 insertions(+) create mode 100644 src/test/java/component/CanBePrefixTest.java create mode 100644 src/test/java/component/CongestionMarkTest.java create mode 100644 src/test/java/component/FreshnessPeriodTest.java create mode 100644 src/test/java/component/HopLimitTest.java create mode 100644 src/test/java/component/MustBeRefreshTest.java create mode 100644 src/test/java/component/NonceTest.java create mode 100644 src/test/java/component/TTLTest.java 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); + } +}