Method recvLoop

internal/nodeagent/session.go:149–157

()

}

func (s *session) recvLoop() error {
	for {
		msg, err := s.stream.Recv()
		if err != nil {
			return err
		}
		s.dispatch(msg)
	}
}

func (s *session) dispatch(msg *nodev1.ServerMessage) {
	// 1) cancel 帧：取消 inflight。