新TAP测试(TODO 解析arp)
This commit is contained in:
parent
1a3c9baba1
commit
3c5bad2f67
|
@ -95,7 +95,7 @@ func (cli *RPCClient) run() {
|
||||||
defer stream.CloseSend()
|
defer stream.CloseSend()
|
||||||
|
|
||||||
var ticker = time.NewTicker(time.Millisecond * 20)
|
var ticker = time.NewTicker(time.Millisecond * 20)
|
||||||
var frames [][]byte
|
|
||||||
buf := bytes.NewBuffer(nil)
|
buf := bytes.NewBuffer(nil)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
|
@ -105,8 +105,8 @@ func (cli *RPCClient) run() {
|
||||||
}
|
}
|
||||||
buf.Reset()
|
buf.Reset()
|
||||||
cli.Lock(func() bool {
|
cli.Lock(func() bool {
|
||||||
Compress(buf, frames)
|
Compress(buf, cli.Frames)
|
||||||
frames = frames[:0]
|
cli.Frames = cli.Frames[:0]
|
||||||
return true
|
return true
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user