新TAP测试
This commit is contained in:
parent
b885839c09
commit
5bae5ca7b5
|
@ -112,6 +112,7 @@ func NewNetTunnel() *NetTunnel {
|
||||||
go func() {
|
go func() {
|
||||||
for wbuf := range nt.writer {
|
for wbuf := range nt.writer {
|
||||||
var frame ethernet.Frame = wbuf
|
var frame ethernet.Frame = wbuf
|
||||||
|
log.Printf("ifce write %d", len(frame))
|
||||||
_, err := nt.ifce.Write(frame)
|
_, err := nt.ifce.Write(frame)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
|
@ -164,7 +165,7 @@ func (nt *NetTunnel) SendFrames(stream gen.FrameService_SendFramesServer) error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Panic(err)
|
log.Panic(err)
|
||||||
}
|
}
|
||||||
log.Printf("request: %v", len(request.Frames))
|
|
||||||
frames := Decompress(request.GetFrames())
|
frames := Decompress(request.GetFrames())
|
||||||
if len(frames) > 0 {
|
if len(frames) > 0 {
|
||||||
for _, frame := range frames {
|
for _, frame := range frames {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user