This commit is contained in:
黄思敏 2022-08-25 12:12:44 +08:00
parent 1402f1957b
commit 1ab81a01e2

3
rpc.go
View File

@ -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() // 接受数据 广播到网卡上
}