blob: c13d0030bb157a86b64ae76a639258b2622510da [file] [log] [blame]
package core
import (
"context"
"github.com/google/gopacket"
"github.com/google/gopacket/layers"
"github.com/google/gopacket/pcap"
"github.com/opencord/voltha/ponsim/v2/common"
"github.com/opencord/voltha/protos/go/openflow_13"
"github.com/sirupsen/logrus"
"net"
"sort"
)
// TODO: Pass-in the certificate information as a structure parameter
// TODO: Add certification information
type PonSimDevice struct {
Name string `json:name`
Port int32 `json:port`
Address string `json:address`
ExternalIf string `json:external_if`
InternalIf string `json:internal_if`
Promiscuous bool `json:promiscuous`
SnapshotLen int32 `json:snapshot_len`
AlarmsOn bool `json:alarm_on`
AlarmsFreq int `json:alarm_freq`
Counter *PonSimMetricCounter `json:counter`
//*grpc.GrpcSecurity
flows []*openflow_13.OfpFlowStats `json:-`
ingressHandler *pcap.Handle `json:-`
egressHandler *pcap.Handle `json:-`
links map[int]map[int]interface{} `json:-`
}
const (
UDP_DST = 1
UDP_SRC = 2
IPV4_DST = 4
VLAN_PCP = 8
VLAN_VID = 16
IP_PROTO = 32
ETH_TYPE = 64
IN_PORT = 128
)
/*
Start performs common setup operations for a ponsim device
*/
func (o *PonSimDevice) Start(ctx context.Context) {
}
/*
Stop performs common cleanup operations for a ponsim device
*/
func (o *PonSimDevice) Stop(ctx context.Context) {
}
/*
GetAddress returns the IP/FQDN for the device
*/
func (o *PonSimDevice) GetAddress() string {
return o.Address
}
/*
GetPort return the port assigned to the device
*/
func (o *PonSimDevice) GetPort() int32 {
return o.Port
}
/*
Forward is responsible of processing incoming data, filtering it and redirecting to the
intended destination
*/
func (o *PonSimDevice) Forward(
ctx context.Context,
port int,
frame gopacket.Packet,
) error {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"frame": frame,
}).Debug("Forwarding packet")
var err error
o.Counter.CountRxFrame(port, len(common.GetEthernetLayer(frame).Payload))
if egressPort, egressFrame := o.processFrame(ctx, port, frame); egressFrame != nil {
forwarded := 0
links := o.links[int(egressPort)]
o.Counter.CountTxFrame(int(egressPort), len(common.GetEthernetLayer(egressFrame).Payload))
for _, link := range links {
forwarded += 1
common.Logger().WithFields(logrus.Fields{
"device": o,
"egressPort": port,
"egressFrame": egressFrame,
}).Debug("Forwarding packet to link")
link.(func(int, gopacket.Packet))(int(egressPort), egressFrame)
}
if forwarded == 0 {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"frame": frame,
}).Warn("Nothing was forwarded")
}
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": egressPort,
"frame": egressFrame,
}).Error("Failed to properly process frame")
}
return err
}
/*
connectNetworkInterfaces opens network interfaces for reading and/or writing packets
*/
func (o *PonSimDevice) connectNetworkInterfaces() {
common.Logger().WithFields(logrus.Fields{
"device": o,
}).Debug("Opening network interfaces")
var err error
if o.ingressHandler, err = pcap.OpenLive(
o.ExternalIf, o.SnapshotLen, o.Promiscuous, pcap.BlockForever,
); err != nil {
common.Logger().WithFields(logrus.Fields{
"device": o,
"interface": o.ExternalIf,
"error": err.Error(),
}).Fatal("Unable to open Ingress interface")
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"interface": o.ExternalIf,
}).Info("Opened Ingress interface")
}
if o.egressHandler, err = pcap.OpenLive(
o.InternalIf, o.SnapshotLen, o.Promiscuous, pcap.BlockForever,
); err != nil {
common.Logger().WithFields(logrus.Fields{
"device": o,
"interface": o.InternalIf,
"error": err.Error(),
}).Fatal("Unable to open egress interface")
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"interface": o.InternalIf,
}).Info("Opened egress interface")
}
}
/*
AddLink assigns a functional operation to a device endpoint
The functional operation is called whenever a packet has been processed
and the endpoint has been identified as the outgoing interface
*/
func (o *PonSimDevice) AddLink(
port int,
index int,
function interface{},
) error {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"index": index,
}).Debug("Linking port to functional operation")
if o.links == nil {
o.links = make(map[int]map[int]interface{})
}
if _, ok := o.links[port]; !ok {
o.links[port] = make(map[int]interface{})
}
o.links[port][index] = function
return nil
}
/*
RemoveLink will remove reference a functional operation for a given port and index
*/
func (o *PonSimDevice) RemoveLink(
port int,
index int,
) error {
if _, hasPort := o.links[port]; hasPort {
if _, hasIndex := o.links[port][index]; hasIndex {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"index": index,
}).Debug("Removing link functional operation")
delete(o.links[port], index)
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"index": index,
}).Warn("No such index for link functional operation")
}
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"index": index,
}).Warn("No such port for functional operation")
}
return nil
}
/*
InstallFlows assigns flows to the device in order of priority
*/
func (o *PonSimDevice) InstallFlows(
ctx context.Context,
flows []*openflow_13.OfpFlowStats,
) error {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flows": flows,
}).Debug("Installing flows")
o.flows = flows
sort.Sort(common.SortByPriority(o.flows))
common.Logger().WithFields(logrus.Fields{
"device": o,
}).Debug("Installed sorted flows")
return nil
}
/*
processFrame is responsible for matching or discarding a frame based on the configured flows
*/
func (o *PonSimDevice) processFrame(
ctx context.Context,
port int,
frame gopacket.Packet,
) (uint32, gopacket.Packet) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"frame": frame,
}).Debug("Processing frame")
var err error
var matchedMask int = 0
var currentMask int
var highestPriority uint32 = 0
var matchedFlow *openflow_13.OfpFlowStats = nil
common.Logger().WithFields(logrus.Fields{
"device": o,
}).Debug("Looping through flows")
for _, flow := range o.flows {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
}).Debug("Checking flow")
if matchedFlow != nil && flow.Priority < highestPriority {
common.Logger().WithFields(logrus.Fields{
"device": o,
"matchedFlow": matchedFlow,
"priority": highestPriority,
}).Debug("Flow has already been matched")
break
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"matchedFlow": matchedFlow,
"priority": flow.Priority,
"highestPriority": highestPriority,
}).Debug("Flow OR Priority requirements not met")
}
highestPriority = flow.Priority
if currentMask, err = o.isMatch(ctx, flow, port, frame); err != nil {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"port": port,
"frame": frame,
"error": err.Error(),
}).Error("Problem while matching flow")
} else if currentMask > matchedMask {
matchedMask = currentMask
matchedFlow = flow
common.Logger().WithFields(logrus.Fields{
"device": o,
"matchedFlow": flow,
"port": port,
"frame": frame,
"matchedMask": matchedMask,
}).Debug("Flow matches")
}
}
if matchedFlow != nil {
egressPort, egressFrame := o.processActions(ctx, matchedFlow, frame)
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"egressPort": egressPort,
"egressFrame": egressFrame,
}).Debug("Processed actions to matched flow")
return egressPort, egressFrame
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"port": port,
"frame": frame,
"matchedMask": matchedMask,
}).Warn("Flow was not successfully matched")
}
return 0, nil
}
/*
isMatch traverses the criteria of a flow and identify all matching elements of a frame (if any)
*/
func (o *PonSimDevice) isMatch(
ctx context.Context,
flow *openflow_13.OfpFlowStats,
port int,
frame gopacket.Packet,
) (int, error) {
matchedMask := 0
for _, ofbfield := range flow.Match.OxmFields {
if ofbfield.GetOxmClass() == openflow_13.OfpOxmClass_OFPXMC_OPENFLOW_BASIC {
switch ofbfield.GetOfbField().Type {
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_IN_PORT:
if ofbfield.GetOfbField().GetPort() != uint32(port) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetPort(),
"actual": port,
}).Warn("Port does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetPort(),
"actual": port,
}).Debug("Port matches")
}
matchedMask |= IN_PORT
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_ETH_TYPE:
cmpType := uint32(common.GetEthernetLayer(frame).EthernetType)
if dot1q := common.GetDot1QLayer(frame); dot1q != nil {
cmpType = uint32(dot1q.Type)
}
if ofbfield.GetOfbField().GetEthType() != cmpType {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": layers.EthernetType(ofbfield.GetOfbField().GetEthType()),
"actual": common.GetEthernetLayer(frame).EthernetType,
}).Warn("Frame type does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": layers.EthernetType(ofbfield.GetOfbField().GetEthType()),
"actual": common.GetEthernetLayer(frame).EthernetType,
}).Debug("Frame type matches")
}
matchedMask |= ETH_TYPE
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_IP_PROTO:
if ofbfield.GetOfbField().GetIpProto() != uint32(common.GetIpLayer(frame).Protocol) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetIpProto(),
"actual": common.GetIpLayer(frame).Protocol,
}).Warn("IP protocol does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetIpProto(),
"actual": common.GetIpLayer(frame).Protocol,
}).Debug("IP protocol matches")
}
matchedMask |= IP_PROTO
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_VLAN_VID:
expectedVlan := ofbfield.GetOfbField().GetVlanVid()
dot1q := common.GetDot1QLayer(frame)
if (expectedVlan&4096 == 0) != (dot1q == nil) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expectedVlan": expectedVlan,
"vlanBitwise": expectedVlan & 4096,
"dot1q": dot1q,
}).Warn("VLAN condition not met")
return 0, nil
}
if dot1q != nil {
if uint32(dot1q.VLANIdentifier) != (expectedVlan & 4095) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": expectedVlan,
"actual": uint32(dot1q.VLANIdentifier),
}).Warn("VLAN VID does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": expectedVlan,
"actual": uint32(dot1q.VLANIdentifier),
}).Debug("VLAN VID matches")
}
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
}).Warn("VLAN VID missing. Not dot1q encapsulation")
}
matchedMask |= VLAN_VID
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_VLAN_PCP:
if ofbfield.GetOfbField().GetVlanPcp() != uint32(common.GetDot1QLayer(frame).Priority) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetVlanPcp(),
"actual": uint32(common.GetDot1QLayer(frame).Priority),
}).Warn("VLAN priority does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetVlanPcp(),
"actual": uint32(common.GetDot1QLayer(frame).Priority),
}).Debug("VLAN priority matches")
}
matchedMask |= VLAN_PCP
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_IPV4_DST:
dstIpRaw := ofbfield.GetOfbField().GetIpv4Dst()
dstIp := net.IPv4(
byte((dstIpRaw>>24)&0xFF),
byte((dstIpRaw>>16)&0xFF),
byte((dstIpRaw>>8)&0xFF),
byte(dstIpRaw&0xFF))
if !dstIp.Equal(common.GetIpLayer(frame).DstIP) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": dstIp,
"actual": common.GetIpLayer(frame).DstIP,
}).Warn("IPv4 destination does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": dstIp,
"actual": common.GetIpLayer(frame).DstIP,
}).Debug("IPv4 destination matches")
}
matchedMask |= IPV4_DST
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_UDP_SRC:
if ofbfield.GetOfbField().GetUdpSrc() != uint32(common.GetUdpLayer(frame).SrcPort) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetUdpSrc(),
"actual": common.GetUdpLayer(frame).SrcPort,
}).Warn("UDP source port does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetUdpSrc(),
"actual": common.GetUdpLayer(frame).SrcPort,
}).Debug("UDP source port matches")
}
matchedMask |= UDP_SRC
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_UDP_DST:
if ofbfield.GetOfbField().GetUdpDst() != uint32(common.GetUdpLayer(frame).DstPort) {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetUdpDst(),
"actual": common.GetUdpLayer(frame).DstPort,
}).Warn("UDP destination port does not match")
return 0, nil
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"expected": ofbfield.GetOfbField().GetUdpDst(),
"actual": common.GetUdpLayer(frame).DstPort,
}).Debug("UDP destination port does matches")
}
matchedMask |= UDP_DST
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_METADATA:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
}).Warn("Skipping metadata")
continue
default:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"type": ofbfield.GetOfbField().Type,
}).Warn("Field type not implemented")
}
}
}
return matchedMask, nil
}
/*
processActions applies transformation instructions to a frame that met all the flow criteria
*/
func (o *PonSimDevice) processActions(
ctx context.Context,
flow *openflow_13.OfpFlowStats,
frame gopacket.Packet,
) (uint32, gopacket.Packet) {
var egressPort uint32
var retFrame gopacket.Packet = frame
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Info("Processing actions")
for _, instruction := range flow.Instructions {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"instruction": instruction,
}).Debug("Processing actions - Instruction entry")
if instruction.Type == uint32(openflow_13.OfpInstructionType_OFPIT_APPLY_ACTIONS) {
for _, action := range instruction.GetActions().GetActions() {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"action": action,
"actionType": action.Type,
}).Debug("Processing actions - Action entry")
switch action.Type {
case openflow_13.OfpActionType_OFPAT_OUTPUT:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Debug("Processing action OFPAT output")
egressPort = action.GetOutput().Port
case openflow_13.OfpActionType_OFPAT_POP_VLAN:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Debug("Processing action OFPAT POP VLAN")
if shim := common.GetDot1QLayer(retFrame); shim != nil {
if eth := common.GetEthernetLayer(retFrame); eth != nil {
ethernetLayer := &layers.Ethernet{
SrcMAC: eth.SrcMAC,
DstMAC: eth.DstMAC,
EthernetType: shim.Type,
}
buffer := gopacket.NewSerializeBuffer()
gopacket.SerializeLayers(buffer, gopacket.SerializeOptions{},
ethernetLayer,
gopacket.Payload(shim.Payload),
)
retFrame = gopacket.NewPacket(
buffer.Bytes(),
layers.LayerTypeEthernet,
gopacket.Default,
)
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("No ETH found while processing POP VLAN action")
}
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("No DOT1Q found while processing POP VLAN action")
}
case openflow_13.OfpActionType_OFPAT_PUSH_VLAN:
if eth := common.GetEthernetLayer(retFrame); eth != nil {
ethernetLayer := &layers.Ethernet{
SrcMAC: eth.SrcMAC,
DstMAC: eth.DstMAC,
EthernetType: layers.EthernetType(action.GetPush().GetEthertype()),
}
dot1qLayer := &layers.Dot1Q{
Type: eth.EthernetType,
}
buffer := gopacket.NewSerializeBuffer()
gopacket.SerializeLayers(
buffer,
gopacket.SerializeOptions{
FixLengths: false,
},
ethernetLayer,
dot1qLayer,
gopacket.Payload(eth.Payload),
)
retFrame = gopacket.NewPacket(
buffer.Bytes(),
layers.LayerTypeEthernet,
gopacket.Default,
)
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("No ETH found while processing PUSH VLAN action")
}
case openflow_13.OfpActionType_OFPAT_SET_FIELD:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Debug("Processing action OFPAT SET FIELD")
if action.GetSetField().GetField().GetOxmClass() ==
openflow_13.OfpOxmClass_OFPXMC_OPENFLOW_BASIC {
field := action.GetSetField().GetField().GetOfbField()
switch field.Type {
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_VLAN_VID:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Debug("Processing action OFPAT SET FIELD - VLAN VID")
if shim := common.GetDot1QLayer(retFrame); shim != nil {
eth := common.GetEthernetLayer(retFrame)
buffer := gopacket.NewSerializeBuffer()
var dot1qLayer *layers.Dot1Q
var ethernetLayer *layers.Ethernet
ethernetLayer = &layers.Ethernet{
SrcMAC: eth.SrcMAC,
DstMAC: eth.DstMAC,
EthernetType: eth.EthernetType,
}
dot1qLayer = &layers.Dot1Q{
Type: shim.Type,
VLANIdentifier: uint16(field.GetVlanVid() & 4095),
}
gopacket.SerializeLayers(
buffer,
gopacket.SerializeOptions{},
ethernetLayer,
dot1qLayer,
gopacket.Payload(shim.LayerPayload()),
)
retFrame = gopacket.NewPacket(
buffer.Bytes(),
layers.LayerTypeEthernet,
gopacket.Default,
)
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"frameDump": retFrame.Dump(),
"vlanVid": shim.VLANIdentifier,
}).Info("Setting DOT1Q VLAN VID")
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("No DOT1Q found while setting VLAN VID")
}
case openflow_13.OxmOfbFieldTypes_OFPXMT_OFB_VLAN_PCP:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Debug("Processing action OFPAT SET FIELD - VLAN PCP")
if shim := common.GetDot1QLayer(retFrame); shim != nil {
shim.Priority = uint8(field.GetVlanPcp())
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"priority": shim.Priority,
}).Info("Setting DOT1Q VLAN PCP")
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("No DOT1Q found while setting VLAN PCP")
}
default:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"type": field.Type,
}).Warn("Set field not implemented for this type")
}
} else {
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
}).Warn("Field not of type OF-BASIC")
}
default:
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"frame": retFrame,
"type": action.Type,
}).Warn("Action type not implemented")
}
}
}
}
common.Logger().WithFields(logrus.Fields{
"device": o,
"flow": flow,
"egressPort": egressPort,
"retFrame": retFrame,
}).Debug("Processed actions")
return egressPort, retFrame
}