Add hooks for sending omci indication
Change-Id: I0b21aa7e41dd14e9613fb3ab41142825527a75ac
diff --git a/core/grpc_service.go b/core/grpc_service.go
index d833104..5fd0e4f 100644
--- a/core/grpc_service.go
+++ b/core/grpc_service.go
@@ -100,8 +100,12 @@
}
func (s *Server) OmciMsgOut(c context.Context, msg *openolt.OmciMsg) (*openolt.Empty, error) {
+ var resp OmciIndication
logger.Debug("OLT %d receives OmciMsgOut to IF %v (ONU-ID: %v) pkt:%x.", s.Olt.ID, msg.IntfId, msg.OnuId, msg.Pkt)
- //s.olt.Queue = append(s.olt.Queue, *msg)
+ resp.IntfId = msg.IntfId
+ resp.OnuId = msg.OnuId
+ resp.Pkt = make([]byte, len(msg.Pkt))
+ s.omciChan <- resp
return new(openolt.Empty), nil
}