From 0166bf38ac56350efbf5baff53e711ed7cad4a43 Mon Sep 17 00:00:00 2001 From: free will <2647778488@qq.com> Date: Tue, 13 Apr 2021 17:04:47 +0800 Subject: [PATCH] add mgmt: ControlParameters --- src/main/java/component/Identifier.java | 83 ------ .../IdentifierComponentContainer.java | 94 +++++++ src/main/java/component/SignatureField.java | 3 +- src/main/java/encoding/IEncodingAble.java | 5 +- src/main/java/mgmt/ControlParameters.java | 258 ++++++++++++++++-- src/main/java/mgmt/MgmtException.java | 14 + 6 files changed, 350 insertions(+), 107 deletions(-) create mode 100644 src/main/java/component/IdentifierComponentContainer.java create mode 100644 src/main/java/mgmt/MgmtException.java diff --git a/src/main/java/component/Identifier.java b/src/main/java/component/Identifier.java index 227a0d7..188222a 100644 --- a/src/main/java/component/Identifier.java +++ b/src/main/java/component/Identifier.java @@ -17,89 +17,6 @@ import java.util.List; * @Date: 17:34 2021/3/10 * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 */ -class IdentifierComponentContainer { - private List identifierComponents=new LinkedList<>(); - - public IdentifierComponentContainer() { - } - - /** - * 获取所有名称组件 - * - * @return - */ - public List getElements() { - return identifierComponents; - } - - /** - * 组件个数 - * - * @return - */ - public int length() { - return identifierComponents.size(); - } - - /** - * 清空组件 - */ - public void clear() { - identifierComponents.clear(); - } - - /** - * 添加一个组件 - * - * @param identifierComponent - */ - public void addElement(IdentifierComponent identifierComponent) { - identifierComponents.add(identifierComponent); - } - - /** - * 获取指定索引位置的组件 - * - * @param index - * @return - */ - public IdentifierComponent getElement(int index) throws ComponentException { - if (index >= this.length()) { - throw new ComponentException("IdentifierComponents.getElement: index is out of bound."); - } - return this.identifierComponents.get(index); - } - - /** - * 获取前 num 个名称组件构成的标识 - * - * @param num - * @return - */ - public IdentifierComponentContainer getPrefix(int num) throws ComponentException { - if (num > this.length()) { - return null; - } - IdentifierComponentContainer identifierComponentContainer = new IdentifierComponentContainer(); - for (int i = 0; i < num; i++) { - identifierComponentContainer.addElement(this.getElement(i)); - } - return identifierComponentContainer; - } - - public IdentifierComponentContainer getSubIdentifierContainer(int startIndex, int num) throws ComponentException { - if ((startIndex + num) > this.length()) { - return null; - } - - IdentifierComponentContainer identifierComponentContainer = new IdentifierComponentContainer(); - for (int i = startIndex; i < startIndex + num; i++) { - identifierComponentContainer.addElement(this.getElement(i)); - } - return identifierComponentContainer; - } -} - public class Identifier implements TlvComponentBase, IEncodingAble { private IdentifierComponentContainer components=new IdentifierComponentContainer(); diff --git a/src/main/java/component/IdentifierComponentContainer.java b/src/main/java/component/IdentifierComponentContainer.java new file mode 100644 index 0000000..2e92726 --- /dev/null +++ b/src/main/java/component/IdentifierComponentContainer.java @@ -0,0 +1,94 @@ +package component; + +import java.util.LinkedList; +import java.util.List; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 16:55 2021/4/13 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class IdentifierComponentContainer { + private List identifierComponents = new LinkedList<>(); + + public IdentifierComponentContainer() { + } + + /** + * 获取所有名称组件 + * + * @return + */ + public List getElements() { + return identifierComponents; + } + + /** + * 组件个数 + * + * @return + */ + public int length() { + return identifierComponents.size(); + } + + /** + * 清空组件 + */ + public void clear() { + identifierComponents.clear(); + } + + /** + * 添加一个组件 + * + * @param identifierComponent + */ + public void addElement(IdentifierComponent identifierComponent) { + identifierComponents.add(identifierComponent); + } + + /** + * 获取指定索引位置的组件 + * + * @param index + * @return + */ + public IdentifierComponent getElement(int index) throws ComponentException { + if (index >= this.length()) { + throw new ComponentException("IdentifierComponents.getElement: index is out of bound."); + } + return this.identifierComponents.get(index); + } + + /** + * 获取前 num 个名称组件构成的标识 + * + * @param num + * @return + */ + public component.IdentifierComponentContainer getPrefix(int num) throws ComponentException { + if (num > this.length()) { + return null; + } + component.IdentifierComponentContainer identifierComponentContainer = new component.IdentifierComponentContainer(); + for (int i = 0; i < num; i++) { + identifierComponentContainer.addElement(this.getElement(i)); + } + return identifierComponentContainer; + } + + public component.IdentifierComponentContainer getSubIdentifierContainer(int startIndex, int num) throws ComponentException { + if ((startIndex + num) > this.length()) { + return null; + } + + component.IdentifierComponentContainer identifierComponentContainer = new component.IdentifierComponentContainer(); + for (int i = startIndex; i < startIndex + num; i++) { + identifierComponentContainer.addElement(this.getElement(i)); + } + return identifierComponentContainer; + } +} diff --git a/src/main/java/component/SignatureField.java b/src/main/java/component/SignatureField.java index e319c46..83d603a 100644 --- a/src/main/java/component/SignatureField.java +++ b/src/main/java/component/SignatureField.java @@ -189,8 +189,7 @@ public class SignatureField implements TlvComponentBase, IEncodingAble { // 解析每一个签名 for (int i = 0; i < subElementNum; i += 2) { // 第奇数个子 TLV 解析为 SignatureInfo - SignatureInfo signatureInfo = null; - signatureInfo = new SignatureInfo(subElements.getBlock(i)); + SignatureInfo signatureInfo = new SignatureInfo(subElements.getBlock(i)); // 第偶数个子 TLV 解析为 SignatureValue SignatureValue signatureValue = new SignatureValue(subElements.getBlock(i + 1)); // 构造Signature diff --git a/src/main/java/encoding/IEncodingAble.java b/src/main/java/encoding/IEncodingAble.java index b4b915a..3c808f6 100644 --- a/src/main/java/encoding/IEncodingAble.java +++ b/src/main/java/encoding/IEncodingAble.java @@ -1,6 +1,7 @@ package encoding; import component.ComponentException; +import mgmt.MgmtException; import packet.PacketException; /* @@ -18,13 +19,13 @@ public interface IEncodingAble { * @param encoder * @return */ - public int wireEncode(Encoder encoder) throws ComponentException, PacketException; + public int wireEncode(Encoder encoder) throws ComponentException, PacketException, MgmtException; /** * 线速解码，将一个TLV解码成一个网络包 * @param block * @return */ - public boolean wireDecode(Block block) throws ComponentException, PacketException; + public boolean wireDecode(Block block) throws ComponentException, PacketException, MgmtException; } diff --git a/src/main/java/mgmt/ControlParameters.java b/src/main/java/mgmt/ControlParameters.java index f24531e..49e7082 100644 --- a/src/main/java/mgmt/ControlParameters.java +++ b/src/main/java/mgmt/ControlParameters.java @@ -1,10 +1,8 @@ package mgmt; import component.*; -import encoding.Block; -import encoding.Encoder; -import encoding.IEncodingAble; -import packet.PacketException; +import encoding.*; +import packet.Interest; /* * @Author: Wang Feng @@ -15,26 +13,246 @@ import packet.PacketException; */ public class ControlParameters implements IEncodingAble { // fib add 必须字段 - public ControlParameterPrefix controlParameterPrefix =new ControlParameterPrefix(); // 前缀标识 - public ControlParameterLogicFaceId controlParameterLogicFaceId=new ControlParameterLogicFaceId(); // 逻辑faceId - public ControlParameterCost controlParameterCost=new ControlParameterCost(); // 链路代价 - public ControlParameterCapacity controlParameterCapacity =new ControlParameterCapacity(); // CS 容量 - public ControlParameterCount controlParameterCount=new ControlParameterCount(); // 需要删除的cs表项数 - public ControlParameterExpireTime controlParameterExpireTime=new ControlParameterExpireTime(); // 超时时间 - public ControlParameterUri controlParameterUri=new ControlParameterUri(); // 远端地址 - public ControlParameterLocalUri controlParameterLocalUri=new ControlParameterLocalUri(); // 本地地址 - public ControlParameterLogicFacePersistency controlParameterLogicFacePersistency=new ControlParameterLogicFacePersistency(); // 逻辑接口持久性 - public ControlParameterUriScheme controlParameterUriScheme=new ControlParameterUriScheme(); // 逻辑地址模式 - public ControlParameterMtu controlParameterMtu=new ControlParameterMtu(); // MTU - + public ControlParameterPrefix controlParameterPrefix = new ControlParameterPrefix(); // 前缀标识 + public ControlParameterLogicFaceId controlParameterLogicFaceId = new ControlParameterLogicFaceId(); // 逻辑faceId + public ControlParameterCost controlParameterCost = new ControlParameterCost(); // 链路代价 + public ControlParameterCapacity controlParameterCapacity = new ControlParameterCapacity(); // CS 容量 + public ControlParameterCount controlParameterCount = new ControlParameterCount(); // 需要删除的cs表项数 + public ControlParameterExpireTime controlParameterExpireTime = new ControlParameterExpireTime(); // 超时时间 + public ControlParameterUri controlParameterUri = new ControlParameterUri(); // 远端地址 + public ControlParameterLocalUri controlParameterLocalUri = new ControlParameterLocalUri(); // 本地地址 + public ControlParameterLogicFacePersistency controlParameterLogicFacePersistency = new ControlParameterLogicFacePersistency(); // 逻辑接口持久性 + public ControlParameterUriScheme controlParameterUriScheme = new ControlParameterUriScheme(); // 逻辑地址模式 + public ControlParameterMtu controlParameterMtu = new ControlParameterMtu(); // MTU + /** + * 将 ControlParameters 编码成一个 TLV + * + * @param encoder + * @return + * @throws MgmtException + */ @Override - public int wireEncode(Encoder encoder) throws ComponentException, PacketException { - return 0; + public int wireEncode(Encoder encoder) throws MgmtException { + try { + int totalLength = 0; + + // 编码 TLV-VALUE + if (this.controlParameterPrefix.isInitial()) { + int tmpLen = this.controlParameterPrefix.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterLogicFaceId.isInitial()) { + int tmpLen = this.controlParameterLogicFaceId.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterCost.isInitial()) { + int tmpLen = this.controlParameterCost.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterCapacity.isInitial()) { + int tmpLen = this.controlParameterCapacity.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterCount.isInitial()) { + int tmpLen = this.controlParameterCount.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterExpireTime.isInitial()) { + int tmpLen = this.controlParameterExpireTime.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterUri.isInitial()) { + int tmpLen = this.controlParameterUri.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterLocalUri.isInitial()) { + int tmpLen = this.controlParameterLocalUri.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterLogicFacePersistency.isInitial()) { + int tmpLen = this.controlParameterLogicFacePersistency.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterUriScheme.isInitial()) { + int tmpLen = this.controlParameterUriScheme.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + if (this.controlParameterMtu.isInitial()) { + int tmpLen = this.controlParameterMtu.wireEncode(encoder); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + } + + // 编码 TLV-LENGTH + int tmpLen = encoder.prependVarNumber(new VlInt(totalLength)); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + + // 编码 TLV-TYPE + tmpLen = encoder.prependVarNumber(new VlInt(TLV.TlvManagementControlParameters)); + if (tmpLen < 0) { + return -1; + } + totalLength += tmpLen; + + return totalLength; + } catch (ComponentException | EncoderException e) { + throw new MgmtException("ControlParameters.wireEncode" + e.getMessage()); + } } + /** + * 从 TLV Block 中解码出一个 ControlParameters + * + * @param block + * @return + */ @Override - public boolean wireDecode(Block block) throws ComponentException, PacketException { - return false; + public boolean wireDecode(Block block) throws MgmtException { + try { + // 检查 Type 是否正确 + if (!TLV.expectType(block.getType(), new VlInt(TLV.TlvManagementControlParameters))) { + return false; + } + + // 首先解析子 Block + if (!block.parseSubElements()) { + return false; + } + + // 提取参数 + ElementContainer elementContainer = block.getSubElements(); + int len = elementContainer.length(); + for (int i = 0; i < len; i++) { + Block newBlock = elementContainer.getBlock(i); + int type = newBlock.getType().getVlIntValue2Int(); + switch (type) { + case TLV.TlvManagementPrefix: + if (!this.controlParameterPrefix.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementCost: + if (!this.controlParameterCost.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementCapacity: + if (!this.controlParameterCapacity.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementCount: + if (!this.controlParameterCount.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementExpireTime: + if (!this.controlParameterExpireTime.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementUri: + if (!this.controlParameterUri.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementLocalUri: + if (!this.controlParameterLocalUri.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementLogicFacePersistency: + if (!this.controlParameterLogicFacePersistency.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementUriScheme: + if (!this.controlParameterUriScheme.wireDecode(newBlock)) { + return false; + } + break; + case TLV.TlvManagementMtu: + if (!this.controlParameterMtu.wireDecode(newBlock)) { + return false; + } + break; + } + } + + return true; + } catch (BlockException | VlIntException | ComponentException e) { + throw new MgmtException("ControlParameters.wireDecode: " + e.getMessage()); + } + } + + public boolean parse(Interest interest) throws MgmtException { + try { + if (interest == null) { + return false; + } + Identifier identifier = interest.getName(); + IdentifierComponentContainer components = identifier.getComponents(); + int len = components.length(); + if (len < 3) { + return false; + } + // 没有分片 最后一个就是控制参数 + if (components.getElement(len - 1).isByteArray()){ + Block block=new Block(components.getElement(len-1).getByteArray(),true); + if(!this.wireDecode(block)){ + return false; + } + }else if (components.getElement(len - 1).isFragmentNumber() + && components.getElement(len - 2).isVersionNumber() + && components.getElement(len - 3).isByteArray()){ + //如果最后一位是分片号 倒数第二位是版本号 倒数第三位是控制参数 + Block block=new Block(components.getElement(len-3).getByteArray(),true); + if(!this.wireDecode(block)){ + return false; + } + }else{ + return false; + } + + return true; + } catch (ComponentException | BlockException e) { + throw new MgmtException("ControlParameters.parse: " + e.getMessage()); + } } } diff --git a/src/main/java/mgmt/MgmtException.java b/src/main/java/mgmt/MgmtException.java new file mode 100644 index 0000000..b78636d --- /dev/null +++ b/src/main/java/mgmt/MgmtException.java @@ -0,0 +1,14 @@ +package mgmt; + +/* + * @Author: hongyu guo + * @Description: + * @Version: 1.0.0 + * @Date: 19:38 2021/03/15 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class MgmtException extends Exception{ + public MgmtException(String msg){ + super("Mgmt."+msg); + } +}