mirror of
https://gitee.com/willfree/mlsr.git
synced 2026-10-04 19:42:02 +08:00
110 lines
2.8 KiB
Go
110 lines
2.8 KiB
Go
// Package route
|
|
// @Author: Wang Feng
|
|
// @Description:
|
|
// @Version: 0.1.0
|
|
// @Date: 2022/5/26 10:39
|
|
// @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
|
|
//
|
|
|
|
package route
|
|
|
|
import (
|
|
"fmt"
|
|
"minlib/encoding"
|
|
"testing"
|
|
)
|
|
|
|
//
|
|
// TestConnectingLogicFaceUri_LogicFaceUri
|
|
// @Description: 设置参数
|
|
// @param t
|
|
//
|
|
func TestConnectingLogicFaceUri_LogicFaceUri(t *testing.T) {
|
|
testCPU := ConnectingLogicFaceUri{}
|
|
testCPU.SetLogicFaceUri("url")
|
|
fmt.Println(testCPU.LogicFaceUri())
|
|
}
|
|
|
|
//
|
|
// TestConnectingLogicFaceUri_WireEncode
|
|
// @Description: 测试编码
|
|
// @param t
|
|
//
|
|
func TestConnectingLogicFaceUri_WireEncode(t *testing.T) {
|
|
testCPU := new(ConnectingLogicFaceUri)
|
|
fmt.Println(testCPU.LogicFaceUri())
|
|
testCPU.SetLogicFaceUri("url")
|
|
fmt.Println(testCPU.LogicFaceUri())
|
|
//testCPC.SetTlvType(5)
|
|
fmt.Println(testCPU.Value())
|
|
var encoder encoding.Encoder
|
|
err := encoder.EncoderReset(encoding.MaxPacketSize, 0)
|
|
if err != nil {
|
|
fmt.Println("encoder.EncoderReset() failed", err)
|
|
return
|
|
}
|
|
a, err := testCPU.WireEncode(&encoder)
|
|
if err != nil {
|
|
fmt.Println("ConnectingLogicFaceUri.WireEncode() failed", err)
|
|
return
|
|
}
|
|
fmt.Println(a)
|
|
buf, err := encoder.GetBuffer()
|
|
if err != nil {
|
|
fmt.Println("encoder.GetBuffer() failed", err)
|
|
return
|
|
}
|
|
fmt.Println("interest buf", buf)
|
|
block, err := encoding.CreateBlockByBuffer(buf[:], false)
|
|
if err != nil {
|
|
fmt.Println("encoding.CreateBlockByBuffer() failed", err)
|
|
}
|
|
fmt.Println("interest block", block)
|
|
}
|
|
|
|
//
|
|
// TestConnectingLogicFaceUri_WireDecode
|
|
// @Description: 测试解码
|
|
// @param t
|
|
//
|
|
func TestConnectingLogicFaceUri_WireDecode(t *testing.T) {
|
|
testCPU := new(ConnectingLogicFaceUri)
|
|
fmt.Println("interest", testCPU.Value())
|
|
//testCPC.SetTlvType(5)
|
|
fmt.Println(testCPU.TlvType())
|
|
testCPU.SetLogicFaceUri("url")
|
|
fmt.Println("interest", testCPU.Value())
|
|
fmt.Println("interest", testCPU.IsInitial())
|
|
var encoder encoding.Encoder
|
|
err := encoder.EncoderReset(encoding.MaxPacketSize, 0)
|
|
if err != nil {
|
|
fmt.Println("encoder.EncoderReset() failed", err)
|
|
return
|
|
}
|
|
a, err := testCPU.WireEncode(&encoder)
|
|
if err != nil {
|
|
fmt.Println("ConnectingLogicFaceUri.WireEncode() failed", err)
|
|
}
|
|
fmt.Println(a)
|
|
buf, err := encoder.GetBuffer()
|
|
if err != nil {
|
|
fmt.Println("encoder.GetBuffer() failed:", err)
|
|
return
|
|
}
|
|
fmt.Println("interest buf", buf)
|
|
block, err := encoding.CreateBlockByBuffer(buf[:], false)
|
|
if err != nil {
|
|
fmt.Println("encoding.CreateBlockByBuffer() failed:", err)
|
|
return
|
|
}
|
|
fmt.Println("interest block", block)
|
|
interest1 := new(ConnectingLogicFaceUri)
|
|
err = interest1.WireDecode(block)
|
|
if err != nil {
|
|
fmt.Println("interest1.WireDecode() failed", err)
|
|
return
|
|
}
|
|
fmt.Println("interest1.value: ", interest1.Value())
|
|
fmt.Println("interest1", interest1.IsInitial())
|
|
}
|