RepoMirrors/netlink
1
0
Fork 0
mirror of https://github.com/vishvananda/netlink synced 2025-02-13 10:37:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add TestTcTbfQoptDeserializeSerialize

Browse Source
This commit is contained in:
chantra 2015-09-11 12:51:40 -07:00
parent ac253c54c7
commit 8ef4616a76
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
nl/tc_linux_test.go
View File

@ -7,6 +7,7 @@ import (
"testing" "testing"
) )
/* TcMsg */
func (msg *TcMsg) write(b []byte) { func (msg *TcMsg) write(b []byte) {
native := NativeEndian() native := NativeEndian()
b[0] = msg.Family b[0] = msg.Family
@ -38,6 +39,7 @@ func TestTcMsgDeserializeSerialize(t *testing.T) {
testDeserializeSerialize(t, orig, safemsg, msg) testDeserializeSerialize(t, orig, safemsg, msg)
} }
/* TcActionMsg */
func (msg *TcActionMsg) write(b []byte) { func (msg *TcActionMsg) write(b []byte) {
b[0] = msg.Family b[0] = msg.Family
copy(b[1:4], msg.Pad[:]) copy(b[1:4], msg.Pad[:])
@ -64,6 +66,7 @@ func TestTcActionMsgDeserializeSerialize(t *testing.T) {
testDeserializeSerialize(t, orig, safemsg, msg) testDeserializeSerialize(t, orig, safemsg, msg)
} }
/* TcRateSpec */
func (msg *TcRateSpec) write(b []byte) { func (msg *TcRateSpec) write(b []byte) {
native := NativeEndian() native := NativeEndian()
b[0] = msg.CellLog b[0] = msg.CellLog
@ -94,3 +97,38 @@ func TestTcRateSpecDeserializeSerialize(t *testing.T) {
msg := DeserializeTcRateSpec(orig) msg := DeserializeTcRateSpec(orig)
testDeserializeSerialize(t, orig, safemsg, msg) testDeserializeSerialize(t, orig, safemsg, msg)
} }
/* TcTbfQopt */
func (msg *TcTbfQopt) write(b []byte) {
native := NativeEndian()
msg.Rate.write(b[0:SizeofTcRateSpec])
start := SizeofTcRateSpec
msg.Peakrate.write(b[start : start+SizeofTcRateSpec])
start += SizeofTcRateSpec
native.PutUint32(b[start:start+4], msg.Limit)
start += 4
native.PutUint32(b[start:start+4], msg.Buffer)
start += 4
native.PutUint32(b[start:start+4], msg.Mtu)
}
func (msg *TcTbfQopt) serializeSafe() []byte {
length := SizeofTcTbfQopt
b := make([]byte, length)
msg.write(b)
return b
}
func deserializeTcTbfQoptSafe(b []byte) *TcTbfQopt {
var msg = TcTbfQopt{}
binary.Read(bytes.NewReader(b[0:SizeofTcTbfQopt]), NativeEndian(), &msg)
return &msg
}
func TestTcTbfQoptDeserializeSerialize(t *testing.T) {
var orig = make([]byte, SizeofTcTbfQopt)
rand.Read(orig)
safemsg := deserializeTcTbfQoptSafe(orig)
msg := DeserializeTcTbfQopt(orig)
testDeserializeSerialize(t, orig, safemsg, msg)
}