测试
This commit is contained in:
parent
bd8c71835f
commit
0c5f40b876
2
tap.go
2
tap.go
|
@ -83,9 +83,9 @@ func (cli *RPCClient) run() {
|
||||||
|
|
||||||
enc := gob.NewEncoder(zenc)
|
enc := gob.NewEncoder(zenc)
|
||||||
cliBuffer := <-cli.FrameChan
|
cliBuffer := <-cli.FrameChan
|
||||||
log.Printf("%v", cliBuffer)
|
|
||||||
enc.Encode(cliBuffer.BytesArray)
|
enc.Encode(cliBuffer.BytesArray)
|
||||||
|
|
||||||
|
log.Printf("%v %d", cliBuffer, len(cliBuffer.BytesArray))
|
||||||
// 发到对面的网卡
|
// 发到对面的网卡
|
||||||
err = stream.Send(&gen.Request{
|
err = stream.Send(&gen.Request{
|
||||||
Frames: buf.Bytes(),
|
Frames: buf.Bytes(),
|
||||||
|
|
Loading…
Reference in New Issue
Block a user