This is a first attempt at getting INGRESS packets flowing northwards in the system.
Tested with ponsim and EAPOL packets generated by the RG tester; confirmed that the
packets flowed from rg->onu->olt->adapter->rw-core->ofagent.
Change-Id: I534c2a376751de50f8e5af9676cd9d467e7b3835
diff --git a/rw_core/core/core.go b/rw_core/core/core.go
index 0908146..298c3ce 100644
--- a/rw_core/core/core.go
+++ b/rw_core/core/core.go
@@ -32,7 +32,7 @@
deviceMgr *DeviceManager
logicalDeviceMgr *LogicalDeviceManager
grpcServer *grpcserver.GrpcServer
- grpcNBIAPIHanfler *APIHandler
+ grpcNBIAPIHandler *APIHandler
config *config.RWCoreFlags
kmp *kafka.InterContainerProxy
clusterDataRoot model.Root
@@ -106,12 +106,13 @@
core.grpcServer = grpcserver.NewGrpcServer(core.config.GrpcHost, core.config.GrpcPort, nil, false)
log.Info("grpc-server-created")
- core.grpcNBIAPIHanfler = NewAPIHandler(core.deviceMgr, core.logicalDeviceMgr)
+ core.grpcNBIAPIHandler = NewAPIHandler(core.deviceMgr, core.logicalDeviceMgr)
+ core.logicalDeviceMgr.setGrpcNbiHandler(core.grpcNBIAPIHandler)
// Create a function to register the core GRPC service with the GRPC server
f := func(gs *grpc.Server) {
voltha.RegisterVolthaServiceServer(
gs,
- core.grpcNBIAPIHanfler,
+ core.grpcNBIAPIHandler,
)
}