mirror of https://github.com/vishvananda/netlink
38 lines
760 B
Go
38 lines
760 B
Go
|
package netlink
|
||
|
|
|
||
|
|
import (
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/vishvananda/netlink/nl"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestXfrmMonitorExpire(t *testing.T) {
|
||
|
|
setUpNetlinkTest(t)()
|
||
|
|
|
||
|
|
ch := make(chan XfrmMsg)
|
||
|
|
done := make(chan struct{})
|
||
|
|
defer close(done)
|
||
|
|
errChan := make(chan error)
|
||
|
|
if err := XfrmMonitor(ch, nil, errChan, nl.XFRM_MSG_EXPIRE); err != nil {
|
||
|
|
t.Fatal(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
// Program state with limits
|
||
|
|
state := getBaseState()
|
||
|
|
state.Limits.TimeHard = 2
|
||
|
|
state.Limits.TimeSoft = 1
|
||
|
|
if err := XfrmStateAdd(state); err != nil {
|
||
|
|
t.Fatal(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
msg := (<-ch).(*XfrmMsgExpire)
|
||
|
|
if msg.XfrmState.Spi != state.Spi || msg.Hard {
|
||
|
|
t.Fatal("Received unexpected msg")
|
||
|
|
}
|
||
|
|
|
||
|
|
msg = (<-ch).(*XfrmMsgExpire)
|
||
|
|
if msg.XfrmState.Spi != state.Spi || !msg.Hard {
|
||
|
|
t.Fatal("Received unexpected msg")
|
||
|
|
}
|
||
|
|
}
|