测试
This commit is contained in:
parent
fb1b65184e
commit
633dbaf37f
|
@ -94,7 +94,7 @@ func (cli *RPCClient) run() {
|
||||||
// log.Println(err)
|
// log.Println(err)
|
||||||
// }
|
// }
|
||||||
|
|
||||||
log.Printf("%v %d", cliBuffer, len(buf.Bytes()))
|
log.Printf("send to target bytes: %d", len(buf.Bytes()))
|
||||||
// 发到对面的网卡
|
// 发到对面的网卡
|
||||||
err = stream.Send(&gen.Request{
|
err = stream.Send(&gen.Request{
|
||||||
Frames: buf.Bytes(),
|
Frames: buf.Bytes(),
|
||||||
|
@ -257,7 +257,7 @@ func (nc *NetCard) runWrite() {
|
||||||
log.Panic(err)
|
log.Panic(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Printf("get wframes len: %d", len(bufs))
|
log.Printf("get wframes decode len: %d", len(bufs))
|
||||||
|
|
||||||
for _, buf := range bufs {
|
for _, buf := range bufs {
|
||||||
_, err := ifce.Write(buf)
|
_, err := ifce.Write(buf)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user