[SEBA-836] BBSim Reflector
Change-Id: Ib4ae5a2c24880dc62209bebb81188eca5f57865d
diff --git a/internal/bbsim/devices/messageTypes.go b/internal/bbsim/devices/messageTypes.go
index fe6abef..b61ac18 100644
--- a/internal/bbsim/devices/messageTypes.go
+++ b/internal/bbsim/devices/messageTypes.go
@@ -18,6 +18,7 @@
import (
"github.com/google/gopacket"
+ "github.com/opencord/bbsim/internal/bbsim/packetHandlers"
"github.com/opencord/voltha-protos/go/openolt"
)
@@ -35,6 +36,12 @@
StartDHCP MessageType = 8
OnuPacketOut MessageType = 9
DyingGaspIndication MessageType = 10
+
+ // BBR messages
+ OmciIndication MessageType = 11 // this are OMCI messages going from the OLT to VOLTHA
+ SendEapolFlow MessageType = 12
+ SendDhcpFlow MessageType = 13
+ OnuPacketIn MessageType = 14
)
func (m MessageType) String() string {
@@ -50,6 +57,10 @@
"StartDHCP",
"OnuPacketOut",
"DyingGaspIndication",
+ "OmciIndication",
+ "SendEapolFlow",
+ "SendDhcpFlow",
+ "OnuPacketIn",
}
return names[m]
}
@@ -91,6 +102,12 @@
omciMsg *openolt.OmciMsg
}
+type OmciIndicationMessage struct {
+ OnuSN *openolt.SerialNumber
+ OnuID uint32
+ OmciInd *openolt.OmciIndication
+}
+
type OnuFlowUpdateMessage struct {
PonPortID uint32
OnuID uint32
@@ -102,10 +119,11 @@
OnuID uint32
}
-type OnuPacketOutMessage struct {
+type OnuPacketMessage struct {
IntfId uint32
OnuId uint32
Packet gopacket.Packet
+ Type packetHandlers.PacketType
}
type DyingGaspIndicationMessage struct {