diff --git a/rpc.go b/rpc.go index 4cc2f3e..0bbe549 100644 --- a/rpc.go +++ b/rpc.go @@ -41,13 +41,14 @@ func (rpc *RPCServer) run() { // SayHello implements helloworld.GreeterServer func (s *RPCServer) SendFrames(stream gen.FrameService_SendFramesServer) error { - log.Printf("Received: %v", stream) + log.Printf("Start: %v", stream) for { request, err := stream.Recv() if err != nil { log.Panic(err) } + log.Printf("request: %v", request) s.netCard.FrameChan <- request.GetFrames() // 接受数据 广播到网卡上 }