[VOL-4188] Use ProxyAddress while sending OMCI messages to olt adapter
Change-Id: Iac8778fb4b65d1a1a8cf4b9d491d7c4d59bb6b5c
diff --git a/internal/pkg/onuadaptercore/omci_cc.go b/internal/pkg/onuadaptercore/omci_cc.go
index ed4d59d..fd93109 100644
--- a/internal/pkg/onuadaptercore/omci_cc.go
+++ b/internal/pkg/onuadaptercore/omci_cc.go
@@ -37,6 +37,7 @@
//"github.com/opencord/voltha-lib-go/v4/pkg/kafka"
"github.com/opencord/voltha-lib-go/v4/pkg/log"
+ "github.com/opencord/voltha-protos/v4/go/common"
ic "github.com/opencord/voltha-protos/v4/go/inter_container"
//"github.com/opencord/voltha-protos/v4/go/openflow_13"
//"github.com/opencord/voltha-protos/v4/go/voltha"
@@ -592,7 +593,11 @@
"toDeviceType": oo.pBaseDeviceHandler.ProxyAddressType,
"proxyDeviceID": oo.pBaseDeviceHandler.ProxyAddressID})
}
- omciMsg := &ic.InterAdapterOmciMessage{Message: omciTxRequest.txFrame}
+ omciMsg := &ic.InterAdapterOmciMessage{
+ Message: omciTxRequest.txFrame,
+ ProxyAddress: oo.pBaseDeviceHandler.device.ProxyAddress,
+ ConnectStatus: common.ConnectStatus_REACHABLE, // If we are sending OMCI messages means we are connected, else we should not be here
+ }
if sendErr := oo.adapterProxy.SendInterAdapterMessage(log.WithSpanFromContext(context.Background(), ctx), omciMsg,
ic.InterAdapterMessageType_OMCI_REQUEST,
//fromTopic,toType,toDevId, ProxyDevId