VOL-291 : PON simulator refactoring for cluster integration
- Added ponsim build target in Makefile
- Added new option to vcore to select comm type with ponsim
- Modified all proto files to include destination go package
Amendments:
- Clean up based on review comments
- Properly close GRPC connections in ponsim_olt adapter
- Added voltha namespace to some k8s templates
Change-Id: I2f349fa7b3550a8a8cc8fc676cc896f33fbb9372
diff --git a/ponsim/v2/grpc/sbi/olt_handler.go b/ponsim/v2/grpc/sbi/olt_handler.go
new file mode 100644
index 0000000..bb058ca
--- /dev/null
+++ b/ponsim/v2/grpc/sbi/olt_handler.go
@@ -0,0 +1,62 @@
+package sbi
+
+import (
+ "context"
+ "github.com/google/uuid"
+ "github.com/opencord/voltha/ponsim/v2/common"
+ "github.com/opencord/voltha/ponsim/v2/core"
+ "github.com/opencord/voltha/protos/go/ponsim"
+ "github.com/sirupsen/logrus"
+)
+
+type PonSimOltHandler struct {
+ olt *core.PonSimOltDevice
+}
+
+func NewPonSimOltHandler(olt *core.PonSimOltDevice) *PonSimOltHandler {
+ var handler *PonSimOltHandler
+
+ handler = &PonSimOltHandler{olt: olt}
+
+ return handler
+}
+
+func (h *PonSimOltHandler) Register(
+ ctx context.Context,
+ request *ponsim.RegistrationRequest,
+) (*ponsim.RegistrationReply, error) {
+ common.Logger().WithFields(logrus.Fields{
+ "handler": h,
+ }).Info("Registering device")
+
+ onu := &core.PonSimOnuDevice{
+ PonSimDevice: core.PonSimDevice{
+ Address: request.Address, Port: request.Port, //GrpcSecurity: h.olt.GrpcSecurity,
+ }}
+
+ if assignedPort, err := h.olt.AddOnu(onu); assignedPort == -1 || err != nil {
+ return &ponsim.RegistrationReply{
+ Id: uuid.New().String(),
+ Status: ponsim.RegistrationReply_FAILED,
+ StatusMessage: "Failed to register ONU",
+ ParentAddress: common.GetInterfaceIP(h.olt.ExternalIf),
+ ParentPort: h.olt.Port,
+ AssignedPort: assignedPort,
+ }, err
+ } else {
+ common.Logger().WithFields(logrus.Fields{
+ "handler": h,
+ "onus": h.olt.GetOnus(),
+ }).Debug("ONU Added")
+
+ return &ponsim.RegistrationReply{
+ Id: uuid.New().String(),
+ Status: ponsim.RegistrationReply_REGISTERED,
+ StatusMessage: "Successfully registered ONU",
+ ParentAddress: common.GetInterfaceIP(h.olt.ExternalIf),
+ ParentPort: h.olt.Port,
+ AssignedPort: assignedPort,
+ }, nil
+
+ }
+}