writing logicface...

src/main/java/logicface/LinkService.java

@@ -0,0 +1,160 @@
+package logicface;
+
+import component.LpPacketFragmentId;
+import component.LpPacketFragmentNum;
+import component.LpPacketFragmentSeq;
+import encoding.*;
+import packet.Interest;
+import packet.LpPacket;
+import packet.MINPacket;
+import packet.PacketException;
+import util.ByteHelper;
+
+/*
+ * @Author: Wang Feng
+ * @Description:
+ * @Version: 1.0.0
+ * @Date: 20:31 2021/4/13
+ * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
+ */
+public class LinkService {
+    public ITransport transport;               // 传输通道
+    public LogicFace logicFace=new LogicFace();// LinkService关联的logicFace
+    public int mtu;               // MTU大小
+    public int lpPacketHeadSize;  // lpPacket 编码成数组时的头部大小
+    public long lpPacketId;       // 发送的lpPacket 编码
+
+    /**
+     * 计算lpPacket头部大小
+     */
+    private void calculateLpPacketHeadSize() throws LogicFaceException {
+        try {
+            LpPacket lpPacket=new LpPacket();
+            lpPacket.lpPacketHeader.setLpPacketFragmentId(new LpPacketFragmentId(Long.MAX_VALUE));
+            lpPacket.lpPacketHeader.setLpPacketFragmentSeq(new LpPacketFragmentSeq(Long.MAX_VALUE));
+            lpPacket.lpPacketHeader.setLpPacketFragmentNum(new LpPacketFragmentNum(Long.MAX_VALUE));
+
+            byte[] buf=new byte[Encoder.MaxPacketSize];
+            Encoder encoder=new Encoder();
+            if(!encoder.encoderReset(new SizeT(Encoder.MaxPacketSize+1000),new SizeT(0))){
+                throw new LogicFaceException("LinkService.calculateLpPacketHeadSize: encoderReset error");
+            }
+            this.lpPacketHeadSize = lpPacket.wireEncode(encoder);
+            this.lpPacketHeadSize -= Encoder.MaxPacketSize;
+        } catch (EncoderException | PacketException e) {
+            throw new LogicFaceException("LinkService.calculateLpPacketHeadSize: "+e.getMessage());
+        }
+    }
+
+    /**
+     * 初始化linkService
+     * @param mtu
+     * @throws LogicFaceException
+     */
+    public void init(int mtu) throws LogicFaceException {
+        this.mtu=mtu;
+        this.calculateLpPacketHeadSize();
+        this.lpPacketId=0;
+    }
+
+    /**
+     * 从lpPacket中提取出MINPacket对象
+     * @param lpPacket
+     * @return
+     */
+    private MINPacket getMINPacketFromLpPacket(LpPacket lpPacket) throws LogicFaceException {
+        try {
+            byte[] payload=lpPacket.payload.getValue();
+            Block block=new Block(payload,true);
+
+            MINPacket minPacket=new MINPacket();
+            if(!minPacket.wireDecode(block)){
+                return null;
+            }
+
+            return minPacket;
+        } catch (BlockException | PacketException e) {
+            throw new LogicFaceException("LinkService.getMINPacketFromLpPacket: "+e.getMessage());
+        }
+    }
+
+    /**
+     * 收到lpPacket包的处理函数，该函数被相关联的 transport 的 receive 函数调用
+     * @return
+     */
+    public MINPacket receivePacket() throws LogicFaceException {
+        LpPacket lpPacket=this.transport.receive();
+        // 未分包，只有一个包
+        MINPacket minPacket=this.getMINPacketFromLpPacket(lpPacket);
+        return minPacket;
+    }
+
+    /**
+     * 发送一个lp包分片
+     * @param buf 分片的数据
+     * @param bufLen 数据长度
+     * @param fragmentId  分片号
+     * @param fragmentNum 分片数
+     * @param fragmentSeq 第几块分片，从0开始
+     * @return
+     */
+    private boolean sendFragment(byte[] buf,int bufLen,long fragmentId,long fragmentNum, long fragmentSeq){
+        LpPacket lpPacket=new LpPacket();
+        lpPacket.setId(fragmentId);
+        lpPacket.setFragmentNum(fragmentNum);
+        lpPacket.setFragmentSeq(fragmentSeq);
+        byte[] nbuf=ByteHelper.getLenBytes(buf,0,bufLen);
+        lpPacket.setValue(nbuf);
+        return this.transport.send(lpPacket);
+    }
+
+    /**
+     * 发送指定长度的一段数据，如果数据过长，会调用sendFragment发送多个分片
+     * @param buf
+     * @param bufLen
+     * @return
+     */
+    private boolean sendByteBuffer(byte[] buf,int bufLen){
+        int fragmentLen=this.mtu-this.lpPacketHeadSize-10;
+        int startIndex=0;
+        int fragmentSeq=0;
+        int fragmentNum=bufLen/fragmentLen;
+        if(bufLen%fragmentLen!=0){
+            fragmentNum++;
+        }
+        while (startIndex<bufLen){
+            if(fragmentLen>(bufLen-startIndex)){
+                fragmentLen=bufLen-startIndex;
+            }
+            byte[] nbuf= ByteHelper.getLenBytes(buf,startIndex,fragmentLen);
+            if(!this.sendFragment(nbuf,fragmentLen,this.lpPacketId,fragmentNum,fragmentSeq)){
+                return false;
+            }
+            startIndex+=fragmentLen;
+            fragmentSeq++;
+        }
+        this.lpPacketId++;
+        return true;
+    }
+
+    /**
+     * 发送一个兴趣包
+     * @param interest
+     * @return
+     */
+    public boolean sendInterest(Interest interest) throws LogicFaceException {
+        try {
+            Encoder encoder=new Encoder();
+            if(!encoder.encoderReset(new SizeT(Encoder.MaxPacketSize),new SizeT(0))){
+                return false;
+            }
+            int bufLen=interest.wireEncode(encoder);
+            byte[] buf=encoder.getBuffer();
+            return this.sendByteBuffer(buf,bufLen);
+        } catch (EncoderException | PacketException e) {
+            throw new LogicFaceException("LinkService.sendInterest: "+e.getMessage());
+        }
+    }
+
+    
+}

src/main/java/logicface/LogicFace.java

@@ -0,0 +1,78 @@
+package logicface;
+
+import component.Identifier;
+import packet.MINPacket;
+
+/*
+ * @Author: Wang Feng
+ * @Description: 逻辑接口类
+ * @Version: 1.0.0
+ * @Date: 20:27 2021/4/13
+ * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
+ */
+public class LogicFace {
+    // LogicFaceType区：LogicFace的类型
+    public static final int LogicFaceTypeTCP    = 0;
+    public static final int LogicFaceTypeUDP    = 1;
+    public static final int LogicFaceTypeEther  = 2;
+    public static final int LogicFaceTypeUnix   = 3;
+    public static final int LogicFaceTypeInner  = 4;
+
+    // 成员变量区
+    public int logicFaceType;
+    public ITransport transport;                      // 与logicFace绑定的transport
+    public LinkService linkService; // 与logicFace绑定的linkService
+    public LogicFaceCounters logicFaceCounters=new LogicFaceCounters(); // logicFace 流量统计对象
+    public long expireTime; // 超时时间 ms
+    public boolean state;   //  true 为 up , false 为down
+
+    /**
+     * 通过TCP连接MIR
+     * @param ip MIR的IP地址，如"1.1.12.2"
+     * @param port MIR的TCP端口号，如 13899
+     * @return
+     */
+    public boolean initWithTcp(String ip,String port){
+        return true;
+    }
+
+    /**
+     * 通过UDP连接MIR
+     * @param ip MIR的IP地址，如"1.1.12.2"
+     * @param port MIR的TCP端口号，如 13899
+     * @return
+     */
+    public boolean initWithUdp(String ip,String port){
+        return true;
+    }
+
+    /**
+     * 通过unixSocket连接MIR
+     * @param path MIR的unix socket地址，默认是 "/tmp/mir-sock"
+     * @return
+     */
+    public boolean initWithUnixSocket(String path){
+        return true;
+    }
+
+    /**
+     * 在MIR中注册一个标识，路由指向本客户端
+     * //				（1） 构造一个命令兴趣包， 通过l.SendInterest(interest) 把兴趣包发出去；
+     * //				（2） 等待一个数据包， 如果等待超时，则报错，如果接收到的包不是数据包则报错；
+     * //				（3） 解析收到的数据包，根据数据包中的应答信息判断标识是否注册成功
+     * @param identifier 要添加的路由标识
+     * @param timeout 超时时间，以  毫秒  为单位
+     * @return
+     */
+    public boolean registerIdentifier(Identifier identifier,long timeout){
+        return true;
+    }
+
+    /**
+     * 从 LogicFace 中接收一个网络包
+     * @return 多标识网络包
+     */
+//    public MINPacket ReceivePacket(){
+//        return this.linkService
+//    }
+}

src/main/java/logicface/LogicFaceCounters.java

@@ -0,0 +1,11 @@
+package logicface;
+
+/*
+ * @Author: Wang Feng
+ * @Description:
+ * @Version: 1.0.0
+ * @Date: 20:35 2021/4/13
+ * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
+ */
+public class LogicFaceCounters {
+}

src/main/java/logicface/LogicFaceException.java

@@ -0,0 +1,14 @@
+package logicface;
+
+/*
+ * @Author: hongyu guo
+ * @Description:
+ * @Version: 1.0.0
+ * @Date: 19:38 2021/03/15
+ * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
+ */
+public class LogicFaceException extends Exception{
+    public LogicFaceException(String msg){
+        super("LogicFace."+msg);
+    }
+}

src/main/java/packet/LpPacket.java

@@ -1,8 +1,6 @@
 package packet;
 
-import component.ComponentException;
-import component.LpPacketHeader;
-import component.Payload;
+import component.*;
 import encoding.*;
 
 /*
@@ -24,6 +22,38 @@ public class LpPacket implements IEncodingAble {
         this.payload=payload;
     }
 
+    public void setId(long fragmentId){
+        this.lpPacketHeader.setLpPacketFragmentId(new LpPacketFragmentId(fragmentId));
+    }
+
+    public long getId(){
+        return this.lpPacketHeader.getLpPacketFragmentId().getId();
+    }
+
+    public void setFragmentNum(long fragmentNum){
+        this.lpPacketHeader.setLpPacketFragmentNum(new LpPacketFragmentNum(fragmentNum));
+    }
+
+    public long getFragmentNum(){
+        return this.lpPacketHeader.getLpPacketFragmentNum().getFragmentNum();
+    }
+
+    public void setFragmentSeq(long fragmentSeq){
+        this.lpPacketHeader.setLpPacketFragmentSeq(new LpPacketFragmentSeq(fragmentSeq));
+    }
+
+    public long getFragmentSeq(){
+        return this.lpPacketHeader.getLpPacketFragmentSeq().getFragmentSeq();
+    }
+
+    public void setValue(byte[] value){
+        this.payload.setValue(value);
+    }
+
+    public byte[] getValue(){
+        return this.payload.getValue();
+    }
+
     /**
      * 将 LpPacket 线速编码为一个 TLV
      * @param encoder