summaryrefslogtreecommitdiffhomepage
path: root/internal/pkg/zebra/zapi.go
diff options
context:
space:
mode:
authorHitoshi Irino <irino@sfc.wide.ad.jp>2020-04-25 22:06:21 +0900
committerHitoshi Irino <irino@sfc.wide.ad.jp>2020-04-26 07:43:50 +0900
commitcf572bc5fc4647ea675c8a3482d80d181f62c66c (patch)
treeb50bc6a682c801062ffe19a198b05ddc743a84ee /internal/pkg/zebra/zapi.go
parentf11b9c7afb198dd6bfea9a167f41a62569f24756 (diff)
Refactoring Zebra and supporting frr7.3
- Change const values to camel case from snake case to make zero golint's warnigns - Introduce convert functions (toEach, toCommon) between the newest version to older versions - Merge code about decode nexthop to reduce lines of code - Add frr7.3 statemet in allowable software for config - Rename and Update generated file by stringer
Diffstat (limited to 'internal/pkg/zebra/zapi.go')
-rw-r--r--internal/pkg/zebra/zapi.go4175
1 files changed, 1915 insertions, 2260 deletions
diff --git a/internal/pkg/zebra/zapi.go b/internal/pkg/zebra/zapi.go
index cbae40f0..eb4d243a 100644
--- a/internal/pkg/zebra/zapi.go
+++ b/internal/pkg/zebra/zapi.go
@@ -19,761 +19,856 @@ import (
"encoding/binary"
"errors"
"fmt"
+ "github.com/osrg/gobgp/pkg/packet/bgp"
+ log "github.com/sirupsen/logrus"
"io"
"math"
"net"
"strings"
"syscall"
-
- log "github.com/sirupsen/logrus"
-
- "github.com/osrg/gobgp/pkg/packet/bgp"
)
const (
- HEADER_MARKER uint8 = 255
- FRR_HEADER_MARKER uint8 = 254
- INTERFACE_NAMSIZ = 20
+ // MinZapiVer is minimum zebra api version which is referred in zclient
+ MinZapiVer uint8 = 2
+ // MaxZapiVer is maximum zebra api version which is referredd in zclient
+ MaxZapiVer uint8 = 6
+ // DefaultVrf is default vrf id is referredd in zclient and server
+ DefaultVrf = 0
)
const (
- MinZapiVer uint8 = 2
- MaxZapiVer uint8 = 6
+ headerMarker uint8 = 255
+ frrHeaderMarker uint8 = 254
+ interfaceNameSize = 20
+ maxPathNum = 64
+ maxMplsLabel = 16
)
// Internal Interface Status.
-type INTERFACE_STATUS uint8
+type interfaceStatus uint8
const (
- INTERFACE_ACTIVE INTERFACE_STATUS = 0x01
- INTERFACE_SUB INTERFACE_STATUS = 0x02
- INTERFACE_LINKDETECTION INTERFACE_STATUS = 0x04
- INTERFACE_VRF_LOOPBACK INTERFACE_STATUS = 0x08
+ interfaceActive interfaceStatus = 0x01
+ interfaceSub interfaceStatus = 0x02
+ interfaceLinkDetection interfaceStatus = 0x04
+ interfaceVrfLoopback interfaceStatus = 0x08
)
// Interface Link Layer Types.
-//go:generate stringer -type=LINK_TYPE
-type LINK_TYPE uint32
+//go:generate stringer -type=linkType
+type linkType uint32
const (
- LINK_TYPE_UNKNOWN LINK_TYPE = iota
- LINK_TYPE_ETHER
- LINK_TYPE_EETHER
- LINK_TYPE_AX25
- LINK_TYPE_PRONET
- LINK_TYPE_IEEE802
- LINK_TYPE_ARCNET
- LINK_TYPE_APPLETLK
- LINK_TYPE_DLCI
- LINK_TYPE_ATM
- LINK_TYPE_METRICOM
- LINK_TYPE_IEEE1394
- LINK_TYPE_EUI64
- LINK_TYPE_INFINIBAND
- LINK_TYPE_SLIP
- LINK_TYPE_CSLIP
- LINK_TYPE_SLIP6
- LINK_TYPE_CSLIP6
- LINK_TYPE_RSRVD
- LINK_TYPE_ADAPT
- LINK_TYPE_ROSE
- LINK_TYPE_X25
- LINK_TYPE_PPP
- LINK_TYPE_CHDLC
- LINK_TYPE_LAPB
- LINK_TYPE_RAWHDLC
- LINK_TYPE_IPIP
- LINK_TYPE_IPIP6
- LINK_TYPE_FRAD
- LINK_TYPE_SKIP
- LINK_TYPE_LOOPBACK
- LINK_TYPE_LOCALTLK
- LINK_TYPE_FDDI
- LINK_TYPE_SIT
- LINK_TYPE_IPDDP
- LINK_TYPE_IPGRE
- LINK_TYPE_IP6GRE
- LINK_TYPE_PIMREG
- LINK_TYPE_HIPPI
- LINK_TYPE_ECONET
- LINK_TYPE_IRDA
- LINK_TYPE_FCPP
- LINK_TYPE_FCAL
- LINK_TYPE_FCPL
- LINK_TYPE_FCFABRIC
- LINK_TYPE_IEEE802_TR
- LINK_TYPE_IEEE80211
- LINK_TYPE_IEEE80211_RADIOTAP
- LINK_TYPE_IEEE802154
- LINK_TYPE_IEEE802154_PHY
+ linkTypeUnknown linkType = iota
+ linkTypeEther
+ linkTypeEEther
+ linkTypeAX25
+ linkTypePRONET
+ linkTypeIeee802
+ linkTypeARCNET
+ linkTypeAPPLETLK
+ linkTypeDLCI
+ linkTypeATM
+ linkTypeMetricOM
+ linkTypeIeee1394
+ linkTypeEUI64
+ linkTypeINFINIBAND
+ linkTypeSLIP
+ linkTypeCSLIP
+ linkTypeSLIP6
+ linkTypeCSLIP6
+ linkTypeRSRVD
+ linkTypeADAPT
+ linkTypeROSE
+ linkTypeX25
+ linkTypePPP
+ linkTypeCHDLC
+ linkTypeLAPB
+ linkTypeRAWHDLC
+ linkTypeIPIP
+ linkTypeIPIP6
+ linkTypeFRAD
+ linkTypeSKIP
+ linkTypeLOOPBACK
+ linkTypeLOCALTLK
+ linkTypeFDDI
+ linkTypeSIT
+ linkTypeIPDDP
+ linkTypeIPGRE
+ linkTypeIP6GRE
+ linkTypePIMREG
+ linkTypeHIPPI
+ linkTypeECONET
+ linkTypeIRDA
+ linkTypeFCPP
+ linkTypeFCAL
+ linkTypeFCPL
+ linkTypeFCFABRIC
+ linkTypeIeee802Tr
+ linkTypeIeee80211
+ linkTypeIeee80211RadioTap
+ linkTypeIeee802154
+ linkTypeIeee802154Phy
)
-const VRF_DEFAULT = 0
-const MAXPATH_NUM = 64
-const MPLS_MAX_LABEL = 16
-
+// HeaderSize returns suitable header size from version
func HeaderSize(version uint8) uint16 {
switch version {
case 3, 4:
return 8
case 5, 6:
return 10
- default:
- return 6
}
+ return 6 // version == 2
}
-func (t INTERFACE_STATUS) String() string {
+// HeaderMarker returns suitable header marker from version
+func HeaderMarker(version uint8) uint8 {
+ if version > 3 {
+ return frrHeaderMarker
+ }
+ return headerMarker
+}
+
+func (t interfaceStatus) String() string {
ss := make([]string, 0, 3)
- if t&INTERFACE_ACTIVE > 0 {
- ss = append(ss, "ACTIVE")
+ if t&interfaceActive > 0 {
+ ss = append(ss, "Active")
}
- if t&INTERFACE_SUB > 0 {
- ss = append(ss, "SUB")
+ if t&interfaceSub > 0 {
+ ss = append(ss, "Sub")
}
- if t&INTERFACE_LINKDETECTION > 0 {
- ss = append(ss, "LINKDETECTION")
+ if t&interfaceLinkDetection > 0 {
+ ss = append(ss, "LinkDetection")
}
- if t&INTERFACE_VRF_LOOPBACK > 0 {
- ss = append(ss, "VRF_LOOPBACK")
+ if t&interfaceVrfLoopback > 0 {
+ ss = append(ss, "VrfLoopback")
}
return strings.Join(ss, "|")
}
// Interface Connected Address Flags
-type INTERFACE_ADDRESS_FLAG uint8
+type interfaceAddressFlag uint8
const (
- INTERFACE_ADDRESS_SECONDARY INTERFACE_ADDRESS_FLAG = 0x01
- INTERFACE_ADDRESS_PEER INTERFACE_ADDRESS_FLAG = 0x02
- INTERFACE_ADDRESS_UNNUMBERED INTERFACE_ADDRESS_FLAG = 0x04
+ interfaceAddressSecondary interfaceAddressFlag = 0x01
+ interfaceAddressPeer interfaceAddressFlag = 0x02
+ interfaceAddressUnnumbered interfaceAddressFlag = 0x04
)
-func (t INTERFACE_ADDRESS_FLAG) String() string {
+func (t interfaceAddressFlag) String() string {
ss := make([]string, 0, 3)
- if t&INTERFACE_ADDRESS_SECONDARY > 0 {
+ if t&interfaceAddressSecondary > 0 {
ss = append(ss, "SECONDARY")
}
- if t&INTERFACE_ADDRESS_PEER > 0 {
+ if t&interfaceAddressPeer > 0 {
ss = append(ss, "PEER")
}
- if t&INTERFACE_ADDRESS_UNNUMBERED > 0 {
+ if t&interfaceAddressUnnumbered > 0 {
ss = append(ss, "UNNUMBERED")
}
return strings.Join(ss, "|")
}
-// Address Family Identifier.
-//go:generate stringer -type=AFI
-type AFI uint8
+// Address Family IDentifier.
+//go:generate stringer -type=afi
+type afi uint8
const (
- AFI_IP AFI = 1
- AFI_IP6 AFI = 2
- AFI_ETHER AFI = 3
- AFI_MAX AFI = 4
+ afiIP afi = 1
+ afiIP6 afi = 2
+ afiEther afi = 3
+ afiMax afi = 4
)
-// Subsequent Address Family Identifier.
-//go:generate stringer -type=SAFI
-type SAFI uint8
+// Safi is Subsequent Address Family IDentifier.
+//go:generate stringer -type=Safi
+type Safi uint8
-// SAFI definition in Zebra of FRRouting 4.x, 5.x, 6.x
+// Safi definition in Zebra of FRRouting 4.x, 5.x, 6.x, and 7.x
const (
- _ SAFI = iota
- FRR_ZAPI5_SAFI_UNICAST
- FRR_ZAPI5_SAFI_MULTICAST
- FRR_ZAPI5_SAFI_MPLS_VPN
- FRR_ZAPI5_SAFI_ENCAP
- FRR_ZAPI5_SAFI_EVPN
- FRR_ZAPI5_SAFI_LABELED_UNICAST
- FRR_ZAPI5_SAFI_FLOWSPEC
- FRR_ZAPI5_SAFI_MAX
+ safiUnspec Safi = iota // add in FRRouting version 7.2 (Zapi 6)
+ SafiUnicast
+ safiMulticast
+ safiMplsVpn
+ safiEncap
+ safiEvpn
+ safiLabeledUnicast
+ safiFlowspec // add in FRRouting version 5 (Zapi 5)
+ safiMax
)
-// SAFI definition in Zebra of Quagga and FRRouting 3.x
+// Safi definition in Zebra of Quagga and FRRouting 3.x
const (
- _ SAFI = iota
- SAFI_UNICAST
- SAFI_MULTICAST
- FRR_SAFI_MPLS_VPN // SAFI_RESERVED_3 in quagga
- SAFI_MPLS_VPN // SAFI_RESERVED_4 in FRRouting 3.x
- FRR_SAFI_ENCAP
- FRR_SAFI_EVPN
- SAFI_ENCAP // SAFI_MAX in FRRouting 3.x
- SAFI_MAX
+ zapi4SafiMplsVpn Safi = iota + safiMulticast + 1 // SafiRESERVED_3 in quagga
+ zapi3SafiMplsVpn // SafiRESERVED_4 in FRRouting 3.x
+ zapi4SafiEncap
+ zapi4SafiEvpn
+ zapi3SafiEncap // SafiMax in FRRouting 3.x
)
-// API Types.
-//go:generate stringer -type=API_TYPE
-type API_TYPE uint16
-
-// For FRRouting version 7. (ZAPI version 6)
+var zapi3SafiMap = map[Safi]Safi{
+ zapi3SafiMplsVpn: safiMplsVpn,
+ zapi3SafiEncap: safiEncap,
+}
+var zapi4SafiMap = map[Safi]Safi{
+ zapi4SafiMplsVpn: safiMplsVpn,
+ zapi4SafiEncap: safiEncap,
+ zapi4SafiEvpn: safiEvpn,
+}
+var safiRouteFamilyIPv4Map = map[Safi]bgp.RouteFamily{
+ safiUnspec: bgp.RF_OPAQUE,
+ SafiUnicast: bgp.RF_IPv4_UC,
+ safiMulticast: bgp.RF_IPv4_MC,
+ safiMplsVpn: bgp.RF_IPv4_VPN,
+ safiEncap: bgp.RF_IPv4_ENCAP,
+ safiLabeledUnicast: bgp.RF_IPv4_MPLS,
+ safiFlowspec: bgp.RF_FS_IPv4_UC,
+}
+var safiRouteFamilyIPv6Map = map[Safi]bgp.RouteFamily{
+ safiUnspec: bgp.RF_OPAQUE,
+ SafiUnicast: bgp.RF_IPv6_UC,
+ safiMulticast: bgp.RF_IPv6_MC,
+ safiMplsVpn: bgp.RF_IPv6_VPN,
+ safiEncap: bgp.RF_IPv6_ENCAP,
+ safiLabeledUnicast: bgp.RF_IPv6_MPLS,
+ safiFlowspec: bgp.RF_FS_IPv6_UC,
+}
+
+// APIType is referred in zclient_test.
+//go:generate stringer -type=APIType
+type APIType uint16
+
+// For FRRouting version 7.3 (ZAPI version 6)
const (
- FRR_ZAPI6_INTERFACE_ADD API_TYPE = iota
- FRR_ZAPI6_INTERFACE_DELETE
- FRR_ZAPI6_INTERFACE_ADDRESS_ADD
- FRR_ZAPI6_INTERFACE_ADDRESS_DELETE
- FRR_ZAPI6_INTERFACE_UP
- FRR_ZAPI6_INTERFACE_DOWN
- FRR_ZAPI6_INTERFACE_SET_MASTER
- //FRR_ZAPI6_INTERFACE_SET_PROTODOWN // Add Frr 7.2
- FRR_ZAPI6_ROUTE_ADD
- FRR_ZAPI6_ROUTE_DELETE
- FRR_ZAPI6_ROUTE_NOTIFY_OWNER
- FRR_ZAPI6_REDISTRIBUTE_ADD
- FRR_ZAPI6_REDISTRIBUTE_DELETE
- FRR_ZAPI6_REDISTRIBUTE_DEFAULT_ADD
- FRR_ZAPI6_REDISTRIBUTE_DEFAULT_DELETE
- FRR_ZAPI6_ROUTER_ID_ADD
- FRR_ZAPI6_ROUTER_ID_DELETE
- FRR_ZAPI6_ROUTER_ID_UPDATE
- FRR_ZAPI6_HELLO
- FRR_ZAPI6_CAPABILITIES
- FRR_ZAPI6_NEXTHOP_REGISTER
- FRR_ZAPI6_NEXTHOP_UNREGISTER
- FRR_ZAPI6_NEXTHOP_UPDATE
- FRR_ZAPI6_INTERFACE_NBR_ADDRESS_ADD
- FRR_ZAPI6_INTERFACE_NBR_ADDRESS_DELETE
- FRR_ZAPI6_INTERFACE_BFD_DEST_UPDATE
- FRR_ZAPI6_IMPORT_ROUTE_REGISTER
- FRR_ZAPI6_IMPORT_ROUTE_UNREGISTER
- FRR_ZAPI6_IMPORT_CHECK_UPDATE
- FRR_ZAPI6_BFD_DEST_REGISTER
- FRR_ZAPI6_BFD_DEST_DEREGISTER
- FRR_ZAPI6_BFD_DEST_UPDATE
- FRR_ZAPI6_BFD_DEST_REPLAY
- FRR_ZAPI6_REDISTRIBUTE_ROUTE_ADD
- FRR_ZAPI6_REDISTRIBUTE_ROUTE_DEL
- FRR_ZAPI6_VRF_UNREGISTER
- FRR_ZAPI6_VRF_ADD
- FRR_ZAPI6_VRF_DELETE
- FRR_ZAPI6_VRF_LABEL
- FRR_ZAPI6_INTERFACE_VRF_UPDATE
- FRR_ZAPI6_BFD_CLIENT_REGISTER
- FRR_ZAPI6_BFD_CLIENT_DEREGISTER
- FRR_ZAPI6_INTERFACE_ENABLE_RADV
- FRR_ZAPI6_INTERFACE_DISABLE_RADV
- FRR_ZAPI6_IPV4_NEXTHOP_LOOKUP_MRIB
- FRR_ZAPI6_INTERFACE_LINK_PARAMS
- FRR_ZAPI6_MPLS_LABELS_ADD
- FRR_ZAPI6_MPLS_LABELS_DELETE
- FRR_ZAPI6_IPMR_ROUTE_STATS
- FRR_ZAPI6_LABEL_MANAGER_CONNECT
- FRR_ZAPI6_LABEL_MANAGER_CONNECT_ASYNC
- FRR_ZAPI6_GET_LABEL_CHUNK
- FRR_ZAPI6_RELEASE_LABEL_CHUNK
- FRR_ZAPI6_FEC_REGISTER
- FRR_ZAPI6_FEC_UNREGISTER
- FRR_ZAPI6_FEC_UPDATE
- FRR_ZAPI6_ADVERTISE_DEFAULT_GW
- FRR_ZAPI6_ADVERTISE_SUBNET
- FRR_ZAPI6_ADVERTISE_ALL_VNI
- FRR_ZAPI6_LOCAL_ES_ADD
- FRR_ZAPI6_LOCAL_ES_DEL
- FRR_ZAPI6_VNI_ADD
- FRR_ZAPI6_VNI_DEL
- FRR_ZAPI6_L3VNI_ADD
- FRR_ZAPI6_L3VNI_DEL
- FRR_ZAPI6_REMOTE_VTEP_ADD
- FRR_ZAPI6_REMOTE_VTEP_DEL
- FRR_ZAPI6_MACIP_ADD
- FRR_ZAPI6_MACIP_DEL
- FRR_ZAPI6_IP_PREFIX_ROUTE_ADD
- FRR_ZAPI6_IP_PREFIX_ROUTE_DEL
- FRR_ZAPI6_REMOTE_MACIP_ADD
- FRR_ZAPI6_REMOTE_MACIP_DEL
- FRR_ZAPI6_DUPLICATE_ADDR_DETECTION
- FRR_ZAPI6_PW_ADD
- FRR_ZAPI6_PW_DELETE
- FRR_ZAPI6_PW_SET
- FRR_ZAPI6_PW_UNSET
- FRR_ZAPI6_PW_STATUS_UPDATE
- FRR_ZAPI6_RULE_ADD
- FRR_ZAPI6_RULE_DELETE
- FRR_ZAPI6_RULE_NOTIFY_OWNER
- FRR_ZAPI6_TABLE_MANAGER_CONNECT
- FRR_ZAPI6_GET_TABLE_CHUNK
- FRR_ZAPI6_RELEASE_TABLE_CHUNK
- FRR_ZAPI6_IPSET_CREATE
- FRR_ZAPI6_IPSET_DESTROY
- FRR_ZAPI6_IPSET_ENTRY_ADD
- FRR_ZAPI6_IPSET_ENTRY_DELETE
- FRR_ZAPI6_IPSET_NOTIFY_OWNER
- FRR_ZAPI6_IPSET_ENTRY_NOTIFY_OWNER
- FRR_ZAPI6_IPTABLE_ADD
- FRR_ZAPI6_IPTABLE_DELETE
- FRR_ZAPI6_IPTABLE_NOTIFY_OWNER
- FRR_ZAPI6_VXLAN_FLOOD_CONTROL
+ interfaceAdd APIType = iota // 0 // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ interfaceDelete // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ interfaceAddressAdd // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ interfaceAddressDelete // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ interfaceUp // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ interfaceDown // same ID in frr3, 4, 5, 6, 7.0, 7.1. 7.2. 7.3
+ _interfaceSetMaster
+ _interfaceSetProtoDown // Add in frr 7.2
+ RouteAdd // RouteAdd is referred in zclient_test
+ RouteDelete // RouteDelete is referred in zclient_test
+ _routeNotifyOwner // 10
+ redistributeAdd
+ _redistributeDelete
+ _redistributeDefaultAdd
+ _redistributeDefaultDelete
+ routerIDAdd
+ _routerIDDelete
+ routerIDUpdate
+ hello
+ _capabilities // add in frr5
+ nexthopRegister // 20
+ nexthopUnregister
+ nexthopUpdate
+ _interfaceNBRAddressAdd
+ _interfaceNBRAddressDelete
+ _interfaceBFDDestUpdate
+ _importRouteRegister
+ _importRouteUnregister
+ _importCheckUpdate
+ _bfdDestRegister
+ _bfdDestDeregister // 30
+ _bfdDestUpdate
+ _bfdDestReplay
+ redistributeRouteAdd
+ redistributeRouteDel
+ _vrfUnregister
+ _vrfAdd
+ _vrfDelete
+ vrfLabel // add in frr5
+ _interfaceVRFUpdate
+ _bfdClientRegister // 40
+ _bfdClientDeregister
+ _interfaceEnableRADV
+ _interfaceDisableRADV
+ ipv4NexthopLookupMRIB
+ _interfaceLinkParams
+ _mplsLabelsAdd
+ _mplsLabelsDelete
+ _mplsLabelsReplace // add in frr7.3
+ _ipmrRouteStats
+ labelManagerConnect // 50
+ labelManagerConnectAsync // add in frr5
+ getLabelChunk
+ releaseLabelChunk
+ _fecRegister
+ _fecUnregister
+ _fecUpdate
+ _advertiseDefaultGW
+ _advertiseSviMACIP // add in frr7.1
+ _advertiseSubnet
+ _advertiseAllVNI // 60
+ _localESAdd
+ _localESDel
+ _vniAdd
+ _vniDel
+ _l3VNIAdd
+ _l3VNIDel
+ _remoteVTEPAdd
+ _remoteVTEPDel
+ _macIPAdd
+ _macIPDel // 70
+ _ipPrefixRouteAdd
+ _ipPrefixRouteDel
+ _remoteMACIPAdd
+ _remoteMACIPDel
+ _duplicateAddrDetection
+ _pwAdd
+ _pwDelete
+ _pwSet
+ _pwUnset
+ _pwStatusUpdate // 80
+ _ruleAdd
+ _ruleDelete
+ _ruleNotifyOwner
+ _tableManagerConnect
+ _getTableChunk
+ _releaseTableChunk
+ _ipSetCreate
+ _ipSetDestroy
+ _ipSetEntryAdd
+ _ipSetEntryDelete // 90
+ _ipSetNotifyOwner
+ _ipSetEntryNotifyOwner
+ _ipTableAdd
+ _ipTableDelete
+ _ipTableNotifyOwner
+ _vxlanFloodControl
+ _vxlanSgAdd
+ _vxlanSgDel
+ _vxlanSgReplay
+ _mlagProcessUp // 100 // add in frr7.3
+ _mlagProcessDown // add in frr7.3
+ _mlagClientRegister // add in frr7.3
+ _mlagClientUnregister // add in frr7.3
+ _mlagClientForwardMsg // add in frr7.3
+ zebraError // add in frr7.3
+ // BackwardIPv6RouteAdd is referred in zclient_test
+ BackwardIPv6RouteAdd // quagga, frr3, frr4, frr5
+ // BackwardIPv6RouteDelete is referred in zclient_test
+ BackwardIPv6RouteDelete // quagga, frr3, frr4, frr5
)
-
-// For FRRouting 5. (ZAPI version 5)
const (
- FRR_ZAPI5_INTERFACE_ADD API_TYPE = iota
- FRR_ZAPI5_INTERFACE_DELETE
- FRR_ZAPI5_INTERFACE_ADDRESS_ADD
- FRR_ZAPI5_INTERFACE_ADDRESS_DELETE
- FRR_ZAPI5_INTERFACE_UP
- FRR_ZAPI5_INTERFACE_DOWN
- FRR_ZAPI5_INTERFACE_SET_MASTER
- FRR_ZAPI5_ROUTE_ADD
- FRR_ZAPI5_ROUTE_DELETE
- FRR_ZAPI5_ROUTE_NOTIFY_OWNER
- FRR_ZAPI5_IPV4_ROUTE_ADD
- FRR_ZAPI5_IPV4_ROUTE_DELETE
- FRR_ZAPI5_IPV6_ROUTE_ADD
- FRR_ZAPI5_IPV6_ROUTE_DELETE
- FRR_ZAPI5_REDISTRIBUTE_ADD
- FRR_ZAPI5_REDISTRIBUTE_DELETE
- FRR_ZAPI5_REDISTRIBUTE_DEFAULT_ADD
- FRR_ZAPI5_REDISTRIBUTE_DEFAULT_DELETE
- FRR_ZAPI5_ROUTER_ID_ADD
- FRR_ZAPI5_ROUTER_ID_DELETE
- FRR_ZAPI5_ROUTER_ID_UPDATE
- FRR_ZAPI5_HELLO
- FRR_ZAPI5_CAPABILITIES
- FRR_ZAPI5_NEXTHOP_REGISTER
- FRR_ZAPI5_NEXTHOP_UNREGISTER
- FRR_ZAPI5_NEXTHOP_UPDATE
- FRR_ZAPI5_INTERFACE_NBR_ADDRESS_ADD
- FRR_ZAPI5_INTERFACE_NBR_ADDRESS_DELETE
- FRR_ZAPI5_INTERFACE_BFD_DEST_UPDATE
- FRR_ZAPI5_IMPORT_ROUTE_REGISTER
- FRR_ZAPI5_IMPORT_ROUTE_UNREGISTER
- FRR_ZAPI5_IMPORT_CHECK_UPDATE
- FRR_ZAPI5_IPV4_ROUTE_IPV6_NEXTHOP_ADD
- FRR_ZAPI5_BFD_DEST_REGISTER
- FRR_ZAPI5_BFD_DEST_DEREGISTER
- FRR_ZAPI5_BFD_DEST_UPDATE
- FRR_ZAPI5_BFD_DEST_REPLAY
- FRR_ZAPI5_REDISTRIBUTE_ROUTE_ADD
- FRR_ZAPI5_REDISTRIBUTE_ROUTE_DEL
- FRR_ZAPI5_VRF_UNREGISTER
- FRR_ZAPI5_VRF_ADD
- FRR_ZAPI5_VRF_DELETE
- FRR_ZAPI5_VRF_LABEL
- FRR_ZAPI5_INTERFACE_VRF_UPDATE
- FRR_ZAPI5_BFD_CLIENT_REGISTER
- FRR_ZAPI5_INTERFACE_ENABLE_RADV
- FRR_ZAPI5_INTERFACE_DISABLE_RADV
- FRR_ZAPI5_IPV4_NEXTHOP_LOOKUP_MRIB
- FRR_ZAPI5_INTERFACE_LINK_PARAMS
- FRR_ZAPI5_MPLS_LABELS_ADD
- FRR_ZAPI5_MPLS_LABELS_DELETE
- FRR_ZAPI5_IPMR_ROUTE_STATS
- FRR_ZAPI5_LABEL_MANAGER_CONNECT
- FRR_ZAPI5_LABEL_MANAGER_CONNECT_ASYNC
- FRR_ZAPI5_GET_LABEL_CHUNK
- FRR_ZAPI5_RELEASE_LABEL_CHUNK
- FRR_ZAPI5_FEC_REGISTER
- FRR_ZAPI5_FEC_UNREGISTER
- FRR_ZAPI5_FEC_UPDATE
- FRR_ZAPI5_ADVERTISE_DEFAULT_GW
- FRR_ZAPI5_ADVERTISE_SUBNET
- FRR_ZAPI5_ADVERTISE_ALL_VNI
- FRR_ZAPI5_VNI_ADD
- FRR_ZAPI5_VNI_DEL
- FRR_ZAPI5_L3VNI_ADD
- FRR_ZAPI5_L3VNI_DEL
- FRR_ZAPI5_REMOTE_VTEP_ADD
- FRR_ZAPI5_REMOTE_VTEP_DEL
- FRR_ZAPI5_MACIP_ADD
- FRR_ZAPI5_MACIP_DEL
- FRR_ZAPI5_IP_PREFIX_ROUTE_ADD
- FRR_ZAPI5_IP_PREFIX_ROUTE_DEL
- FRR_ZAPI5_REMOTE_MACIP_ADD
- FRR_ZAPI5_REMOTE_MACIP_DEL
- FRR_ZAPI5_PW_ADD
- FRR_ZAPI5_PW_DELETE
- FRR_ZAPI5_PW_SET
- FRR_ZAPI5_PW_UNSET
- FRR_ZAPI5_PW_STATUS_UPDATE
- FRR_ZAPI5_RULE_ADD
- FRR_ZAPI5_RULE_DELETE
- FRR_ZAPI5_RULE_NOTIFY_OWNER
- FRR_ZAPI5_TABLE_MANAGER_CONNECT
- FRR_ZAPI5_GET_TABLE_CHUNK
- FRR_ZAPI5_RELEASE_TABLE_CHUNK
- FRR_ZAPI5_IPSET_CREATE
- FRR_ZAPI5_IPSET_DESTROY
- FRR_ZAPI5_IPSET_ENTRY_ADD
- FRR_ZAPI5_IPSET_ENTRY_DELETE
- FRR_ZAPI5_IPSET_NOTIFY_OWNER
- FRR_ZAPI5_IPSET_ENTRY_NOTIFY_OWNER
- FRR_ZAPI5_IPTABLE_ADD
- FRR_ZAPI5_IPTABLE_DELETE
- FRR_ZAPI5_IPTABLE_NOTIFY_OWNER
+ zapi6Frr7dot2MinDifferentAPIType APIType = 48 //frr7.2(zapi6)
+ zapi5ClMinDifferentAPIType APIType = 19 //cumuluslinux3.7.7, zebra4.0+cl3u13(zapi5)
+ zapi5MinDifferentAPIType APIType = 7 //frr4&5(zapi5), frr6&7.0&7.1(zapi6)
+ zapi4MinDifferentAPIType APIType = 6
+ zapi3MinDifferentAPIType APIType = 0
)
-// For FRRouting version 3. (ZAPI version 4)
+func minDifferentAPIType(version uint8, softwareName string) APIType {
+ if version < 4 {
+ return zapi3MinDifferentAPIType
+ } else if version == 4 {
+ return zapi4MinDifferentAPIType
+ } else if version == 5 && softwareName == "cumulus" {
+ return zapi5ClMinDifferentAPIType
+ } else if version == 5 ||
+ (version == 6 && (softwareName == "frr6" || softwareName == "frr7" || softwareName == "frr7.1")) {
+ return zapi5MinDifferentAPIType
+ }
+ return zapi6Frr7dot2MinDifferentAPIType
+}
+
const (
- FRR_INTERFACE_ADD API_TYPE = iota
- FRR_INTERFACE_DELETE
- FRR_INTERFACE_ADDRESS_ADD
- FRR_INTERFACE_ADDRESS_DELETE
- FRR_INTERFACE_UP
- FRR_INTERFACE_DOWN
- FRR_IPV4_ROUTE_ADD
- FRR_IPV4_ROUTE_DELETE
- FRR_IPV6_ROUTE_ADD
- FRR_IPV6_ROUTE_DELETE
- FRR_REDISTRIBUTE_ADD
- FRR_REDISTRIBUTE_DELETE
- FRR_REDISTRIBUTE_DEFAULT_ADD
- FRR_REDISTRIBUTE_DEFAULT_DELETE
- FRR_ROUTER_ID_ADD
- FRR_ROUTER_ID_DELETE
- FRR_ROUTER_ID_UPDATE
- FRR_HELLO
- FRR_NEXTHOP_REGISTER
- FRR_NEXTHOP_UNREGISTER
- FRR_NEXTHOP_UPDATE
- FRR_INTERFACE_NBR_ADDRESS_ADD
- FRR_INTERFACE_NBR_ADDRESS_DELETE
- FRR_INTERFACE_BFD_DEST_UPDATE
- FRR_IMPORT_ROUTE_REGISTER
- FRR_IMPORT_ROUTE_UNREGISTER
- FRR_IMPORT_CHECK_UPDATE
- FRR_IPV4_ROUTE_IPV6_NEXTHOP_ADD
- FRR_BFD_DEST_REGISTER
- FRR_BFD_DEST_DEREGISTER
- FRR_BFD_DEST_UPDATE
- FRR_BFD_DEST_REPLAY
- FRR_REDISTRIBUTE_IPV4_ADD
- FRR_REDISTRIBUTE_IPV4_DEL
- FRR_REDISTRIBUTE_IPV6_ADD
- FRR_REDISTRIBUTE_IPV6_DEL
- FRR_VRF_UNREGISTER
- FRR_VRF_ADD
- FRR_VRF_DELETE
- FRR_INTERFACE_VRF_UPDATE
- FRR_BFD_CLIENT_REGISTER
- FRR_INTERFACE_ENABLE_RADV
- FRR_INTERFACE_DISABLE_RADV
- FRR_IPV4_NEXTHOP_LOOKUP_MRIB
- FRR_INTERFACE_LINK_PARAMS
- FRR_MPLS_LABELS_ADD
- FRR_MPLS_LABELS_DELETE
- FRR_IPV4_NEXTHOP_ADD
- FRR_IPV4_NEXTHOP_DELETE
- FRR_IPV6_NEXTHOP_ADD
- FRR_IPV6_NEXTHOP_DELETE
- FRR_IPMR_ROUTE_STATS
- FRR_LABEL_MANAGER_CONNECT
- FRR_GET_LABEL_CHUNK
- FRR_RELEASE_LABEL_CHUNK
- FRR_PW_ADD
- FRR_PW_DELETE
- FRR_PW_SET
- FRR_PW_UNSET
- FRR_PW_STATUS_UPDATE
+ zapi6Frr7dot2LabelManagerConnect APIType = 49 // difference from frr7.3
+ zapi6Frr7dot2LabelManagerConnectAsync APIType = 50 // difference from frr7.3
+ zapi6Frr7dot2GetLabelChunk APIType = 51 // difference from frr7.3
+ zapi6Frr7dot2ReleaseLabelChunk APIType = 52 // difference from frr7.3
)
-// For Quagga.
-const (
- _ API_TYPE = iota
- INTERFACE_ADD
- INTERFACE_DELETE
- INTERFACE_ADDRESS_ADD
- INTERFACE_ADDRESS_DELETE
- INTERFACE_UP
- INTERFACE_DOWN
- IPV4_ROUTE_ADD
- IPV4_ROUTE_DELETE
- IPV6_ROUTE_ADD
- IPV6_ROUTE_DELETE
- REDISTRIBUTE_ADD
- REDISTRIBUTE_DELETE
- REDISTRIBUTE_DEFAULT_ADD
- REDISTRIBUTE_DEFAULT_DELETE
- IPV4_NEXTHOP_LOOKUP
- IPV6_NEXTHOP_LOOKUP
- IPV4_IMPORT_LOOKUP
- IPV6_IMPORT_LOOKUP
- INTERFACE_RENAME
- ROUTER_ID_ADD
- ROUTER_ID_DELETE
- ROUTER_ID_UPDATE
- HELLO
- IPV4_NEXTHOP_LOOKUP_MRIB
- VRF_UNREGISTER
- INTERFACE_LINK_PARAMS
- NEXTHOP_REGISTER
- NEXTHOP_UNREGISTER
- NEXTHOP_UPDATE
- MESSAGE_MAX
+var apiTypeZapi6Frr7dot2Map = map[APIType]APIType{
+ labelManagerConnect: zapi6Frr7dot2LabelManagerConnect,
+ labelManagerConnectAsync: zapi6Frr7dot2LabelManagerConnectAsync,
+ getLabelChunk: zapi6Frr7dot2GetLabelChunk,
+ releaseLabelChunk: zapi6Frr7dot2ReleaseLabelChunk,
+}
+
+const ( // frr7.0, 7.1
+ zapi6Frr7RouteAdd APIType = 7
+ zapi6Frr7RouteDelete APIType = 8
+ zapi6Frr7RedistributAdd APIType = 10
+ zapi6Frr7RouterIDAdd APIType = 14
+ zapi6Frr7RouterIDUpdate APIType = 16
+ zapi6Frr7Hello APIType = 17
+ zapi6Frr7NexthopRegister APIType = 19
+ zapi6Frr7NexthopUnregister APIType = 20
+ zapi6Frr7NexthopUpdate APIType = 21
+ zapi6Frr7RedistributeRouteAdd APIType = 32
+ zapi6Frr7RedistributeRouteDel APIType = 33
+ zapi6Frr7VrfLabel APIType = 37
+ zapi6Frr7Ipv4NexthopLookupMRIB APIType = 43
+ zapi6Frr7LabelManagerConnect APIType = 48
+ zapi6Frr7LabelManagerConnectAsync APIType = 49
+ zapi6Frr7GetLabelChunk APIType = 50
+ zapi6Frr7ReleaseLabelChunk APIType = 51
+)
+
+var apiTypeZapi6Frr7Map = map[APIType]APIType{ // frr7.0, 7.1
+ RouteAdd: zapi6Frr7RouteAdd,
+ RouteDelete: zapi6Frr7RouteDelete,
+ redistributeAdd: zapi6Frr7RedistributAdd,
+ routerIDAdd: zapi6Frr7RouterIDAdd,
+ routerIDUpdate: zapi6Frr7RouterIDUpdate,
+ hello: zapi6Frr7Hello,
+ nexthopRegister: zapi6Frr7NexthopRegister,
+ nexthopUnregister: zapi6Frr7NexthopUnregister,
+ nexthopUpdate: zapi6Frr7NexthopUpdate,
+ redistributeRouteAdd: zapi6Frr7RedistributeRouteAdd,
+ redistributeRouteDel: zapi6Frr7RedistributeRouteDel,
+ vrfLabel: zapi6Frr7VrfLabel,
+ ipv4NexthopLookupMRIB: zapi6Frr7Ipv4NexthopLookupMRIB,
+ labelManagerConnect: zapi6Frr7LabelManagerConnect,
+ labelManagerConnectAsync: zapi6Frr7LabelManagerConnectAsync,
+ getLabelChunk: zapi6Frr7GetLabelChunk,
+ releaseLabelChunk: zapi6Frr7ReleaseLabelChunk,
+}
+
+var apiTypeZapi6Frr6Map = map[APIType]APIType{
+ RouteAdd: zapi6Frr7RouteAdd, // same as frr7.0&7.1
+ RouteDelete: zapi6Frr7RouteDelete, // same as frr7.0&7.1
+ redistributeAdd: zapi6Frr7RedistributAdd, // same as frr7.0&7.1
+ routerIDAdd: zapi6Frr7RouterIDAdd, // same as frr7.0&7.1
+ routerIDUpdate: zapi6Frr7RouterIDUpdate, // same as frr7.0&7.1
+ hello: zapi6Frr7Hello, // same as frr7.0&7.1
+ nexthopRegister: zapi6Frr7NexthopRegister, // same as frr7.0&7.1
+ nexthopUnregister: zapi6Frr7NexthopUnregister, // same as frr7.0&7.1
+ nexthopUpdate: zapi6Frr7NexthopUpdate, // same as frr7.0&7.1
+ redistributeRouteAdd: redistributeRouteAdd, // same as frr7.2&7.3
+ redistributeRouteDel: redistributeRouteDel, // same as frr7.2&7.3
+ vrfLabel: vrfLabel, // same as frr7.2&7.3
+ ipv4NexthopLookupMRIB: ipv4NexthopLookupMRIB, // same as frr7.2&7.3
+ labelManagerConnect: zapi6Frr7dot2LabelManagerConnect, // same as frr7.2
+ labelManagerConnectAsync: zapi6Frr7dot2LabelManagerConnectAsync, // same as frr7.2
+ getLabelChunk: zapi6Frr7dot2GetLabelChunk, // same as frr7.2
+ releaseLabelChunk: zapi6Frr7dot2ReleaseLabelChunk, // same as frr7.2
+}
+
+const ( // For Cumulus Linux 3.7.7, zebra 4.0+cl3u13 (ZAPI version 5)
+ zapi5ClIpv4NexthopLookupMRIB APIType = 42
+ zapi5ClLabelManagerConnect APIType = 47
+ zapi5ClGetLabelChunk APIType = 48
+ zapi5ClReleaseLabelChunk APIType = 49
)
-// Route Types.
-//go:generate stringer -type=ROUTE_TYPE
-type ROUTE_TYPE uint8
+var apiTypeZapi5ClMap = map[APIType]APIType{
+ nexthopRegister: zapi6Frr7NexthopRegister, // same as frr7.0&7.1
+ nexthopUnregister: zapi6Frr7NexthopUnregister, // same as frr7.0&7.1
+ nexthopUpdate: zapi6Frr7NexthopUpdate, // same as frr7.0&7.1
+ redistributeRouteAdd: zapi6Frr7RedistributeRouteAdd, // same as frr7.0&7.1
+ redistributeRouteDel: zapi6Frr7RedistributeRouteDel, // same as frr7.0&7.1
+ vrfLabel: zapi6Frr7VrfLabel, // same as frr7.0&7.1
+ labelManagerConnect: zapi5ClLabelManagerConnect,
+ getLabelChunk: zapi5ClGetLabelChunk,
+ releaseLabelChunk: zapi5ClReleaseLabelChunk,
+}
-// For FRRouting version 7 (ZAPI version 6).
const (
- FRR_ZAPI6_ROUTE_SYSTEM ROUTE_TYPE = iota
- FRR_ZAPI6_ROUTE_KERNEL
- FRR_ZAPI6_ROUTE_CONNECT
- FRR_ZAPI6_ROUTE_STATIC
- FRR_ZAPI6_ROUTE_RIP
- FRR_ZAPI6_ROUTE_RIPNG
- FRR_ZAPI6_ROUTE_OSPF
- FRR_ZAPI6_ROUTE_OSPF6
- FRR_ZAPI6_ROUTE_ISIS
- FRR_ZAPI6_ROUTE_BGP
- FRR_ZAPI6_ROUTE_PIM
- FRR_ZAPI6_ROUTE_EIGRP
- FRR_ZAPI6_ROUTE_NHRP
- FRR_ZAPI6_ROUTE_HSLS
- FRR_ZAPI6_ROUTE_OLSR
- FRR_ZAPI6_ROUTE_TABLE
- FRR_ZAPI6_ROUTE_LDP
- FRR_ZAPI6_ROUTE_VNC
- FRR_ZAPI6_ROUTE_VNC_DIRECT
- FRR_ZAPI6_ROUTE_VNC_DIRECT_RH
- FRR_ZAPI6_ROUTE_BGP_DIRECT
- FRR_ZAPI6_ROUTE_BGP_DIRECT_EXT
- FRR_ZAPI6_ROUTE_BABEL
- FRR_ZAPI6_ROUTE_SHARP
- FRR_ZAPI6_ROUTE_PBR
- FRR_ZAPI6_ROUTE_BFD
- FRR_ZAPI6_ROUTE_OPENFABRIC // FRRRouting version 7 adds.
- FRR_ZAPI6_ROUTE_VRRP // FRRRouting version 7.2 adds.
- FRR_ZAPI6_ROUTE_ALL
- FRR_ZAPI6_ROUTE_MAX
+ zapi5RedistributAdd APIType = 14
+ zapi5RouterIDAdd APIType = 18
+ zapi5RouterIDUpdate APIType = 20
+ zapi5Hello APIType = 21
+ zapi5Frr5NexthopRegister APIType = 23
+ zapi5Frr5NexthopUnregister APIType = 24
+ zapi5Frr5NexthopUpdate APIType = 25
+ zapi5Frr5RedistributeRouteAdd APIType = 37
+ zapi5Frr5RedistributeRouteDel APIType = 38
+ zapi5Frr5VrfLabel APIType = 42
+ zapi5Frr5Ipv4NexthopLookupMRIB APIType = 47
+ zapi5Frr5LabelManagerConnect APIType = 52
+ zapi5Frr5LabelManagerConnectAsync APIType = 53
+ zapi5Frr5GetLabelChunk APIType = 54
+ zapi5Frr5ReleaseLabelChunk APIType = 55
)
-// For FRRouting version 5 (ZAPI version 5).
+var apiTypeZapi5Frr5Map = map[APIType]APIType{
+ RouteAdd: zapi6Frr7RouteAdd, // same as frr7.0&7.1
+ RouteDelete: zapi6Frr7RouteDelete, // same as frr7.0&7.1
+ redistributeAdd: zapi5RedistributAdd,
+ routerIDAdd: zapi5RouterIDAdd,
+ routerIDUpdate: zapi5RouterIDUpdate,
+ hello: zapi5Hello,
+ nexthopRegister: zapi5Frr5NexthopRegister,
+ nexthopUnregister: zapi5Frr5NexthopUnregister,
+ nexthopUpdate: zapi5Frr5NexthopUpdate,
+ redistributeRouteAdd: zapi5Frr5RedistributeRouteAdd,
+ redistributeRouteDel: zapi5Frr5RedistributeRouteDel,
+ vrfLabel: zapi5Frr5VrfLabel,
+ ipv4NexthopLookupMRIB: zapi5Frr5Ipv4NexthopLookupMRIB,
+ labelManagerConnect: zapi5Frr5LabelManagerConnect,
+ labelManagerConnectAsync: zapi5Frr5LabelManagerConnectAsync,
+ getLabelChunk: zapi5Frr5GetLabelChunk,
+ releaseLabelChunk: zapi5Frr5ReleaseLabelChunk,
+}
+
const (
- FRR_ZAPI5_ROUTE_SYSTEM ROUTE_TYPE = iota
- FRR_ZAPI5_ROUTE_KERNEL
- FRR_ZAPI5_ROUTE_CONNECT
- FRR_ZAPI5_ROUTE_STATIC
- FRR_ZAPI5_ROUTE_RIP
- FRR_ZAPI5_ROUTE_RIPNG
- FRR_ZAPI5_ROUTE_OSPF
- FRR_ZAPI5_ROUTE_OSPF6
- FRR_ZAPI5_ROUTE_ISIS
- FRR_ZAPI5_ROUTE_BGP
- FRR_ZAPI5_ROUTE_PIM
- FRR_ZAPI5_ROUTE_EIGRP
- FRR_ZAPI5_ROUTE_NHRP
- FRR_ZAPI5_ROUTE_HSLS
- FRR_ZAPI5_ROUTE_OLSR
- FRR_ZAPI5_ROUTE_TABLE
- FRR_ZAPI5_ROUTE_LDP
- FRR_ZAPI5_ROUTE_VNC
- FRR_ZAPI5_ROUTE_VNC_DIRECT
- FRR_ZAPI5_ROUTE_VNC_DIRECT_RH
- FRR_ZAPI5_ROUTE_BGP_DIRECT
- FRR_ZAPI5_ROUTE_BGP_DIRECT_EXT
- FRR_ZAPI5_ROUTE_BABEL
- FRR_ZAPI5_ROUTE_SHARP
- FRR_ZAPI5_ROUTE_PBR // FRRRouting version 5 adds.
- FRR_ZAPI5_ROUTE_ALL
- FRR_ZAPI5_ROUTE_MAX
+ zapi5Frr4NexthopRegister APIType = 22
+ zapi5Frr4NexthopUnregister APIType = 23
+ zapi5Frr4NexthopUpdate APIType = 24
+ zapi5Frr4RedistributeRouteAdd APIType = 36
+ zapi5Frr4RedistributeRouteDel APIType = 37
+ zapi5Frr4Ipv4NexthopLookupMRIB APIType = 45
+ zapi5Frr4LabelManagerConnect APIType = 50
+ zapi5Frr4GetLabelChunk APIType = 51
+ zapi5Frr4ReleaseLabelChunk APIType = 52
)
-// For FRRouting.
+var apiTypeZapi5Frr4Map = map[APIType]APIType{
+ RouteAdd: zapi6Frr7RouteAdd, // same as frr7.0&7.1
+ RouteDelete: zapi6Frr7RouteDelete, // same as frr7.0&7.1
+ redistributeAdd: zapi5RedistributAdd,
+ routerIDAdd: zapi5RouterIDAdd,
+ routerIDUpdate: zapi5RouterIDUpdate,
+ hello: zapi5Hello,
+ nexthopRegister: zapi5Frr4NexthopRegister,
+ nexthopUnregister: zapi5Frr4NexthopUnregister,
+ nexthopUpdate: zapi5Frr4NexthopUpdate,
+ redistributeRouteAdd: zapi5Frr4RedistributeRouteAdd,
+ redistributeRouteDel: zapi5Frr4RedistributeRouteDel,
+ ipv4NexthopLookupMRIB: zapi5Frr4Ipv4NexthopLookupMRIB,
+ labelManagerConnect: zapi5Frr4LabelManagerConnect,
+ getLabelChunk: zapi5Frr4GetLabelChunk,
+ releaseLabelChunk: zapi5Frr4ReleaseLabelChunk,
+}
+
const (
- FRR_ROUTE_SYSTEM ROUTE_TYPE = iota
- FRR_ROUTE_KERNEL
- FRR_ROUTE_CONNECT
- FRR_ROUTE_STATIC
- FRR_ROUTE_RIP
- FRR_ROUTE_RIPNG
- FRR_ROUTE_OSPF
- FRR_ROUTE_OSPF6
- FRR_ROUTE_ISIS
- FRR_ROUTE_BGP
- FRR_ROUTE_PIM
- FRR_ROUTE_HSLS
- FRR_ROUTE_OLSR
- FRR_ROUTE_TABLE
- FRR_ROUTE_LDP
- FRR_ROUTE_VNC
- FRR_ROUTE_VNC_DIRECT
- FRR_ROUTE_VNC_DIRECT_RH
- FRR_ROUTE_BGP_DIRECT
- FRR_ROUTE_BGP_DIRECT_EXT
- FRR_ROUTE_ALL
- FRR_ROUTE_MAX
+ zapi4IPv4RouteAdd APIType = 6 // deleted in zapi6
+ zapi4IPv4RouteDelete APIType = 7 // deleted in zapi6
+ zapi4IPv6RouteAdd APIType = 8 // deleted in zapi6
+ zapi4IPv6RouteDelete APIType = 9 // deleted in zapi6
+ zapi4RedistributAdd APIType = 10
+ zapi4RouterIDAdd APIType = 14
+ zapi4RouterIDUpdate APIType = 16
+ zapi4Hello APIType = 17
+ zapi4NexthopRegister APIType = 18
+ zapi4NexthopUnregister APIType = 19
+ zapi4NexthopUpdate APIType = 20
+ zapi4RedistributeIPv4Add APIType = 32 // deleted in zapi6
+ zapi4RedistributeIPv4Del APIType = 33 // deleted in zapi6
+ zapi4RedistributeIPv6Add APIType = 34 // deleted in zapi6
+ zapi4RedistributeIPv6Del APIType = 35 // deleted in zapi6
+ zapi4LabelManagerConnect APIType = 52
+ zapi4GetLabelChunk APIType = 53
+ zapi4ReleaseLabelChunk APIType = 54
)
-// For Quagga.
+var apiTypeZapi4Map = map[APIType]APIType{
+ RouteAdd: zapi4IPv4RouteAdd, // deleted in zapi5
+ RouteDelete: zapi4IPv4RouteDelete, // deleted in zapi5
+ redistributeAdd: zapi4RedistributAdd,
+ routerIDAdd: zapi4RouterIDAdd,
+ routerIDUpdate: zapi4RouterIDUpdate,
+ hello: zapi4Hello,
+ nexthopRegister: zapi4NexthopRegister,
+ nexthopUnregister: zapi4NexthopUnregister,
+ nexthopUpdate: zapi4NexthopUpdate,
+ redistributeRouteAdd: zapi4RedistributeIPv4Add, // deleted in zapi5
+ redistributeRouteDel: zapi4RedistributeIPv4Del, // deleted in zapi5
+ ipv4NexthopLookupMRIB: zapi6Frr7Ipv4NexthopLookupMRIB, // same as frr7.0&7.1
+ labelManagerConnect: zapi4LabelManagerConnect,
+ getLabelChunk: zapi4GetLabelChunk,
+ releaseLabelChunk: zapi4ReleaseLabelChunk,
+ BackwardIPv6RouteAdd: zapi4IPv6RouteAdd,
+ BackwardIPv6RouteDelete: zapi4IPv6RouteDelete,
+}
+
const (
- ROUTE_SYSTEM ROUTE_TYPE = iota
- ROUTE_KERNEL
- ROUTE_CONNECT
- ROUTE_STATIC
- ROUTE_RIP
- ROUTE_RIPNG
- ROUTE_OSPF
- ROUTE_OSPF6
- ROUTE_ISIS
- ROUTE_BGP
- ROUTE_PIM
- ROUTE_HSLS
- ROUTE_OLSR
- ROUTE_BABEL
- ROUTE_NHRP // quagga 1.2.4
- ROUTE_MAX
+ zapi3InterfaceAdd APIType = 1
+ zapi3InterfaceDelete APIType = 2
+ zapi3InterfaceAddressAdd APIType = 3
+ zapi3InterfaceAddressDelete APIType = 4
+ zapi3InterfaceUp APIType = 5
+ zapi3InterfaceDown APIType = 6
+ zapi3IPv4RouteAdd APIType = 7 // deleted in zapi5
+ zapi3IPv4RouteDelete APIType = 8 // deleted in zapi5
+ zapi3IPv6RouteAdd APIType = 9 // deleted in zapi5
+ zapi3IPv6RouteDelete APIType = 10 // deleted in zapi5
+ zapi3RedistributeAdd APIType = 11
+ zapi3IPv4NexthopLookup APIType = 15 // zapi3(quagga) only
+ zapi3IPv6NexthopLookup APIType = 16 // zapi3(quagga) only
+ zapi3IPv4ImportLookup APIType = 17 // zapi3(quagga) only
+ zapi3RouterIDAdd APIType = 20
+ zapi3RouterIDUpdate APIType = 22
+ zapi3Hello APIType = 23
+ zapi3Ipv4NexthopLookupMRIB APIType = 24
+ zapi3NexthopRegister APIType = 27
+ zapi3NexthopUnregister APIType = 28
+ zapi3NexthopUpdate APIType = 29
)
-var routeTypeValueMapFrrZapi6 = map[string]ROUTE_TYPE{
- "system": FRR_ZAPI6_ROUTE_SYSTEM,
- "kernel": FRR_ZAPI6_ROUTE_KERNEL,
- "connect": FRR_ZAPI6_ROUTE_CONNECT, // hack for backward compatibility
- "directly-connected": FRR_ZAPI6_ROUTE_CONNECT,
- "static": FRR_ZAPI6_ROUTE_STATIC,
- "rip": FRR_ZAPI6_ROUTE_RIP,
- "ripng": FRR_ZAPI6_ROUTE_RIPNG,
- "ospf": FRR_ZAPI6_ROUTE_OSPF,
- "ospf3": FRR_ZAPI6_ROUTE_OSPF6,
- "isis": FRR_ZAPI6_ROUTE_ISIS,
- "bgp": FRR_ZAPI6_ROUTE_BGP,
- "pim": FRR_ZAPI6_ROUTE_PIM,
- "eigrp": FRR_ZAPI6_ROUTE_EIGRP,
- "nhrp": FRR_ZAPI6_ROUTE_EIGRP,
- "hsls": FRR_ZAPI6_ROUTE_HSLS,
- "olsr": FRR_ZAPI6_ROUTE_OLSR,
- "table": FRR_ZAPI6_ROUTE_TABLE,
- "ldp": FRR_ZAPI6_ROUTE_LDP,
- "vnc": FRR_ZAPI6_ROUTE_VNC,
- "vnc-direct": FRR_ZAPI6_ROUTE_VNC_DIRECT,
- "vnc-direct-rh": FRR_ZAPI6_ROUTE_VNC_DIRECT_RH,
- "bgp-direct": FRR_ZAPI6_ROUTE_BGP_DIRECT,
- "bgp-direct-ext": FRR_ZAPI6_ROUTE_BGP_DIRECT_EXT,
- "babel": FRR_ZAPI6_ROUTE_BABEL,
- "sharp": FRR_ZAPI6_ROUTE_SHARP,
- "pbr": FRR_ZAPI6_ROUTE_PBR,
- "bfd": FRR_ZAPI6_ROUTE_BFD,
- "openfabric": FRR_ZAPI6_ROUTE_OPENFABRIC,
- "vrrp": FRR_ZAPI6_ROUTE_VRRP,
- "all": FRR_ZAPI6_ROUTE_ALL,
-}
-
-var routeTypeValueMapFrrZapi5 = map[string]ROUTE_TYPE{
- "system": FRR_ZAPI5_ROUTE_SYSTEM,
- "kernel": FRR_ZAPI5_ROUTE_KERNEL,
- "connect": FRR_ZAPI5_ROUTE_CONNECT, // hack for backward compatibility
- "directly-connected": FRR_ZAPI5_ROUTE_CONNECT,
- "static": FRR_ZAPI5_ROUTE_STATIC,
- "rip": FRR_ZAPI5_ROUTE_RIP,
- "ripng": FRR_ZAPI5_ROUTE_RIPNG,
- "ospf": FRR_ZAPI5_ROUTE_OSPF,
- "ospf3": FRR_ZAPI5_ROUTE_OSPF6,
- "isis": FRR_ZAPI5_ROUTE_ISIS,
- "bgp": FRR_ZAPI5_ROUTE_BGP,
- "pim": FRR_ZAPI5_ROUTE_PIM,
- "eigrp": FRR_ZAPI5_ROUTE_EIGRP,
- "nhrp": FRR_ZAPI5_ROUTE_EIGRP,
- "hsls": FRR_ZAPI5_ROUTE_HSLS,
- "olsr": FRR_ZAPI5_ROUTE_OLSR,
- "table": FRR_ZAPI5_ROUTE_TABLE,
- "ldp": FRR_ZAPI5_ROUTE_LDP,
- "vnc": FRR_ZAPI5_ROUTE_VNC,
- "vnc-direct": FRR_ZAPI5_ROUTE_VNC_DIRECT,
- "vnc-direct-rh": FRR_ZAPI5_ROUTE_VNC_DIRECT_RH,
- "bgp-direct": FRR_ZAPI5_ROUTE_BGP_DIRECT,
- "bgp-direct-ext": FRR_ZAPI5_ROUTE_BGP_DIRECT_EXT,
- "babel": FRR_ZAPI5_ROUTE_BABEL,
- "sharp": FRR_ZAPI5_ROUTE_SHARP,
- "pbr": FRR_ZAPI5_ROUTE_PBR,
- "all": FRR_ZAPI5_ROUTE_ALL,
-}
-
-var routeTypeValueMapFrr = map[string]ROUTE_TYPE{
- "system": FRR_ROUTE_SYSTEM,
- "kernel": FRR_ROUTE_KERNEL,
- "connect": FRR_ROUTE_CONNECT, // hack for backward compatibility
- "directly-connected": FRR_ROUTE_CONNECT,
- "static": FRR_ROUTE_STATIC,
- "rip": FRR_ROUTE_RIP,
- "ripng": FRR_ROUTE_RIPNG,
- "ospf": FRR_ROUTE_OSPF,
- "ospf3": FRR_ROUTE_OSPF6,
- "isis": FRR_ROUTE_ISIS,
- "bgp": FRR_ROUTE_BGP,
- "pim": FRR_ROUTE_PIM,
- "hsls": FRR_ROUTE_HSLS,
- "olsr": FRR_ROUTE_OLSR,
- "table": FRR_ROUTE_TABLE,
- "ldp": FRR_ROUTE_LDP,
- "vnc": FRR_ROUTE_VNC,
- "vnc-direct": FRR_ROUTE_VNC_DIRECT,
- "vnc-direct-rh": FRR_ROUTE_VNC_DIRECT_RH,
- "bgp-direct": FRR_ROUTE_BGP_DIRECT,
- "bgp-direct-ext": FRR_ROUTE_BGP_DIRECT_EXT,
- "all": FRR_ROUTE_ALL,
-}
-
-var routeTypeValueMap = map[string]ROUTE_TYPE{
- "system": ROUTE_SYSTEM,
- "kernel": ROUTE_KERNEL,
- "connect": ROUTE_CONNECT, // hack for backward compatibility
- "directly-connected": ROUTE_CONNECT,
- "static": ROUTE_STATIC,
- "rip": ROUTE_RIP,
- "ripng": ROUTE_RIPNG,
- "ospf": ROUTE_OSPF,
- "ospf3": ROUTE_OSPF6,
- "isis": ROUTE_ISIS,
- "bgp": ROUTE_BGP,
- "pim": ROUTE_PIM,
- "hsls": ROUTE_HSLS,
- "olsr": ROUTE_OLSR,
- "babel": ROUTE_BABEL,
- "nhrp": ROUTE_NHRP,
-}
-
-func RouteTypeFromString(typ string, version uint8, softwareName string) (ROUTE_TYPE, error) {
- delegateRouteTypeValueMap := routeTypeValueMap
- if version == 4 {
- delegateRouteTypeValueMap = routeTypeValueMapFrr
+var apiTypeZapi3Map = map[APIType]APIType{
+ interfaceAdd: zapi3InterfaceAdd,
+ interfaceDelete: zapi3InterfaceDelete,
+ interfaceAddressAdd: zapi3InterfaceAddressAdd,
+ interfaceAddressDelete: zapi3InterfaceAddressDelete,
+ interfaceUp: zapi3InterfaceUp,
+ interfaceDown: zapi3InterfaceDown,
+ RouteAdd: zapi3IPv4RouteAdd, // deleted in zapi5
+ RouteDelete: zapi3IPv4RouteDelete, // deleted in zapi5
+ redistributeAdd: zapi3RedistributeAdd,
+ routerIDAdd: zapi3RouterIDAdd,
+ routerIDUpdate: zapi3RouterIDUpdate,
+ hello: zapi3Hello,
+ nexthopRegister: zapi3NexthopRegister,
+ nexthopUnregister: zapi3NexthopUnregister,
+ nexthopUpdate: zapi3NexthopUpdate,
+ BackwardIPv6RouteAdd: zapi3IPv6RouteAdd,
+ BackwardIPv6RouteDelete: zapi3IPv6RouteDelete,
+}
+
+func (t APIType) doesNeedConversion(version uint8, softwareName string) bool {
+ if (version == 6 && (softwareName == "frr7.3" || softwareName == "")) || t < minDifferentAPIType(version, softwareName) {
+ return false
+ }
+ return true
+}
+func apiTypeMap(version uint8, softwareName string) map[APIType]APIType {
+ if version == 6 && (softwareName == "frr7" || softwareName == "frr7.1") {
+ return apiTypeZapi6Frr7Map
+ } else if version == 6 && softwareName == "frr6" {
+ return apiTypeZapi6Frr6Map
} else if version == 5 {
- delegateRouteTypeValueMap = routeTypeValueMapFrrZapi5
- } else if version >= 6 {
- delegateRouteTypeValueMap = routeTypeValueMapFrrZapi6
+ if softwareName == "frr4" {
+ return apiTypeZapi5Frr4Map
+ } else if softwareName == "cumulus" {
+ return apiTypeZapi5ClMap
+ }
+ return apiTypeZapi5Frr5Map
+ } else if version == 4 {
+ return apiTypeZapi4Map
+ } else if version < 4 {
+ return apiTypeZapi3Map
+ }
+ return apiTypeZapi6Frr7dot2Map
+}
+
+// ToEach is referred in zclient_test
+func (t APIType) ToEach(version uint8, softwareName string) APIType {
+ if !t.doesNeedConversion(version, softwareName) {
+ return t
}
- t, ok := delegateRouteTypeValueMap[typ]
- if (version == 5 && softwareName == "frr4" && t == FRR_ZAPI5_ROUTE_PBR) ||
- (version == 6 && softwareName == "frr6" && t == FRR_ZAPI6_ROUTE_OPENFABRIC) ||
- (version == 6 && softwareName != "frr7.2" && t == FRR_ZAPI6_ROUTE_VRRP) {
- ok = false
+ apiMap := apiTypeMap(version, softwareName)
+ backward, ok := apiMap[t]
+ if !ok {
+ backward = zebraError // fail to convert and error value
}
- if ok {
- return t, nil
+ log.WithFields(log.Fields{
+ "Topic": "Zebra",
+ }).Debugf("zebra ToEach converts APIType: %d(%s) -> %d (version: %d, software: %s)",
+ t, t.String(), backward, version, softwareName)
+ return backward // success to convert
+}
+func (t APIType) toCommon(version uint8, softwareName string) APIType {
+ if !t.doesNeedConversion(version, softwareName) {
+ return t
+ }
+ apiMap := apiTypeMap(version, softwareName)
+ for common, backward := range apiMap {
+ if backward == t {
+ log.WithFields(log.Fields{
+ "Topic": "Zebra",
+ }).Debugf("zebra toCommon converts APIType: %d -> %d(%s) (version: %d, software: %s)",
+ t, common, common.String(), version, softwareName)
+ return common // success to convert
+ }
}
- return t, fmt.Errorf("unknown route type: %s in version: %d (%s)", typ, version, softwareName)
+ return zebraError // fail to convert and error value
}
-func addressFamilyFromApi(Api API_TYPE, version uint8) uint8 {
- //ZEBRA_IPV4_NEXTHOP_LOOKUP_MRIB is not implemented.
- if version <= 3 {
- switch Api {
- case IPV4_ROUTE_ADD, IPV4_ROUTE_DELETE, IPV4_NEXTHOP_LOOKUP, IPV4_IMPORT_LOOKUP:
- return syscall.AF_INET
- case IPV6_ROUTE_ADD, IPV6_ROUTE_DELETE, IPV6_NEXTHOP_LOOKUP, IPV6_IMPORT_LOOKUP:
- return syscall.AF_INET6
- }
- } else if version == 4 {
- switch Api {
- case FRR_REDISTRIBUTE_IPV4_ADD, FRR_REDISTRIBUTE_IPV4_DEL, FRR_IPV4_ROUTE_ADD, FRR_IPV4_ROUTE_DELETE, FRR_IPV4_NEXTHOP_LOOKUP_MRIB:
+func (t APIType) addressFamily(version uint8) uint8 {
+ if version == 4 {
+ switch t {
+ case zapi4IPv4RouteAdd, zapi4IPv4RouteDelete, zapi4RedistributeIPv4Add, zapi4RedistributeIPv4Del, zapi6Frr7Ipv4NexthopLookupMRIB:
return syscall.AF_INET
- case FRR_REDISTRIBUTE_IPV6_ADD, FRR_REDISTRIBUTE_IPV6_DEL, FRR_IPV6_ROUTE_ADD, FRR_IPV6_ROUTE_DELETE:
+ case zapi4IPv6RouteAdd, zapi4IPv6RouteDelete, zapi4RedistributeIPv6Add, zapi4RedistributeIPv6Del:
return syscall.AF_INET6
}
- } else if version == 5 {
- switch Api {
- case FRR_ZAPI5_IPV4_ROUTE_ADD, FRR_ZAPI5_IPV4_ROUTE_DELETE:
+ } else if version < 4 {
+ switch t {
+ case zapi3IPv4RouteAdd, zapi3IPv4RouteDelete, zapi3IPv4NexthopLookup, zapi3IPv4ImportLookup, zapi3Ipv4NexthopLookupMRIB:
return syscall.AF_INET
- case FRR_ZAPI5_IPV6_ROUTE_ADD, FRR_ZAPI5_IPV6_ROUTE_DELETE:
+ case zapi3IPv6RouteAdd, zapi3IPv6RouteDelete, zapi3IPv6NexthopLookup:
return syscall.AF_INET6
}
}
return syscall.AF_UNSPEC
}
+// RouteType is referred in zclient.
+//go:generate stringer -type=RouteType
+type RouteType uint8
+
+// For FRRouting version 7 (ZAPI version 6).
+const (
+ routeSystem RouteType = iota //0
+ routeKernel
+ routeConnect
+ RouteStatic
+ routeRIP
+ routeRIPNG
+ routeOSPF
+ routeOSPF6
+ routeISIS
+ RouteBGP
+ routePIM // 10
+ routeEIGRP // FRRRouting version 4 (Zapi5) adds.
+ routeNHRP
+ routeHSLS
+ routeOLSR
+ routeTABLE
+ routeLDP
+ routeVNC
+ routeVNCDirect
+ routeVNCDirectRH
+ routeBGPDirect
+ routeBGPDirectEXT
+ routeBABEL
+ routeSHARP
+ routePBR // FRRRouting version 5 (Zapi5) adds.
+ routeBFD // FRRRouting version 6 (Zapi6) adds.
+ routeOpenfabric // FRRRouting version 7 (Zapi6) adds.
+ routeVRRP // FRRRouting version 7.2 (Zapi6) adds.
+ routeNHG // FRRRouting version 7.3 (Zapi6) adds.
+ routeAll
+ routeMax // max value for error
+)
+const (
+ zapi5Frr4RouteAll RouteType = 24
+ zapi5Frr5RouteAll RouteType = 25
+ zapi6Frr6RouteAll RouteType = 26
+ zapi6Frr7RouteAll RouteType = 27
+ zapi6Frr7dot2RouteAll RouteType = 28
+)
+
+func getRouteAll(version uint8, softwareName string) RouteType {
+ if version == 5 {
+ if softwareName == "frr4" {
+ return zapi5Frr4RouteAll
+ }
+ return zapi5Frr5RouteAll
+ } else if version == 6 {
+ if softwareName == "frr6" {
+ return zapi6Frr6RouteAll
+ } else if softwareName == "frr7" || softwareName == "frr7.1" {
+ return zapi6Frr7RouteAll
+ } else if softwareName == "frr7.2" {
+ return zapi6Frr7dot2RouteAll
+ }
+ }
+ return routeAll
+}
+
+// For FRRouting version 3.0 except common route type.
+const (
+ zapi4RouteNHRP RouteType = iota + routePIM + 1
+ zapi4RouteHSLS
+ zapi4RouteOLSR
+ zapi4RouteTABLE
+ zapi4RouteLDP
+ zapi4RouteVNC
+ zapi4RouteVNCDirect
+ zapi4RouteVNCDirectRH
+ zapi4RouteBGPDixrect
+ zapi4RouteBGPDirectEXT
+ zapi4RouteAll
+)
+
+var routeTypeZapi4Map = map[RouteType]RouteType{
+ routeNHRP: zapi4RouteNHRP,
+ routeHSLS: zapi4RouteHSLS,
+ routeOLSR: zapi4RouteOLSR,
+ routeTABLE: zapi4RouteTABLE,
+ routeLDP: zapi4RouteLDP,
+ routeVNC: zapi4RouteVNC,
+ routeVNCDirect: zapi4RouteVNCDirect,
+ routeVNCDirectRH: zapi4RouteVNCDirectRH,
+ routeBGPDirect: zapi4RouteBGPDixrect,
+ routeBGPDirectEXT: zapi4RouteBGPDirectEXT,
+ routeAll: zapi4RouteAll,
+}
+
+// For Quagga except common route type.
+const (
+ zapi3RouteHSLS RouteType = iota + routePIM + 1
+ zapi3RouteOLSR
+ zapi3RouteBABEL
+ zapi3RouteNHRP // quagga 1.2.4
+)
+
+var routeTypeZapi3Map = map[RouteType]RouteType{
+ routeHSLS: zapi3RouteHSLS,
+ routeOLSR: zapi3RouteOLSR,
+ routeBABEL: zapi3RouteBABEL,
+ routeNHRP: zapi3RouteNHRP,
+}
+
+func (t RouteType) toEach(version uint8, softwareName string) RouteType {
+ if t <= routePIM || version > 4 { // not need to convert
+ return t
+ }
+ routeTypeMap := routeTypeZapi4Map
+ if version < 4 {
+ routeTypeMap = routeTypeZapi3Map
+ }
+ backward, ok := routeTypeMap[t]
+ if ok {
+ return backward // success to convert
+ }
+ return routeMax // fail to convert and error value
+}
+
+var routeTypeValueMap = map[string]RouteType{
+ "system": routeSystem,
+ "kernel": routeKernel,
+ "connect": routeConnect, // hack for backward compatibility
+ "directly-connected": routeConnect,
+ "static": RouteStatic,
+ "rip": routeRIP,
+ "ripng": routeRIPNG,
+ "ospf": routeOSPF,
+ "ospf3": routeOSPF6,
+ "isis": routeISIS,
+ "bgp": RouteBGP,
+ "pim": routePIM,
+ "eigrp": routeEIGRP, // add in frr4(zapi5)
+ "nhrp": routeNHRP,
+ "hsls": routeHSLS,
+ "olsr": routeOLSR,
+ "table": routeTABLE,
+ "ldp": routeLDP,
+ "vnc": routeVNC,
+ "vnc-direct": routeVNCDirect,
+ "vnc-rn": routeVNCDirectRH,
+ "bgp-direct": routeBGPDirect,
+ "bgp-direct-to-nve-groups": routeBGPDirectEXT,
+ "babel": routeBABEL,
+ "sharp": routeSHARP,
+ "pbr": routePBR,
+ "bfd": routeBFD,
+ "openfabric": routeOpenfabric, // add in frr7.0(zapi6)
+ "vrrp": routeVRRP, // add in frr7.2(zapi6)
+ "nhg": routeNHG, // add in frr7.3(zapi6)
+ "wildcard": routeAll,
+}
+
+// RouteTypeFromString converts from string to route type
+func RouteTypeFromString(typ string, version uint8, softwareName string) (RouteType, error) {
+ t, ok := routeTypeValueMap[typ]
+ if !ok { // failed to lookup RouteType from string
+ return t, fmt.Errorf("unknown route type: %s in version: %d (%s)", typ, version, softwareName)
+ }
+ t = t.toEach(version, softwareName) //when lookup failes return routeMax
+ if t > getRouteAll(version, softwareName) {
+ return t, fmt.Errorf("unknown route type: %d in version: %d (%s)", t, version, softwareName)
+ }
+ return t, nil // Success
+}
+
func addressByteLength(family uint8) (int, error) {
switch family {
case syscall.AF_INET:
@@ -794,265 +889,294 @@ func ipFromFamily(family uint8, buf []byte) net.IP {
return nil
}
-// API Message Flags.
-type MESSAGE_FLAG uint8
-
-// For FRRouting version 4, 5 and 6 (ZAPI version 5 and 6).
-const (
- FRR_ZAPI5_MESSAGE_NEXTHOP MESSAGE_FLAG = 0x01
- FRR_ZAPI5_MESSAGE_DISTANCE MESSAGE_FLAG = 0x02
- FRR_ZAPI5_MESSAGE_METRIC MESSAGE_FLAG = 0x04
- FRR_ZAPI5_MESSAGE_TAG MESSAGE_FLAG = 0x08
- FRR_ZAPI5_MESSAGE_MTU MESSAGE_FLAG = 0x10
- FRR_ZAPI5_MESSAGE_SRCPFX MESSAGE_FLAG = 0x20
- FRR_ZAPI5_MESSAGE_LABEL MESSAGE_FLAG = 0x40
- FRR_ZAPI5_MESSAGE_TABLEID MESSAGE_FLAG = 0x80
+// MessageFlag is the type of API Message Flags.
+type MessageFlag uint8
+
+const ( // For FRRouting version 4, 5 and 6 (ZAPI version 5 and 6).
+ // MessageNexthop is referred in zclient
+ MessageNexthop MessageFlag = 0x01
+ // MessageDistance is referred in zclient_test
+ MessageDistance MessageFlag = 0x02
+ // MessageMetric is referred in zclient
+ MessageMetric MessageFlag = 0x04
+ messageTag MessageFlag = 0x08
+ // MessageMTU is referred in zclient_test
+ MessageMTU MessageFlag = 0x10
+ messageSRCPFX MessageFlag = 0x20
+ // MessageLabel is referred in zclient
+ MessageLabel MessageFlag = 0x40 // deleted in frr7.3
+ messageTableID MessageFlag = 0x80 // introduced in frr5
)
-// For FRRouting.
-const (
- FRR_MESSAGE_NEXTHOP MESSAGE_FLAG = 0x01
- FRR_MESSAGE_IFINDEX MESSAGE_FLAG = 0x02
- FRR_MESSAGE_DISTANCE MESSAGE_FLAG = 0x04
- FRR_MESSAGE_METRIC MESSAGE_FLAG = 0x08
- FRR_MESSAGE_TAG MESSAGE_FLAG = 0x10
- FRR_MESSAGE_MTU MESSAGE_FLAG = 0x20
- FRR_MESSAGE_SRCPFX MESSAGE_FLAG = 0x40
+const ( // For FRRouting.
+ messageIFIndex MessageFlag = 0x02
+ zapi4MessageDistance MessageFlag = 0x04
+ zapi4MessageMetric MessageFlag = 0x08
+ zapi4MessageTag MessageFlag = 0x10
+ zapi4MessageMTU MessageFlag = 0x20
+ zapi4MessageSRCPFX MessageFlag = 0x40
)
-// For Quagga.
-const (
- MESSAGE_NEXTHOP MESSAGE_FLAG = 0x01
- MESSAGE_IFINDEX MESSAGE_FLAG = 0x02
- MESSAGE_DISTANCE MESSAGE_FLAG = 0x04
- MESSAGE_METRIC MESSAGE_FLAG = 0x08
- MESSAGE_MTU MESSAGE_FLAG = 0x10
- MESSAGE_TAG MESSAGE_FLAG = 0x20
+const ( // For Quagga.
+ zapi3MessageMTU MessageFlag = 0x10
+ zapi3MessageTag MessageFlag = 0x20
)
-func (t MESSAGE_FLAG) String(version uint8) string {
+// ToEach is referred in zclient
+func (f MessageFlag) ToEach(version uint8) MessageFlag {
+ if version > 4 { //zapi version 5, 6
+ return f
+ }
+ if version < 4 { //zapi version 3, 2
+ switch f {
+ case MessageMTU:
+ return zapi3MessageMTU
+ case messageTag:
+ return zapi3MessageTag
+ }
+ }
+ switch f { //zapi version 4
+ case MessageDistance, MessageMetric, messageTag, MessageMTU, messageSRCPFX:
+ return f << 1
+ }
+ return f
+}
+func (f MessageFlag) string(version uint8) string {
var ss []string
- if (version <= 3 && t&MESSAGE_NEXTHOP > 0) ||
- (version == 4 && t&FRR_MESSAGE_NEXTHOP > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_NEXTHOP > 0) {
+ if f&MessageNexthop > 0 {
ss = append(ss, "NEXTHOP")
}
- if (version <= 3 && t&MESSAGE_IFINDEX > 0) || (version == 4 && t&FRR_MESSAGE_IFINDEX > 0) {
+ if version < 4 && f&messageIFIndex > 0 {
ss = append(ss, "IFINDEX")
}
- if (version <= 3 && t&MESSAGE_DISTANCE > 0) ||
- (version == 4 && t&FRR_MESSAGE_DISTANCE > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_DISTANCE > 0) {
+ if f&MessageDistance.ToEach(version) > 0 {
ss = append(ss, "DISTANCE")
}
- if (version <= 3 && t&MESSAGE_METRIC > 0) ||
- (version == 4 && t&FRR_MESSAGE_METRIC > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_METRIC > 0) {
+ if f&MessageMetric.ToEach(version) > 0 {
ss = append(ss, "METRIC")
}
- if (version <= 3 && t&MESSAGE_MTU > 0) || (version == 4 && t&FRR_MESSAGE_MTU > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_MTU > 0) {
+ if f&MessageMTU.ToEach(version) > 0 {
ss = append(ss, "MTU")
}
- if (version <= 3 && t&MESSAGE_TAG > 0) || (version == 4 && t&FRR_MESSAGE_TAG > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_TAG > 0) {
+ if f&messageTag.ToEach(version) > 0 {
ss = append(ss, "TAG")
}
- if (version == 4 && t&FRR_MESSAGE_SRCPFX > 0) ||
- (version >= 5 && t&FRR_ZAPI5_MESSAGE_SRCPFX > 0) {
+ if version > 3 && f&messageSRCPFX.ToEach(version) > 0 {
ss = append(ss, "SRCPFX")
}
- if version >= 5 && t&FRR_ZAPI5_MESSAGE_LABEL > 0 {
+ if version > 4 && f&MessageLabel > 0 {
ss = append(ss, "LABEL")
}
-
+ if version > 5 && f&messageTableID > 0 {
+ ss = append(ss, "TABLEID")
+ }
return strings.Join(ss, "|")
}
-// Message Flags
-type FLAG uint64
-
-// For FRRouting version 7 (zebra API version 6)
-const (
- FRR_ZAPI6_FLAG_ALLOW_RECURSION FLAG = 0x01
- FRR_ZAPI6_FLAG_SELFROUTE FLAG = 0x02
- FRR_ZAPI6_FLAG_IBGP FLAG = 0x04
- FRR_ZAPI6_FLAG_SELECTED FLAG = 0x08
- FRR_ZAPI6_FLAG_FIB_OVERRIDE FLAG = 0x10
- FRR_ZAPI6_FLAG_EVPN_ROUTE FLAG = 0x20
- FRR_ZAPI6_FLAG_RR_USE_DISTANCE FLAG = 0x40
- FRR_ZAPI6_FLAG_ONLINk FLAG = 0x40
+// Flag is Message Flag which is referred in zclient
+type Flag uint64
+
+const ( // For FRRouting version 7 (zebra API version 6)
+ // FlagAllowRecursion is referred in zclient, and it is renamed from ZEBRA_FLAG_INTERNAL (https://github.com/FRRouting/frr/commit/4e8b02f4df5d6bcfde6390955b8feda2a17dc9bd)
+ FlagAllowRecursion Flag = 0x01 // quagga, frr3, frr4, frr5, frr6, frr7
+ flagSelfRoute Flag = 0x02 // quagga, frr3, frr4, frr5, frr6, frr7
+ // FlagIBGP is referred in zclient
+ FlagIBGP Flag = 0x04
+ // FlagSelected referred in zclient_test
+ FlagSelected Flag = 0x08
+ flagFIBOverride Flag = 0x10
+ flagEvpnRoute Flag = 0x20
+ flagRRUseDistance Flag = 0x40
+ flagOnlink Flag = 0x80 // frr7.0 only, this vale is deleted in frr7.1
)
-// For Quagga (ZAPI v2, v3), FRR v3 (ZAPI v4), FRR v4, v5 (ZAPI v5), FRR v6 (ZAPI v6)
+// For Quagga (ZAPI v2, v3), FRR v3 (ZAPI v4), FRR v4, v5 (ZAPI v5), FRR v6 (ZAPI v6) for backward compatibility
const (
- // Rename ZEBRA_FLAG_INTERNAL -> ZEBRA_FLAG_ALLOW_RECURSION
- // https://github.com/FRRouting/frr/commit/4e8b02f4df5d6bcfde6390955b8feda2a17dc9bd
- FLAG_ALLOW_RECURSION FLAG = 0x01
- FLAG_SELFROUTE FLAG = 0x02
- FLAG_BLACKHOLE FLAG = 0x04 // quagga, frr3
- FLAG_IBGP FLAG = 0x08
- FLAG_SELECTED FLAG = 0x10
- FLAG_CHANGED FLAG = 0x20
- FLAG_STATIC FLAG = 0x40
- FLAG_REJECT FLAG = 0x80 // quagga, frr3
- FLAG_SCOPE_LINK FLAG = 0x100
- FLAG_FIB_OVERRIDE FLAG = 0x200
- FLAG_EVPN_ROUTE FLAG = 0x400
- FLAG_RR_USE_DISTANCE FLAG = 0x800
+ flagBlackhole Flag = 0x04 // quagga, frr3
+ flagStatic Flag = 0x40 // quagga, frr3, frr4, frr5, frr6
+ flagReject Flag = 0x80 // quagga, frr3
+ flagScopeLink Flag = 0x100 // frr4, frr5, frr6
)
-func (t FLAG) String(version uint8, softwareName string) string {
- if version == 6 && softwareName != "frr6" {
- return t.stringFrrZapi6()
+// ToEach is referred in zclient
+func (f Flag) ToEach(version uint8, softwareName string) Flag {
+ if (version == 6 && softwareName != "frr6") || (f < FlagIBGP) || f > flagRRUseDistance {
+ return f
+ }
+ switch f {
+ case FlagIBGP, FlagSelected: // 0x04->0x08,0x08->0x10(quagga, frr3,4,5,6)
+ return f << 1
+ case flagEvpnRoute, flagRRUseDistance: // 0x20->0x400,0x40->0x800(frr4,5,6)
+ return f << 5
+ case flagFIBOverride:
+ if version < 4 {
+ return f << 1 // 0x10->0x20(quagga)
+ }
+ return f << 5 // 0x10->0x200(frr3, frr4, frr5, frr6)
}
- return t.string()
+ return f
}
-func (t FLAG) string() string {
+// String is referred in zclient
+func (f Flag) String(version uint8, softwareName string) string {
var ss []string
- if t&FLAG_ALLOW_RECURSION > 0 {
+ // common flag
+ if f&FlagAllowRecursion > 0 {
ss = append(ss, "FLAG_ALLOW_RECURSION")
}
- if t&FLAG_SELFROUTE > 0 {
+ if f&flagSelfRoute > 0 {
ss = append(ss, "FLAG_SELFROUTE")
}
- if t&FLAG_BLACKHOLE > 0 {
- ss = append(ss, "FLAG_BLACKHOLE")
- }
- if t&FLAG_IBGP > 0 {
+ if f&FlagIBGP.ToEach(version, softwareName) > 0 {
ss = append(ss, "FLAG_IBGP")
}
- if t&FLAG_SELECTED > 0 {
+ if f&FlagSelected.ToEach(version, softwareName) > 0 {
ss = append(ss, "FLAG_SELECTED")
}
- if t&FLAG_CHANGED > 0 {
- ss = append(ss, "FLAG_CHANGED")
- }
- if t&FLAG_STATIC > 0 {
- ss = append(ss, "FLAG_STATIC")
- }
- if t&FLAG_REJECT > 0 {
- ss = append(ss, "FLAG_REJECT")
- }
- if t&FLAG_SCOPE_LINK > 0 {
- ss = append(ss, "FLAG_SCOPE_LINK")
- }
- if t&FLAG_FIB_OVERRIDE > 0 {
- ss = append(ss, "FLAG_FIB_OVERRIDE")
- }
- if t&FLAG_EVPN_ROUTE > 0 {
+ if f&flagEvpnRoute.ToEach(version, softwareName) > 0 {
ss = append(ss, "FLAG_EVPN_ROUTE")
}
- if t&FLAG_RR_USE_DISTANCE > 0 {
+ if f&flagRRUseDistance.ToEach(version, softwareName) > 0 {
ss = append(ss, "FLAG_RR_USE_DISTANCE")
}
-
- return strings.Join(ss, "|")
-}
-func (t FLAG) stringFrrZapi6() string {
- var ss []string
- if t&FRR_ZAPI6_FLAG_ALLOW_RECURSION > 0 {
- ss = append(ss, "FLAG_ALLOW_RECURSION")
- }
- if t&FRR_ZAPI6_FLAG_SELFROUTE > 0 {
- ss = append(ss, "FLAG_SELFROUTE")
- }
- if t&FRR_ZAPI6_FLAG_IBGP > 0 {
- ss = append(ss, "FLAG_IBGP")
+ if f&flagFIBOverride.ToEach(version, softwareName) > 0 {
+ ss = append(ss, "FLAG_FIB_OVERRIDE")
}
- if t&FRR_ZAPI6_FLAG_SELECTED > 0 {
- ss = append(ss, "FLAG_SELECTED")
+ if version == 6 && softwareName == "frr7" && f&flagOnlink > 0 { // frr7.0 only
+ ss = append(ss, "FLAG_ONLINK")
}
- if t&FRR_ZAPI6_FLAG_FIB_OVERRIDE > 0 {
- ss = append(ss, "FLAG_FIB_OVERRIDE")
+ if (version < 6 || (version == 6 && softwareName == "frr6")) && f&flagStatic > 0 {
+ ss = append(ss, "FLAG_STATIC") // quagga, frr3, frr4, frr5, frr6
}
- if t&FRR_ZAPI6_FLAG_EVPN_ROUTE > 0 {
- ss = append(ss, "FLAG_EVPN_ROUTE")
+ if version < 5 && f&flagBlackhole > 0 { // quagga, frr3
+ ss = append(ss, "FLAG_BLACKHOLE")
}
- if t&FRR_ZAPI6_FLAG_RR_USE_DISTANCE > 0 {
- ss = append(ss, "FLAG_RR_USE_DISTANCE")
+ if version < 5 && f&flagReject > 0 { // quagga, frr3
+ ss = append(ss, "FLAG_REJECT")
}
- if t&FRR_ZAPI6_FLAG_ONLINk > 0 {
- ss = append(ss, "FLAG_ONLINK")
+ if (version == 5 || (version == 6 && softwareName == "frr6")) && f&flagScopeLink > 0 {
+ ss = append(ss, "FLAG_SCOPE_LINK") // frr4, frr5, frr6
}
return strings.Join(ss, "|")
}
// Nexthop Types.
-//go:generate stringer -type=NEXTHOP_TYPE
-type NEXTHOP_TYPE uint8
+//go:generate stringer -type=nexthopType
+type nexthopType uint8
// For FRRouting.
const (
- _ NEXTHOP_TYPE = iota
- FRR_NEXTHOP_TYPE_IFINDEX
- FRR_NEXTHOP_TYPE_IPV4
- FRR_NEXTHOP_TYPE_IPV4_IFINDEX
- FRR_NEXTHOP_TYPE_IPV6
- FRR_NEXTHOP_TYPE_IPV6_IFINDEX
- FRR_NEXTHOP_TYPE_BLACKHOLE
+ _ nexthopType = iota
+ nexthopTypeIFIndex // 1
+ nexthopTypeIPv4 // 2
+ nexthopTypeIPv4IFIndex // 3
+ nexthopTypeIPv6 // 4
+ nexthopTypeIPv6IFIndex // 5
+ nexthopTypeBlackhole // 6
)
// For Quagga.
const (
- _ NEXTHOP_TYPE = iota
- NEXTHOP_TYPE_IFINDEX
- NEXTHOP_TYPE_IFNAME
- NEXTHOP_TYPE_IPV4
- NEXTHOP_TYPE_IPV4_IFINDEX
- NEXTHOP_TYPE_IPV4_IFNAME
- NEXTHOP_TYPE_IPV6
- NEXTHOP_TYPE_IPV6_IFINDEX
- NEXTHOP_TYPE_IPV6_IFNAME
- NEXTHOP_TYPE_BLACKHOLE
+ nexthopTypeIFName nexthopType = iota + 2 // 2
+ backwardNexthopTypeIPv4 // 3
+ backwardNexthopTypeIPv4IFIndex // 4
+ nexthopTypeIPv4IFName // 5
+ backwardNexthopTypeIPv6 // 6
+ backwardNexthopTypeIPv6IFIndex // 7
+ nexthopTypeIPv6IFName // 8
+ backwardNexthopTypeBlackhole // 9
)
+var nexthopTypeMap = map[nexthopType]nexthopType{
+ nexthopTypeIPv4: backwardNexthopTypeIPv4, // 2 -> 3
+ nexthopTypeIPv4IFIndex: backwardNexthopTypeIPv4IFIndex, // 3 -> 4
+ nexthopTypeIPv6: backwardNexthopTypeIPv6, // 4 -> 6
+ nexthopTypeIPv6IFIndex: backwardNexthopTypeIPv6IFIndex, // 5 -> 7
+ nexthopTypeBlackhole: backwardNexthopTypeBlackhole, // 6 -> 9
+}
+
+func (t nexthopType) toEach(version uint8) nexthopType {
+ if version > 3 { // frr
+ return t
+ }
+ if t == nexthopTypeIFIndex || t > nexthopTypeBlackhole { // 1 (common), 7, 8, 9 (out of map range)
+ return t
+ }
+ backward, ok := nexthopTypeMap[t]
+ if ok {
+ return backward // converted value
+ }
+ return nexthopType(0) // error for conversion
+}
+
+func (t nexthopType) ipToIPIFIndex() nexthopType {
+ // process of nexthopTypeIPv[4|6] is same as nexthopTypeIPv[4|6]IFIndex
+ // in IPRouteBode of frr7.3 and NexthoUpdate of frr
+ if t == nexthopTypeIPv4 {
+ return nexthopTypeIPv4IFIndex
+ } else if t == nexthopTypeIPv6 {
+ return nexthopTypeIPv6IFIndex
+ }
+ return t
+}
+func (t nexthopType) ifNameToIFIndex() nexthopType { // quagga
+ if t == nexthopTypeIFName {
+ return nexthopTypeIFIndex
+ } else if t == nexthopTypeIPv4IFName {
+ return backwardNexthopTypeIPv4IFIndex
+ } else if t == nexthopTypeIPv6IFName {
+ return backwardNexthopTypeIPv6IFIndex
+ }
+ return t
+}
+
// Nexthop Flags.
-//go:generate stringer -type=NEXTHOP_FLAG
-type NEXTHOP_FLAG uint8
+//go:generate stringer -type=nexthopFlag
+type nexthopFlag uint8
const (
- NEXTHOP_FLAG_ACTIVE NEXTHOP_FLAG = 0x01 // This nexthop is alive.
- NEXTHOP_FLAG_FIB NEXTHOP_FLAG = 0x02 // FIB nexthop.
- NEXTHOP_FLAG_RECURSIVE NEXTHOP_FLAG = 0x04 // Recursive nexthop.
- NEXTHOP_FLAG_ONLINK NEXTHOP_FLAG = 0x08 // Nexthop should be installed onlink.
- NEXTHOP_FLAG_MATCHED NEXTHOP_FLAG = 0x10 // Already matched vs a nexthop
- NEXTHOP_FLAG_FILTERED NEXTHOP_FLAG = 0x20 // rmap filtered (version >= 4)
- NEXTHOP_FLAG_DUPLICATE NEXTHOP_FLAG = 0x40 // nexthop duplicates (version >= 5)
- NEXTHOP_FLAG_EVPN_RVTEP NEXTHOP_FLAG = 0x80 // EVPN remote vtep nexthop (version >= 5)
+ nexthopFlagActive nexthopFlag = 0x01 // This nexthop is alive.
+ nexthopFlagFIB nexthopFlag = 0x02 // FIB nexthop.
+ nexthopFlagRecursive nexthopFlag = 0x04 // Recursive nexthop.
+ nexthopFlagOnlink nexthopFlag = 0x08 // Nexthop should be installed onlink.
+ nexthopFlagMatched nexthopFlag = 0x10 // Already matched vs a nexthop
+ nexthopFlagFiltered nexthopFlag = 0x20 // rmap filtered (version >= 4)
+ nexthopFlagDuplicate nexthopFlag = 0x40 // nexthop duplicates (version >= 5)
+ nexthopFlagEvpnRvtep nexthopFlag = 0x80 // Evpn remote vtep nexthop (version >= 5)
)
// Interface PTM Enable Configuration.
-//go:generate stringer -type=PTM_ENABLE
-type PTM_ENABLE uint8
+//go:generate stringer -type=ptmEnable
+type ptmEnable uint8
const (
- PTM_ENABLE_OFF PTM_ENABLE = 0
- PTM_ENABLE_ON PTM_ENABLE = 1
- PTM_ENABLE_UNSPEC PTM_ENABLE = 2
+ ptmEnableOff ptmEnable = 0
+ ptmEnableOn ptmEnable = 1
+ ptmEnableUnspec ptmEnable = 2
)
// PTM Status.
-//go:generate stringer -type=PTM_STATUS
-type PTM_STATUS uint8
+//go:generate stringer -type=ptmStatus
+type ptmStatus uint8
const (
- PTM_STATUS_DOWN PTM_STATUS = 0
- PTM_STATUS_UP PTM_STATUS = 1
- PTM_STATUS_UNKNOWN PTM_STATUS = 2
+ ptmStatusDown ptmStatus = 0
+ ptmStatusUp ptmStatus = 1
+ ptmStatusUnknown ptmStatus = 2
)
+// Client is zebra client which is referred in zclient
type Client struct {
outgoing chan *Message
incoming chan *Message
- redistDefault ROUTE_TYPE
+ redistDefault RouteType
conn net.Conn
Version uint8
SoftwareName string
}
-func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software string) (*Client, error) {
+// NewClient returns a Client instance (Client constructor)
+func NewClient(network, address string, typ RouteType, version uint8, software string, mplsLabelRangeSize uint32) (*Client, error) {
conn, err := net.Dial(network, address)
if err != nil {
return nil, err
@@ -1069,7 +1193,7 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
if ((version == 2 || version == 3) && software != "" && software != "quagga") ||
(version == 4 && software != "" && software != "frr3") ||
(version == 5 && software != "" && software != "frr4" && software != "frr5" && software != "cumulus") ||
- (version == 6 && software != "" && software != "frr6" && software != "frr7" && software != "frr7.1" && software != "frr7.2") {
+ (version == 6 && software != "" && software != "frr6" && software != "frr7" && software != "frr7.1" && software != "frr7.2" && software != "frr7.3") {
isAllowableSoftware = false
}
if !isAllowableSoftware {
@@ -1092,7 +1216,7 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
for {
m, more := <-outgoing
if more {
- b, err := m.Serialize(software)
+ b, err := m.serialize(software)
if err != nil {
log.WithFields(log.Fields{
"Topic": "Zebra",
@@ -1115,13 +1239,12 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
}
}()
- // Send HELLO/ROUTER_ID_ADD messages to negotiate the Zebra message version.
+ // Send Hello/RouterIDAdd messages to negotiate the Zebra message version.
c.SendHello()
c.SendRouterIDAdd()
- // ZAPIv5 has ZEBRA_LABEL_MANAGER_CONNECT_ASYNC, however frr4 (ZAPIv5) doesn't have it.
- if version > 4 && software != "frr4" {
- c.SendLabelManagerConnectAsync()
+ if mplsLabelRangeSize > 0 && c.SupportMpls() {
+ c.sendLabelManagerConnect(true)
}
receiveSingleMsg := func() (*Message, error) {
@@ -1135,7 +1258,7 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
}
hd := &Header{}
- err = hd.DecodeFromBytes(headerBuf)
+ err = hd.decodeFromBytes(headerBuf)
if c.Version != hd.Version {
log.WithFields(log.Fields{
"Topic": "Zebra",
@@ -1161,11 +1284,10 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
return nil, err
}
- m, err := ParseMessage(hd, bodyBuf, software)
+ m, err := parseMessage(hd, bodyBuf, software)
if err != nil {
// Just outputting warnings (not error message) and ignore this
- // error considering the case that body parser is not implemented
- // yet.
+ // error considering the case that body parser is not implemented yet.
log.WithFields(log.Fields{
"Topic": "Zebra",
"Header": hd,
@@ -1184,7 +1306,7 @@ func NewClient(network, address string, typ ROUTE_TYPE, version uint8, software
// Try to receive the first message from Zebra.
if m, err := receiveSingleMsg(); err != nil {
- c.Close()
+ c.close()
// Return error explicitly in order to retry connection.
return nil, err
} else if m != nil {
@@ -1212,11 +1334,12 @@ func readAll(conn net.Conn, length int) ([]byte, error) {
return buf, err
}
+// Receive return incoming channel message
func (c *Client) Receive() chan *Message {
return c.incoming
}
-func (c *Client) Send(m *Message) {
+func (c *Client) send(m *Message) {
defer func() {
if err := recover(); err != nil {
log.WithFields(log.Fields{
@@ -1232,292 +1355,152 @@ func (c *Client) Send(m *Message) {
c.outgoing <- m
}
-func (c *Client) SendCommand(command API_TYPE, vrfId uint32, body Body) error {
- marker := HEADER_MARKER
- if c.Version >= 4 {
- marker = FRR_HEADER_MARKER
- }
- if c.Version == 6 && c.SoftwareName == "frr6" {
- if frr6Command, err := frr6Zapi6Command(command, c.SoftwareName, false); err == nil {
- command = frr6Command
- } else {
- return err
- }
- } else if c.Version == 6 && c.SoftwareName == "frr7.2" {
- // frr7.2 adds INTERFACE_SET_PROTODOWN between INTERFACE_SET_MASTER(6) and ROUTE_ADD
- if command >= FRR_ZAPI6_ROUTE_ADD {
- command++
- }
- } else if c.Version == 5 && c.SoftwareName == "frr4" {
- if frr4Command, err := frr4Zapi5Command(command, c.SoftwareName, false); err == nil {
- command = frr4Command
- } else {
- return err
- }
- } else if c.Version == 5 && c.SoftwareName == "cumulus" {
- if cumulusCommand, err := cumulusZapi5Command(command, c.SoftwareName, false); err == nil {
- command = cumulusCommand
- } else {
- return err
- }
- }
+func (c *Client) sendCommand(command APIType, vrfID uint32, body Body) error {
m := &Message{
Header: Header{
Len: HeaderSize(c.Version),
- Marker: marker,
+ Marker: HeaderMarker(c.Version),
Version: c.Version,
- VrfId: vrfId,
- Command: command,
+ VrfID: vrfID,
+ Command: command.ToEach(c.Version, c.SoftwareName),
},
Body: body,
}
- c.Send(m)
+ c.send(m)
return nil
}
+// SendHello sends HELLO message to zebra daemon.
func (c *Client) SendHello() error {
if c.redistDefault > 0 {
- command := HELLO
- if c.Version == 4 {
- command = FRR_HELLO
- } else if c.Version == 5 {
- command = FRR_ZAPI5_HELLO
- } else if c.Version >= 6 {
- command = FRR_ZAPI6_HELLO
+ body := &helloBody{
+ redistDefault: c.redistDefault,
+ instance: 0,
}
- body := &HelloBody{
- RedistDefault: c.redistDefault,
- Instance: 0,
- }
- return c.SendCommand(command, VRF_DEFAULT, body)
+ return c.sendCommand(hello, DefaultVrf, body)
}
return nil
}
+// SendRouterIDAdd sends ROUTER_ID_ADD message to zebra daemon.
func (c *Client) SendRouterIDAdd() error {
- command := ROUTER_ID_ADD
- if c.Version == 4 {
- command = FRR_ROUTER_ID_ADD
- } else if c.Version == 5 {
- command = FRR_ZAPI5_ROUTER_ID_ADD
- } else if c.Version >= 6 {
- command = FRR_ZAPI6_ROUTER_ID_ADD
- }
- return c.SendCommand(command, VRF_DEFAULT, nil)
+ return c.sendCommand(routerIDAdd, DefaultVrf, nil)
}
+// SendInterfaceAdd sends INTERFACE_ADD message to zebra daemon.
func (c *Client) SendInterfaceAdd() error {
- command := INTERFACE_ADD
- if c.Version == 4 {
- command = FRR_INTERFACE_ADD
- } else if c.Version >= 5 {
- command = FRR_ZAPI5_INTERFACE_ADD
- }
- return c.SendCommand(command, VRF_DEFAULT, nil)
+ return c.sendCommand(interfaceAdd, DefaultVrf, nil)
}
-func (c *Client) SendRedistribute(t ROUTE_TYPE, vrfId uint32) error {
- command := REDISTRIBUTE_ADD
+// SendRedistribute sends REDISTRIBUTE message to zebra daemon.
+func (c *Client) SendRedistribute(t RouteType, vrfID uint32) error {
+
if c.redistDefault != t {
- bodies := make([]*RedistributeBody, 0)
+ bodies := make([]*redistributeBody, 0)
if c.Version <= 3 {
- bodies = append(bodies, &RedistributeBody{
- Redist: t,
+ bodies = append(bodies, &redistributeBody{
+ redist: t,
})
- } else { // version >= 4
- command = FRR_REDISTRIBUTE_ADD
- if c.Version == 5 {
- command = FRR_ZAPI5_REDISTRIBUTE_ADD
- } else if c.Version >= 6 {
- command = FRR_ZAPI6_REDISTRIBUTE_ADD
- }
- for _, afi := range []AFI{AFI_IP, AFI_IP6} {
- bodies = append(bodies, &RedistributeBody{
- Afi: afi,
- Redist: t,
- Instance: 0,
+ } else { // Version >= 4
+ for _, afi := range []afi{afiIP, afiIP6} {
+ bodies = append(bodies, &redistributeBody{
+ afi: afi,
+ redist: t,
+ instance: 0,
})
}
}
for _, body := range bodies {
- return c.SendCommand(command, vrfId, body)
+ return c.sendCommand(redistributeAdd, vrfID, body)
}
}
-
return nil
}
-func (c *Client) SendRedistributeDelete(t ROUTE_TYPE) error {
- if t < ROUTE_MAX {
- command := REDISTRIBUTE_DELETE
- if c.Version == 4 {
- command = FRR_REDISTRIBUTE_DELETE
- } else if c.Version == 5 {
- command = FRR_ZAPI5_REDISTRIBUTE_DELETE
- } else if c.Version >= 6 {
- command = FRR_ZAPI6_REDISTRIBUTE_DELETE
- }
- body := &RedistributeBody{
- Redist: t,
- }
- return c.SendCommand(command, VRF_DEFAULT, body)
- } else {
- return fmt.Errorf("unknown route type: %d", t)
+// SendIPRoute sends ROUTE message to zebra daemon.
+func (c *Client) SendIPRoute(vrfID uint32, body *IPRouteBody, isWithdraw bool) error {
+ routeFamily := body.RouteFamily(c.Version, c.SoftwareName)
+ if vrfID == DefaultVrf && (routeFamily == bgp.RF_IPv4_VPN || routeFamily == bgp.RF_IPv6_VPN) {
+ return fmt.Errorf("RF_IPv4_VPN or RF_IPv6_VPN are not suitable for Default VRF (default forwarding table)")
}
-}
-
-func (c *Client) SendIPRoute(vrfId uint32, body *IPRouteBody, isWithdraw bool) error {
- routeFamily := body.RouteFamily(c.Version)
- if vrfId == VRF_DEFAULT && (routeFamily == bgp.RF_IPv4_VPN || routeFamily == bgp.RF_IPv6_VPN) {
- return fmt.Errorf("RF_IPv4_VPN or RF_IPv6_VPN are not suitable for VPN_DEFAULT(default forwarding table)")
+ command := RouteAdd
+ if isWithdraw {
+ command = RouteDelete
}
- command := IPV4_ROUTE_ADD
- if c.Version <= 3 {
- if body.Prefix.Prefix.To4() != nil {
- if isWithdraw {
- command = IPV4_ROUTE_DELETE
- }
- } else {
- if isWithdraw {
- command = IPV6_ROUTE_DELETE
- } else {
- command = IPV6_ROUTE_ADD
- }
- }
- } else if c.Version == 4 { // version >= 4
- if body.Prefix.Prefix.To4() != nil {
- if isWithdraw {
- command = FRR_IPV4_ROUTE_DELETE
- } else {
- command = FRR_IPV4_ROUTE_ADD
- }
- } else {
- if isWithdraw {
- command = FRR_IPV6_ROUTE_DELETE
- } else {
- command = FRR_IPV6_ROUTE_ADD
- }
- }
- } else { // version >= 5 (version 6 uses the same value as version 5)
+ if c.Version < 5 && familyFromPrefix(body.Prefix.Prefix) == syscall.AF_INET6 {
+ command = BackwardIPv6RouteAdd
if isWithdraw {
- command = FRR_ZAPI5_ROUTE_DELETE
- } else {
- command = FRR_ZAPI5_ROUTE_ADD
+ command = BackwardIPv6RouteDelete
}
}
- return c.SendCommand(command, vrfId, body)
+ return c.sendCommand(command, vrfID, body)
}
-func (c *Client) SendNexthopRegister(vrfId uint32, body *NexthopRegisterBody, isWithdraw bool) error {
- // Note: NEXTHOP_REGISTER and NEXTHOP_UNREGISTER messages are not
+// SendNexthopRegister sends NEXTHOP_REGISTER message to zebra daemon.
+func (c *Client) SendNexthopRegister(vrfID uint32, body *NexthopRegisterBody, isWithdraw bool) error {
+ // Note: NexthopRegister and NexthopUnregister messages are not
// supported in Zebra protocol version<3.
if c.Version < 3 {
- return fmt.Errorf("NEXTHOP_REGISTER/NEXTHOP_UNREGISTER are not supported in version: %d", c.Version)
+ return fmt.Errorf("NexthopRegister/NexthopUnregister are not supported in version: %d", c.Version)
}
- command := NEXTHOP_REGISTER
- if c.Version == 3 {
- if isWithdraw {
- command = NEXTHOP_UNREGISTER
- }
- } else if c.Version == 4 { // version == 4
- if isWithdraw {
- command = FRR_NEXTHOP_UNREGISTER
- } else {
- command = FRR_NEXTHOP_REGISTER
- }
- } else if c.Version == 5 { // version == 5
- if isWithdraw {
- command = FRR_ZAPI5_NEXTHOP_UNREGISTER
- } else {
- command = FRR_ZAPI5_NEXTHOP_REGISTER
- }
- } else { // version >= 6
- if isWithdraw {
- command = FRR_ZAPI6_NEXTHOP_UNREGISTER
- } else {
- command = FRR_ZAPI6_NEXTHOP_REGISTER
- }
+ command := nexthopRegister
+ if isWithdraw {
+ command = nexthopUnregister
}
- return c.SendCommand(command, vrfId, body)
+ return c.sendCommand(command, vrfID, body)
}
-// Reference: zread_label_manager_connect function in zebra/zserv.c of FRR3.x (ZAPI)
-// Reference: zread_label_manager_connect function in zebra/zapi_msg.c of FRR5.x and 6.x (ZAPI5 and 6)
-
-func (c *Client) SendLabelManagerConnect() error {
- if c.Version < 4 {
- return fmt.Errorf("LABEL_MANAGER_CONNECT is not supported in zebra API version: %d", c.Version)
- }
- command := FRR_LABEL_MANAGER_CONNECT
- proto := FRR_ROUTE_BGP
- if c.Version == 5 {
- command = FRR_ZAPI5_LABEL_MANAGER_CONNECT
- proto = FRR_ZAPI5_ROUTE_BGP
- } else if c.Version == 6 {
- command = FRR_ZAPI6_LABEL_MANAGER_CONNECT
- proto = FRR_ZAPI6_ROUTE_BGP
- }
- return c.SendCommand(
- command, 0,
- &LabelManagerConnectBody{
- RedistDefault: proto,
- Instance: 0,
- })
+// SupportMpls is referred in zclient. It returns bool value.
+func (c *Client) SupportMpls() bool {
+ // Note: frr3&4 have LABEL_MANAGER_CONNECT& GET_LABEL_CHUNK. However
+ // Routes will not be installed via zebra of frr3&4 after call these APIs.
+ if c.Version < 5 || c.SoftwareName == "frr4" {
+ return false // if frr4 or ealier are used
+ }
+ return true // if frr5 or later are used
}
-// Reference: zread_label_manager_connect function in zebra/zserv.c of FRR3.x (ZAPI)
-// Reference: zread_label_manager_connect function in zebra/zapi_msg.c of FRR5.x and 6.x (ZAPI5 and 6)
-
-func (c *Client) SendLabelManagerConnectAsync() error {
- if c.Version < 5 {
- return fmt.Errorf("LABEL_MANAGER_CONNECT_ASYNC is not supported in zebra API version: %d", c.Version)
- }
- // ZAPIv5 has ZEBRA_LABEL_MANAGER_CONNECT_ASYNC, however frr4 (ZAPIv5) doesn't have it.
- if c.SoftwareName == "frr4" {
- return fmt.Errorf("LABEL_MANAGER_CONNECT_ASYNC is not supported in software: %s", c.SoftwareName)
+// Ref: zread_label_manager_connect in zebra/zserv.c of FRR3 (ZAPI4)
+// Ref: zread_label_manager_connect in zebra/zapi_msg.c of FRR5&6 (ZAPI5&6)
+func (c *Client) sendLabelManagerConnect(async bool) error {
+ if c.Version < 4 {
+ return fmt.Errorf("LabelManagerConnect is not supported in zebra API version: %d", c.Version)
}
- command := FRR_ZAPI5_LABEL_MANAGER_CONNECT_ASYNC
- proto := FRR_ZAPI5_ROUTE_BGP
- if c.Version == 6 {
- command = FRR_ZAPI6_LABEL_MANAGER_CONNECT_ASYNC
- proto = FRR_ZAPI6_ROUTE_BGP
+ command := labelManagerConnectAsync
+ if !async || c.Version == 4 || (c.Version == 5 && c.SoftwareName == "frr4") {
+ command = labelManagerConnect
}
- return c.SendCommand(
+ return c.sendCommand(
command, 0,
- &LabelManagerConnectBody{
- RedistDefault: proto,
- Instance: 0,
+ &labelManagerConnectBody{
+ redistDefault: RouteBGP,
+ instance: 0,
})
}
+// SendGetLabelChunk sends GET_LABEL_CHUNK message to zebra daemon.
func (c *Client) SendGetLabelChunk(body *GetLabelChunkBody) error {
if c.Version < 4 {
- return fmt.Errorf("GET_LABEL_CHUNK is not supported in version: %d", c.Version)
+ return fmt.Errorf("GetLabelChunk is not supported in version: %d", c.Version)
}
- command := FRR_GET_LABEL_CHUNK
- body.Instance = 0
- if c.Version == 5 {
- body.Proto = uint8(FRR_ZAPI5_ROUTE_BGP)
- command = FRR_ZAPI5_GET_LABEL_CHUNK
- } else if c.Version == 6 {
- body.Proto = uint8(FRR_ZAPI6_ROUTE_BGP)
- command = FRR_ZAPI6_GET_LABEL_CHUNK
- }
- return c.SendCommand(command, 0, body)
+ body.instance = 0
+ body.proto = uint8(RouteBGP)
+ return c.sendCommand(getLabelChunk, 0, body)
}
-func (c *Client) SendVrfLabel(label uint32, vrfId uint32) error {
- body := &VrfLabelBody{
- Label: label,
- Afi: AFI_IP,
- LabelType: LSP_BGP,
+// SendVrfLabel sends VRF_LABEL message to zebra daemon.
+func (c *Client) SendVrfLabel(label uint32, vrfID uint32) error {
+ // ZAPIv5 has ZEBRA_VRF_LABEL, however frr4 (ZAPIv5) doesn't have it.
+ if c.Version < 5 || (c.Version == 5 && c.SoftwareName == "frr4") {
+ return fmt.Errorf("VrfLabel is not supported in zebra API version: %d software: %s", c.Version, c.SoftwareName)
}
- command := FRR_ZAPI5_VRF_LABEL
- if c.Version == 6 {
- command = FRR_ZAPI6_VRF_LABEL
+ body := &vrfLabelBody{
+ label: label,
+ afi: afiIP,
+ labelType: lspBGP,
}
- return c.SendCommand(command, vrfId, body)
+ return c.sendCommand(vrfLabel, vrfID, body)
}
// for avoiding double close
@@ -1533,20 +1516,30 @@ func closeChannel(ch chan *Message) bool {
return false
}
-func (c *Client) Close() error {
+func (c *Client) close() error {
closeChannel(c.outgoing)
return c.conn.Close()
}
+// SetLabelFlag is referred in zclient, this func sets label flag
+func (c Client) SetLabelFlag(msgFlags *MessageFlag, nexthop *Nexthop) {
+ if c.Version == 6 && (c.SoftwareName == "frr7.3" || c.SoftwareName == "") {
+ nexthop.flags |= zapiNexthopFlagLabel
+ } else if c.Version > 4 {
+ *msgFlags |= MessageLabel
+ }
+}
+
+// Header is header of zebra message.
type Header struct {
Len uint16
Marker uint8
Version uint8
- VrfId uint32 // ZAPI v4: 16bits, v5: 32bits
- Command API_TYPE
+ VrfID uint32 // ZAPI v4: 16bits, v5: 32bits
+ Command APIType
}
-func (h *Header) Serialize() ([]byte, error) {
+func (h *Header) serialize() ([]byte, error) {
buf := make([]byte, HeaderSize(h.Version))
binary.BigEndian.PutUint16(buf[0:2], h.Len)
buf[2] = h.Marker
@@ -1555,10 +1548,10 @@ func (h *Header) Serialize() ([]byte, error) {
case 2:
binary.BigEndian.PutUint16(buf[4:6], uint16(h.Command))
case 3, 4:
- binary.BigEndian.PutUint16(buf[4:6], uint16(h.VrfId))
+ binary.BigEndian.PutUint16(buf[4:6], uint16(h.VrfID))
binary.BigEndian.PutUint16(buf[6:8], uint16(h.Command))
case 5, 6:
- binary.BigEndian.PutUint32(buf[4:8], uint32(h.VrfId))
+ binary.BigEndian.PutUint32(buf[4:8], uint32(h.VrfID))
binary.BigEndian.PutUint16(buf[8:10], uint16(h.Command))
default:
return nil, fmt.Errorf("unsupported ZAPI version: %d", h.Version)
@@ -1566,7 +1559,7 @@ func (h *Header) Serialize() ([]byte, error) {
return buf, nil
}
-func (h *Header) DecodeFromBytes(data []byte) error {
+func (h *Header) decodeFromBytes(data []byte) error {
if uint16(len(data)) < 4 {
return fmt.Errorf("not all ZAPI message header")
}
@@ -1578,202 +1571,193 @@ func (h *Header) DecodeFromBytes(data []byte) error {
}
switch h.Version {
case 2:
- h.Command = API_TYPE(binary.BigEndian.Uint16(data[4:6]))
+ h.Command = APIType(binary.BigEndian.Uint16(data[4:6]))
case 3, 4:
- h.VrfId = uint32(binary.BigEndian.Uint16(data[4:6]))
- h.Command = API_TYPE(binary.BigEndian.Uint16(data[6:8]))
+ h.VrfID = uint32(binary.BigEndian.Uint16(data[4:6]))
+ h.Command = APIType(binary.BigEndian.Uint16(data[6:8]))
case 5, 6:
- h.VrfId = binary.BigEndian.Uint32(data[4:8])
- h.Command = API_TYPE(binary.BigEndian.Uint16(data[8:10]))
+ h.VrfID = binary.BigEndian.Uint32(data[4:8])
+ h.Command = APIType(binary.BigEndian.Uint16(data[8:10]))
default:
return fmt.Errorf("unsupported ZAPI version: %d", h.Version)
}
return nil
}
+// Body is an interface for zebra messages.
type Body interface {
- DecodeFromBytes([]byte, uint8, string) error
- Serialize(uint8, string) ([]byte, error)
- String(uint8, string) string
+ decodeFromBytes([]byte, uint8, string) error
+ serialize(uint8, string) ([]byte, error)
+ string(uint8, string) string
}
-type UnknownBody struct {
+type unknownBody struct {
Data []byte
}
-func (b *UnknownBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+func (b *unknownBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
b.Data = data
return nil
}
-func (b *UnknownBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+func (b *unknownBody) serialize(version uint8, softwareName string) ([]byte, error) {
return b.Data, nil
}
-func (b *UnknownBody) String(version uint8, softwareName string) string {
+func (b *unknownBody) string(version uint8, softwareName string) string {
return fmt.Sprintf("data: %v", b.Data)
}
-type HelloBody struct {
- RedistDefault ROUTE_TYPE
- Instance uint16
- ReceiveNotify uint8
+type helloBody struct {
+ redistDefault RouteType
+ instance uint16
+ receiveNotify uint8
}
-// Reference: zread_hello function in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-// Reference: zread_hello function in zebra/zserv.c of FRR3.x (ZAPI4)
-// Reference: zread_hello function in zebra/zapi_msg.c of FRR5.x (ZAPI5)
-func (b *HelloBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- b.RedistDefault = ROUTE_TYPE(data[0])
+// Ref: zread_hello in zebra/zserv.c of Quagga1.2&FRR3 (ZAPI3&4)
+// Ref: zread_hello in zebra/zapi_msg.c of FRR5 (ZAPI5)
+func (b *helloBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
+ b.redistDefault = RouteType(data[0])
if version >= 4 {
- b.Instance = binary.BigEndian.Uint16(data[1:3])
+ b.instance = binary.BigEndian.Uint16(data[1:3])
if version >= 5 {
- b.ReceiveNotify = data[3]
+ b.receiveNotify = data[3]
}
}
return nil
}
-// Reference: zebra_hello_send function in lib/zclient.c of Quagga1.2.x (ZAPI3)
-// Reference: zebra_hello_send function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zebra_hello_send function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *HelloBody) Serialize(version uint8, softwareName string) ([]byte, error) {
- if version <= 3 {
- return []byte{uint8(b.RedistDefault)}, nil
- } else { // version >= 4
- var buf []byte
- if version == 4 {
- buf = make([]byte, 3)
- } else if version >= 5 {
- buf = make([]byte, 4)
- }
- buf[0] = uint8(b.RedistDefault)
- binary.BigEndian.PutUint16(buf[1:3], b.Instance)
- if version >= 5 {
- buf[3] = b.ReceiveNotify
- }
- return buf, nil
+// Ref: zebra_hello_send in lib/zclient.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *helloBody) serialize(version uint8, softwareName string) ([]byte, error) {
+ if version < 4 {
+ return []byte{uint8(b.redistDefault)}, nil
+ }
+ var buf []byte
+ if version == 4 {
+ buf = make([]byte, 3)
+ } else if version > 4 {
+ buf = make([]byte, 4)
}
+ buf[0] = uint8(b.redistDefault)
+ binary.BigEndian.PutUint16(buf[1:3], b.instance)
+ if version > 4 {
+ buf[3] = b.receiveNotify
+ }
+ return buf, nil
}
-func (b *HelloBody) String(version uint8, softwareName string) string {
+func (b *helloBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"route_type: %s, instance :%d",
- b.RedistDefault.String(), b.Instance)
+ b.redistDefault.String(), b.instance)
}
-type RedistributeBody struct {
- Afi AFI
- Redist ROUTE_TYPE
- Instance uint16
+type redistributeBody struct {
+ afi afi
+ redist RouteType
+ instance uint16
}
-// Reference: zebra_redistribute_add function in zebra/redistribute.c of Quagga1.2.x (ZAPI3)
-// Reference: zebra_redistribute_add function in zebra/redistribute.c of FRR3.x (ZAPI4)
-// Reference: zebra_redistribute_add function in zebra/redistribute.c of FRR5.x (ZAPI5)
-func (b *RedistributeBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zebra_redistribute_add in zebra/redistribute.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *redistributeBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
if version <= 3 {
- b.Redist = ROUTE_TYPE(data[0])
+ b.redist = RouteType(data[0])
} else { // version >= 4
- b.Afi = AFI(data[0])
- b.Redist = ROUTE_TYPE(data[1])
- b.Instance = binary.BigEndian.Uint16(data[2:4])
+ b.afi = afi(data[0])
+ b.redist = RouteType(data[1])
+ b.instance = binary.BigEndian.Uint16(data[2:4])
}
return nil
}
-// Reference: zebra_redistribute_send function in lib/zclient.c of Quagga1.2.x (ZAPI3)
-// Reference: zebra_redistribute_send function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zebra_redistribute_send function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *RedistributeBody) Serialize(version uint8, softwareName string) ([]byte, error) {
- if version <= 3 {
- return []byte{uint8(b.Redist)}, nil
- } else { // version >= 4
- buf := make([]byte, 4)
- buf[0] = uint8(b.Afi)
- buf[1] = uint8(b.Redist)
- binary.BigEndian.PutUint16(buf[2:4], b.Instance)
- return buf, nil
+// Ref: zebra_redistribute_send in lib/zclient.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *redistributeBody) serialize(version uint8, softwareName string) ([]byte, error) {
+ if version < 4 {
+ return []byte{uint8(b.redist)}, nil
}
+ buf := make([]byte, 4)
+ buf[0] = uint8(b.afi)
+ buf[1] = uint8(b.redist)
+ binary.BigEndian.PutUint16(buf[2:4], b.instance)
+ return buf, nil
}
-func (b *RedistributeBody) String(version uint8, softwareName string) string {
+func (b *redistributeBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"afi: %s, route_type: %s, instance :%d",
- b.Afi.String(), b.Redist.String(), b.Instance)
-}
-
-type LinkParam struct {
- Status uint32
- TeMetric uint32
- MaxBw float32
- MaxRsvBw float32
- UnrsvBw [8]float32
- BwClassNum uint32
- AdminGroup uint32
- RemoteAS uint32
- RemoteIP net.IP
- AveDelay uint32
- MinDelay uint32
- MaxDelay uint32
- DelayVar uint32
- PktLoss float32
- ResidualBw float32
- AvailableBw float32
- UseBw float32
-}
-
-type InterfaceUpdateBody struct {
- Name string
- Index uint32
- Status INTERFACE_STATUS
- Flags uint64
- PTMEnable PTM_ENABLE
- PTMStatus PTM_STATUS
- Metric uint32
- Speed uint32
- MTU uint32
- MTU6 uint32
- Bandwidth uint32
- LinkIfindex uint32
- Linktype LINK_TYPE
- HardwareAddr net.HardwareAddr
- LinkParam LinkParam
-}
-
-// Reference: zebra_interface_if_set_value function in lib/zclient.c of Quagga1.2.x (ZAPI4)
-// Reference: zebra_interface_if_set_value function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zebra_interface_if_set_value function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *InterfaceUpdateBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- if len(data) < INTERFACE_NAMSIZ+33 {
- return fmt.Errorf("lack of bytes. need %d but %d", INTERFACE_NAMSIZ+29, len(data))
- }
-
- b.Name = strings.Trim(string(data[:INTERFACE_NAMSIZ]), "\u0000")
- data = data[INTERFACE_NAMSIZ:]
- b.Index = binary.BigEndian.Uint32(data[0:4])
- b.Status = INTERFACE_STATUS(data[4])
- b.Flags = binary.BigEndian.Uint64(data[5:13])
- if version >= 4 {
- b.PTMEnable = PTM_ENABLE(data[13])
- b.PTMStatus = PTM_STATUS(data[14])
- b.Metric = binary.BigEndian.Uint32(data[15:19])
- b.Speed = binary.BigEndian.Uint32(data[19:23])
+ b.afi.String(), b.redist.String(), b.instance)
+}
+
+type linkParam struct {
+ status uint32
+ teMetric uint32
+ maxBw float32
+ maxRsvBw float32
+ unrsvBw [8]float32
+ bwClassNum uint32
+ adminGroup uint32
+ remoteAS uint32
+ remoteIP net.IP
+ aveDelay uint32
+ minDelay uint32
+ maxDelay uint32
+ delayVar uint32
+ pktLoss float32
+ residualBw float32
+ availableBw float32
+ useBw float32
+}
+
+type interfaceUpdateBody struct {
+ name string
+ index uint32
+ status interfaceStatus
+ flags uint64
+ ptmEnable ptmEnable
+ ptmStatus ptmStatus
+ metric uint32
+ speed uint32
+ mtu uint32
+ mtu6 uint32
+ bandwidth uint32
+ linkIfindex uint32
+ linktype linkType
+ hardwareAddr net.HardwareAddr
+ linkParam linkParam
+}
+
+// Ref: zebra_interface_if_set_value in lib/zclient.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *interfaceUpdateBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
+ if len(data) < interfaceNameSize+33 {
+ return fmt.Errorf("lack of bytes. need %d but %d", interfaceNameSize+29, len(data))
+ }
+
+ b.name = strings.Trim(string(data[:interfaceNameSize]), "\u0000")
+ data = data[interfaceNameSize:]
+ b.index = binary.BigEndian.Uint32(data[0:4])
+ b.status = interfaceStatus(data[4])
+ b.flags = binary.BigEndian.Uint64(data[5:13])
+ if version > 3 {
+ b.ptmEnable = ptmEnable(data[13])
+ b.ptmStatus = ptmStatus(data[14])
+ b.metric = binary.BigEndian.Uint32(data[15:19])
+ b.speed = binary.BigEndian.Uint32(data[19:23])
data = data[23:]
} else {
- b.Metric = binary.BigEndian.Uint32(data[13:17])
+ b.metric = binary.BigEndian.Uint32(data[13:17])
data = data[17:]
}
- b.MTU = binary.BigEndian.Uint32(data[0:4])
- b.MTU6 = binary.BigEndian.Uint32(data[4:8])
- b.Bandwidth = binary.BigEndian.Uint32(data[8:12])
+ b.mtu = binary.BigEndian.Uint32(data[0:4])
+ b.mtu6 = binary.BigEndian.Uint32(data[4:8])
+ b.bandwidth = binary.BigEndian.Uint32(data[8:12])
data = data[12:]
- if version == 6 && softwareName == "frr7.2" {
- b.LinkIfindex = binary.BigEndian.Uint32(data[:4])
+ if version == 6 &&
+ (softwareName == "frr7.2" || softwareName == "frr7.3" || softwareName == "") { //link Ifindex
+ b.linkIfindex = binary.BigEndian.Uint32(data[:4])
data = data[4:]
}
- if version >= 3 {
- b.Linktype = LINK_TYPE(binary.BigEndian.Uint32(data[:4]))
+ if version > 2 {
+ b.linktype = linkType(binary.BigEndian.Uint32(data[:4]))
data = data[4:]
}
l := binary.BigEndian.Uint32(data[:4])
@@ -1781,287 +1765,457 @@ func (b *InterfaceUpdateBody) DecodeFromBytes(data []byte, version uint8, softwa
if len(data) < 4+int(l) {
return fmt.Errorf("lack of bytes in remain data. need %d but %d", 4+l, len(data))
}
- b.HardwareAddr = data[4 : 4+l]
+ b.hardwareAddr = data[4 : 4+l]
}
- if version >= 3 {
- LinkParam := data[4+l]
- if LinkParam > 0 {
+ if version > 2 {
+ linkParam := data[4+l]
+ if linkParam > 0 {
data = data[5+l:]
- b.LinkParam.Status = binary.BigEndian.Uint32(data[0:4])
- b.LinkParam.TeMetric = binary.BigEndian.Uint32(data[4:8])
- b.LinkParam.MaxBw = math.Float32frombits(binary.BigEndian.Uint32(data[8:12]))
- b.LinkParam.MaxRsvBw = math.Float32frombits(binary.BigEndian.Uint32(data[12:16]))
- b.LinkParam.BwClassNum = binary.BigEndian.Uint32(data[16:20])
- for i := uint32(0); i < b.LinkParam.BwClassNum; i++ {
- b.LinkParam.UnrsvBw[i] = math.Float32frombits(binary.BigEndian.Uint32(data[20+i*4 : 24+i*4]))
+ b.linkParam.status = binary.BigEndian.Uint32(data[0:4])
+ b.linkParam.teMetric = binary.BigEndian.Uint32(data[4:8])
+ b.linkParam.maxBw = math.Float32frombits(binary.BigEndian.Uint32(data[8:12]))
+ b.linkParam.maxRsvBw = math.Float32frombits(binary.BigEndian.Uint32(data[12:16]))
+ b.linkParam.bwClassNum = binary.BigEndian.Uint32(data[16:20])
+ for i := uint32(0); i < b.linkParam.bwClassNum; i++ {
+ b.linkParam.unrsvBw[i] = math.Float32frombits(binary.BigEndian.Uint32(data[20+i*4 : 24+i*4]))
}
- data = data[20+b.LinkParam.BwClassNum*4:]
- b.LinkParam.AdminGroup = binary.BigEndian.Uint32(data[0:4])
- b.LinkParam.RemoteAS = binary.BigEndian.Uint32(data[4:8])
- b.LinkParam.RemoteIP = data[8:12]
- b.LinkParam.AveDelay = binary.BigEndian.Uint32(data[12:16])
- b.LinkParam.MinDelay = binary.BigEndian.Uint32(data[16:20])
- b.LinkParam.MaxDelay = binary.BigEndian.Uint32(data[20:24])
- b.LinkParam.DelayVar = binary.BigEndian.Uint32(data[24:28])
- b.LinkParam.PktLoss = math.Float32frombits(binary.BigEndian.Uint32(data[28:32]))
- b.LinkParam.ResidualBw = math.Float32frombits(binary.BigEndian.Uint32(data[32:36]))
- b.LinkParam.AvailableBw = math.Float32frombits(binary.BigEndian.Uint32(data[36:40]))
- b.LinkParam.UseBw = math.Float32frombits(binary.BigEndian.Uint32(data[40:44]))
+ data = data[20+b.linkParam.bwClassNum*4:]
+ b.linkParam.adminGroup = binary.BigEndian.Uint32(data[0:4])
+ b.linkParam.remoteAS = binary.BigEndian.Uint32(data[4:8])
+ b.linkParam.remoteIP = data[8:12]
+ b.linkParam.aveDelay = binary.BigEndian.Uint32(data[12:16])
+ b.linkParam.minDelay = binary.BigEndian.Uint32(data[16:20])
+ b.linkParam.maxDelay = binary.BigEndian.Uint32(data[20:24])
+ b.linkParam.delayVar = binary.BigEndian.Uint32(data[24:28])
+ b.linkParam.pktLoss = math.Float32frombits(binary.BigEndian.Uint32(data[28:32]))
+ b.linkParam.residualBw = math.Float32frombits(binary.BigEndian.Uint32(data[32:36]))
+ b.linkParam.availableBw = math.Float32frombits(binary.BigEndian.Uint32(data[36:40]))
+ b.linkParam.useBw = math.Float32frombits(binary.BigEndian.Uint32(data[40:44]))
}
}
return nil
}
-func (b *InterfaceUpdateBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+func (b *interfaceUpdateBody) serialize(version uint8, softwareName string) ([]byte, error) {
return []byte{}, nil
}
-func (b *InterfaceUpdateBody) String(version uint8, softwareName string) string {
+func (b *interfaceUpdateBody) string(version uint8, softwareName string) string {
s := fmt.Sprintf(
"name: %s, idx: %d, status: %s, flags: %s, ptm_enable: %s, ptm_status: %s, metric: %d, speed: %d, mtu: %d, mtu6: %d, bandwidth: %d, linktype: %s",
- b.Name, b.Index, b.Status.String(), intfflag2string(b.Flags), b.PTMEnable.String(), b.PTMStatus.String(), b.Metric, b.Speed, b.MTU, b.MTU6, b.Bandwidth, b.Linktype.String())
- if len(b.HardwareAddr) > 0 {
- return s + fmt.Sprintf(", mac: %s", b.HardwareAddr.String())
+ b.name, b.index, b.status.String(), intfflag2string(b.flags), b.ptmEnable.String(), b.ptmStatus.String(), b.metric, b.speed, b.mtu, b.mtu6, b.bandwidth, b.linktype.String())
+ if len(b.hardwareAddr) > 0 {
+ return s + fmt.Sprintf(", mac: %s", b.hardwareAddr.String())
}
return s
}
-type InterfaceAddressUpdateBody struct {
- Index uint32
- Flags INTERFACE_ADDRESS_FLAG
- Prefix net.IP
- Length uint8
- Destination net.IP
+type interfaceAddressUpdateBody struct {
+ index uint32
+ flags interfaceAddressFlag
+ prefix net.IP
+ length uint8
+ destination net.IP
}
-// Reference: zebra_interface_address_read function in lib/zclient.c of Quagga1.2.x (ZAPI4)
-// Reference: zebra_interface_address_read function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zebra_interface_address_read function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *InterfaceAddressUpdateBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- b.Index = binary.BigEndian.Uint32(data[:4])
- b.Flags = INTERFACE_ADDRESS_FLAG(data[4])
+// Ref: zebra_interface_address_read in lib/zclient.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *interfaceAddressUpdateBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
+ b.index = binary.BigEndian.Uint32(data[:4])
+ b.flags = interfaceAddressFlag(data[4])
family := data[5]
addrlen, err := addressByteLength(family)
if err != nil {
return err
}
- b.Prefix = data[6 : 6+addrlen]
- b.Length = data[6+addrlen]
- b.Destination = data[7+addrlen : 7+addrlen*2]
+ b.prefix = data[6 : 6+addrlen]
+ b.length = data[6+addrlen]
+ b.destination = data[7+addrlen : 7+addrlen*2]
return nil
}
-func (b *InterfaceAddressUpdateBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+func (b *interfaceAddressUpdateBody) serialize(version uint8, softwareName string) ([]byte, error) {
return []byte{}, nil
}
-func (b *InterfaceAddressUpdateBody) String(version uint8, softwareName string) string {
+func (b *interfaceAddressUpdateBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"idx: %d, flags: %s, addr: %s/%d",
- b.Index, b.Flags.String(), b.Prefix.String(), b.Length)
+ b.index, b.flags.String(), b.prefix.String(), b.length)
}
-type RouterIDUpdateBody struct {
- Length uint8
- Prefix net.IP
+type routerIDUpdateBody struct {
+ length uint8
+ prefix net.IP
}
-// Reference: zebra_router_id_update_read function in lib/zclient.c of Quagga1.2.x (ZAPI4)
-// Reference: zebra_router_id_update_read function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zebra_router_id_update_read function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *RouterIDUpdateBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zebra_router_id_update_read in lib/zclient.c of Quagga1.2&FRR3&FRR5 (ZAPI3&4&5)
+func (b *routerIDUpdateBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
family := data[0]
addrlen, err := addressByteLength(family)
if err != nil {
return err
}
- b.Prefix = data[1 : 1+addrlen]
- b.Length = data[1+addrlen]
+ b.prefix = data[1 : 1+addrlen]
+ b.length = data[1+addrlen]
return nil
}
-func (b *RouterIDUpdateBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+func (b *routerIDUpdateBody) serialize(version uint8, softwareName string) ([]byte, error) {
return []byte{}, nil
}
-func (b *RouterIDUpdateBody) String(version uint8, softwareName string) string {
- return fmt.Sprintf("id: %s/%d", b.Prefix.String(), b.Length)
+func (b *routerIDUpdateBody) string(version uint8, softwareName string) string {
+ return fmt.Sprintf("id: %s/%d", b.prefix.String(), b.length)
}
-/*
- Reference: struct zapi_nexthop in lib/zclient.h of FRR5.x (ZAPI5)
-*/
+const (
+ zapiNexthopFlagOnlink uint8 = 0x01 // frr7.1, 7.2, 7.3
+ zapiNexthopFlagLabel uint8 = 0x02 // frr7.3
+ zapiNexthopFlagWeight uint8 = 0x04 // frr7.3
+)
+
+// Flag for nexthop processing. It is gobgp's internal flag.
+type nexthopProcessFlag uint8
+
+const (
+ nexthopHasType nexthopProcessFlag = 0x01
+ nexthopHasVrfID nexthopProcessFlag = 0x02
+ nexthopHasFlag nexthopProcessFlag = 0x04
+ nexthopHasOnlink nexthopProcessFlag = 0x08
+ nexthopProcessIPToIPIFindex nexthopProcessFlag = 0x10
+ nexthopProcessIFnameToIFindex nexthopProcessFlag = 0x20 // for quagga
+)
+
+func nexthopProcessFlagForIPRouteBody(version uint8, softwareName string, isDecode bool) nexthopProcessFlag {
+ if version < 5 {
+ if isDecode {
+ return nexthopProcessFlag(0) // frr3&quagga don't have type&vrfid
+ }
+ return nexthopHasType // frr3&quagga need type for encode(serialize)
+ }
+ processFlag := (nexthopHasVrfID | nexthopHasType) // frr4, 5, 6, 7
+ if version == 6 {
+ switch softwareName {
+ case "frr7.3", "":
+ processFlag |= (nexthopHasFlag | nexthopProcessIPToIPIFindex)
+ case "frr7.2", "frr7.1", "frr7.0":
+ processFlag |= nexthopHasOnlink
+ }
+ }
+ return processFlag
+}
+
+// Nexthop is referred in zclient (Ref: struct zapi_nexthop in lib/zclient.h of FRR5.x (ZAPI5))
type Nexthop struct {
- Type NEXTHOP_TYPE
- VrfId uint32
- Ifindex uint32
+ Type nexthopType
+ VrfID uint32
+ Ifindex uint32 // Ifindex is referred in zclient_test
Gate net.IP
- BlackholeType uint8
+ flags uint8
+ blackholeType uint8
LabelNum uint8
MplsLabels []uint32
- Onlink uint8
+ weight uint32
+ rmac [6]byte
}
-func (n *Nexthop) String() string {
+func (n Nexthop) string() string {
s := make([]string, 0)
s = append(s, fmt.Sprintf(
"type: %s, gate: %s, ifindex: %d, vrf_id: %d, label_num: %d",
- n.Type.String(), n.Gate.String(), n.Ifindex, n.VrfId, n.LabelNum))
+ n.Type.String(), n.Gate.String(), n.Ifindex, n.VrfID, n.LabelNum))
for i := uint8(0); i < n.LabelNum; i++ {
s = append(s, fmt.Sprintf("label: %d", n.MplsLabels[i]))
}
return strings.Join(s, ", ")
}
+func (n Nexthop) gateToType(version uint8) nexthopType {
+ if n.Gate.To4() != nil {
+ if version > 4 && n.Ifindex > 0 {
+ return nexthopTypeIPv4IFIndex
+ }
+ return nexthopTypeIPv4.toEach(version)
+ } else if n.Gate.To16() != nil {
+ if version > 4 && n.Ifindex > 0 {
+ return nexthopTypeIPv6IFIndex
+ }
+ return nexthopTypeIPv6.toEach(version)
+ } else if n.Ifindex > 0 {
+ return nexthopTypeIFIndex.toEach(version)
+ } else if version > 4 {
+ return nexthopTypeBlackhole
+ }
+ return nexthopType(0)
+}
+// Ref: zapi_nexthop_encode in lib/zclient.h of FRR7.3
+func (n Nexthop) encode(version uint8, softwareName string, processFlag nexthopProcessFlag, message MessageFlag, apiFlag Flag) []byte {
+ var buf []byte
+ if processFlag&nexthopHasVrfID > 0 {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, n.VrfID)
+ buf = append(buf, tmpbuf...)
+ }
+ if processFlag&nexthopHasType > 0 {
+ if n.Type == nexthopType(0) {
+ n.Type = n.gateToType(version)
+ }
+ buf = append(buf, uint8(n.Type))
+ }
+ if processFlag&nexthopHasFlag > 0 {
+ if n.LabelNum > 0 {
+ n.flags |= zapiNexthopFlagLabel
+ }
+ if n.weight > 0 {
+ n.flags |= zapiNexthopFlagWeight
+ }
+ }
+ if processFlag&nexthopHasFlag > 0 || processFlag&nexthopHasOnlink > 0 {
+ buf = append(buf, n.flags) // frr7.1, 7.2 has onlink, 7.3 has flag
+ }
+
+ nhType := n.Type
+ if processFlag&nexthopProcessIPToIPIFindex > 0 {
+ nhType = nhType.ipToIPIFIndex()
+ }
+ if processFlag&nexthopProcessIFnameToIFindex > 0 {
+ nhType = nhType.ifNameToIFIndex()
+ }
+ if nhType == nexthopTypeIPv4.toEach(version) ||
+ nhType == nexthopTypeIPv4IFIndex.toEach(version) {
+ buf = append(buf, n.Gate.To4()...)
+ } else if nhType == nexthopTypeIPv6.toEach(version) ||
+ nhType == nexthopTypeIPv6IFIndex.toEach(version) {
+ buf = append(buf, n.Gate.To16()...)
+ }
+ if nhType == nexthopTypeIFIndex ||
+ nhType == nexthopTypeIPv4IFIndex.toEach(version) ||
+ nhType == nexthopTypeIPv6IFIndex.toEach(version) {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, n.Ifindex)
+ buf = append(buf, tmpbuf...)
+ }
+ if nhType == nexthopTypeBlackhole.toEach(version) {
+ buf = append(buf, uint8(n.blackholeType))
+ }
+ if n.flags&zapiNexthopFlagLabel > 0 || message&MessageLabel > 0 {
+ tmpbuf := make([]byte, 1+4*n.LabelNum)
+ tmpbuf[0] = n.LabelNum
+ for i := uint8(0); i < n.LabelNum; i++ {
+ // frr uses stream_put for mpls label array.
+ // stream_put is unaware of byteorder coversion.
+ // Therefore LittleEndian is used instead of BigEndian.
+ binary.LittleEndian.PutUint32(tmpbuf[i*4+1:], n.MplsLabels[i])
+ }
+ buf = append(buf, tmpbuf...)
+ }
+ if n.flags&zapiNexthopFlagWeight > 0 && n.weight > 0 {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, uint32(n.weight))
+ buf = append(buf, tmpbuf...)
+ }
+ if apiFlag&flagEvpnRoute.ToEach(version, softwareName) > 0 {
+ buf = append(buf, n.rmac[:]...)
+ }
+ return buf
+}
+
+// Ref: zapi_nexthop_decode in lib/zclient.h of FRR7.3
+func (n *Nexthop) decode(data []byte, version uint8, softwareName string, family uint8, processFlag nexthopProcessFlag, message MessageFlag, apiFlag Flag, nhType nexthopType) (int, error) {
+ offset := 0
+ if processFlag&nexthopHasVrfID > 0 {
+ n.VrfID = binary.BigEndian.Uint32(data[offset : offset+4])
+ offset += 4
+ }
+
+ n.Type = nhType // data does not have nexthop type
+ if processFlag&nexthopHasType > 0 {
+ n.Type = nexthopType(data[offset])
+ offset++
+ }
+
+ n.flags = uint8(0)
+ if processFlag&nexthopHasFlag > 0 || processFlag&nexthopHasOnlink > 0 {
+ n.flags = uint8(data[offset])
+ offset++
+ }
+
+ nhType = n.Type
+ if processFlag&nexthopProcessIPToIPIFindex > 0 {
+ nhType = nhType.ipToIPIFIndex()
+ }
+ if processFlag&nexthopProcessIFnameToIFindex > 0 {
+ nhType = nhType.ifNameToIFIndex()
+ }
+ if family == syscall.AF_INET {
+ n.Gate = net.ParseIP("0.0.0.0")
+ } else if family == syscall.AF_INET6 {
+ n.Gate = net.ParseIP("::")
+ }
+ if nhType == nexthopTypeIPv4.toEach(version) ||
+ nhType == nexthopTypeIPv4IFIndex.toEach(version) {
+ n.Gate = net.IP(data[offset : offset+4]).To4()
+ offset += 4
+ } else if nhType == nexthopTypeIPv6.toEach(version) ||
+ nhType == nexthopTypeIPv6IFIndex.toEach(version) {
+ n.Gate = net.IP(data[offset : offset+16]).To16()
+ offset += 16
+ }
+ if nhType == nexthopTypeIFIndex ||
+ nhType == nexthopTypeIPv4IFIndex.toEach(version) ||
+ nhType == nexthopTypeIPv6IFIndex.toEach(version) {
+ n.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
+ offset += 4
+ }
+ if nhType == nexthopTypeBlackhole.toEach(version) {
+ n.blackholeType = data[offset]
+ offset++
+ }
+ if n.flags&zapiNexthopFlagLabel > 0 || message&MessageLabel > 0 {
+ n.LabelNum = uint8(data[offset])
+ offset++
+ if n.LabelNum > maxMplsLabel {
+ n.LabelNum = maxMplsLabel
+ }
+ if n.LabelNum > 0 {
+ n.MplsLabels = make([]uint32, n.LabelNum)
+ for i := uint8(0); i < n.LabelNum; i++ {
+ // frr uses stream_put which is unaware of byteorder for mpls label array.
+ // Therefore LittleEndian is used instead of BigEndian.
+ n.MplsLabels[i] = binary.LittleEndian.Uint32(data[offset : offset+4])
+ offset += 4
+ }
+ }
+ }
+ if n.flags&zapiNexthopFlagWeight > 0 {
+ n.weight = binary.BigEndian.Uint32(data[offset:])
+ }
+ if apiFlag&flagEvpnRoute.ToEach(version, softwareName) > 0 {
+ copy(n.rmac[0:], data[offset:offset+6])
+ }
+ return offset, nil
+}
+
+// Ref: zapi_nexthop_update_decode in lib/zclient.h
+// decodeNexthops is referred from decodeFromBytes of NexthopUpdateBody and IPRouteBody
+func decodeNexthops(nexthops *[]Nexthop, data []byte, version uint8, softwareName string, family uint8, numNexthop uint16, processFlag nexthopProcessFlag, message MessageFlag, apiFlag Flag, nhType nexthopType) (int, error) {
+ offset := 0
+ *nexthops = make([]Nexthop, numNexthop)
+ for i := uint16(0); i < numNexthop; i++ {
+ size, err := (&((*nexthops)[i])).decode(data[offset:], version, softwareName, family, processFlag, message, apiFlag, nhType)
+ if err != nil {
+ return offset, err
+ }
+ offset += size
+ }
+ return offset, nil
+}
+
+// Prefix referred in zclient is struct for network prefix and relate information
type Prefix struct {
Family uint8
PrefixLen uint8
Prefix net.IP
}
+func familyFromPrefix(prefix net.IP) uint8 {
+ if prefix.To4() != nil {
+ return syscall.AF_INET
+ } else if prefix.To16() != nil {
+ return syscall.AF_INET6
+ }
+ return syscall.AF_UNSPEC
+}
+
+// IPRouteBody is struct for IPRotue (zapi_route)
type IPRouteBody struct {
- Type ROUTE_TYPE
- Instance uint16
- Flags FLAG
- Message MESSAGE_FLAG
- SAFI SAFI
+ Type RouteType
+ instance uint16
+ Flags Flag
+ Message MessageFlag
+ Safi Safi
Prefix Prefix
- SrcPrefix Prefix
+ srcPrefix Prefix
Nexthops []Nexthop
Distance uint8
Metric uint32
Mtu uint32
- Tag uint32
- Rmac [6]byte
- Api API_TYPE
+ tag uint32
+ API APIType // API is referred in zclient_test
+}
+
+func (b *IPRouteBody) safi(version uint8, sw string) Safi {
+ if b.Safi == safiUnspec && (version < 6 || sw == "frr6" || sw == "frr7" || sw == "frr7.1") {
+ return SafiUnicast // older versions don't have safiUnspec
+ }
+ if b.Safi <= safiMulticast || version > 4 { // not need to convert
+ return b.Safi
+ }
+ safiMap := zapi4SafiMap
+ if version < 4 {
+ safiMap = zapi3SafiMap
+ }
+ safi, ok := safiMap[b.Safi]
+ if !ok {
+ safi = safiUnspec // failed to convert
+ }
+ log.WithFields(log.Fields{
+ "Topic": "Zebra",
+ "Body": b,
+ }).Debugf("zebra converts safi: %s -> %s", b.Safi.String(), safi.String())
+ return safi // success to convert
}
-func (b *IPRouteBody) RouteFamily(version uint8) bgp.RouteFamily {
+// RouteFamily is referred in zclient
+func (b *IPRouteBody) RouteFamily(version uint8, softwareName string) bgp.RouteFamily {
if b == nil {
- return bgp.RF_OPAQUE
+ return bgp.RF_OPAQUE // fail
}
- family := addressFamilyFromApi(b.Api, version)
+ safi := b.safi(version, softwareName)
+ if safi == safiEvpn {
+ return bgp.RF_EVPN // sucess
+ }
+ family := b.Prefix.Family
if family == syscall.AF_UNSPEC {
- if b.Prefix.Prefix.To4() != nil {
- family = syscall.AF_INET
- } else if b.Prefix.Prefix.To16() != nil {
- family = syscall.AF_INET6
- }
+ family = familyFromPrefix(b.Prefix.Prefix)
}
- if version < 5 {
- switch family {
- case syscall.AF_INET:
- switch b.SAFI {
- case SAFI_UNICAST:
- return bgp.RF_IPv4_UC
- case SAFI_MULTICAST:
- return bgp.RF_IPv4_MC
- case SAFI_MPLS_VPN, FRR_SAFI_MPLS_VPN:
- return bgp.RF_IPv4_VPN
- case FRR_SAFI_ENCAP, SAFI_ENCAP:
- return bgp.RF_IPv4_ENCAP
- default:
- return bgp.RF_IPv4_UC
- }
- case syscall.AF_INET6:
- switch b.SAFI {
- case SAFI_UNICAST:
- return bgp.RF_IPv6_UC
- case SAFI_MULTICAST:
- return bgp.RF_IPv6_MC
- case SAFI_MPLS_VPN, FRR_SAFI_MPLS_VPN:
- return bgp.RF_IPv6_VPN
- case FRR_SAFI_ENCAP, SAFI_ENCAP:
- return bgp.RF_IPv6_ENCAP
- default:
- return bgp.RF_IPv6_UC
- }
- default:
- switch b.SAFI {
- case FRR_SAFI_EVPN:
- return bgp.RF_EVPN
- default:
- return bgp.RF_OPAQUE
- }
- }
- } else {
- switch family {
- case syscall.AF_INET:
- switch b.SAFI {
- case FRR_ZAPI5_SAFI_UNICAST:
- return bgp.RF_IPv4_UC
- case FRR_ZAPI5_SAFI_MULTICAST:
- return bgp.RF_IPv4_MC
- case FRR_ZAPI5_SAFI_MPLS_VPN:
- return bgp.RF_IPv4_VPN
- case FRR_ZAPI5_SAFI_ENCAP:
- return bgp.RF_IPv4_ENCAP
- case FRR_ZAPI5_SAFI_LABELED_UNICAST:
- return bgp.RF_IPv4_MPLS
- case FRR_ZAPI5_SAFI_FLOWSPEC:
- return bgp.RF_FS_IPv4_UC
- default:
- return bgp.RF_IPv4_UC
- }
- case syscall.AF_INET6:
- switch b.SAFI {
- case FRR_ZAPI5_SAFI_UNICAST:
- return bgp.RF_IPv6_UC
- case FRR_ZAPI5_SAFI_MULTICAST:
- return bgp.RF_IPv6_MC
- case FRR_ZAPI5_SAFI_MPLS_VPN:
- return bgp.RF_IPv6_VPN
- case FRR_ZAPI5_SAFI_ENCAP:
- return bgp.RF_IPv6_ENCAP
- case FRR_ZAPI5_SAFI_LABELED_UNICAST:
- return bgp.RF_IPv6_MPLS
- case FRR_ZAPI5_SAFI_FLOWSPEC:
- return bgp.RF_FS_IPv6_UC
- default:
- return bgp.RF_IPv6_UC
- }
- default:
- switch b.SAFI {
- case FRR_ZAPI5_SAFI_EVPN:
- return bgp.RF_EVPN
- default:
- return bgp.RF_OPAQUE
- }
- }
+ if family == syscall.AF_UNSPEC { // familyFromPrefix returs AF_UNSPEC
+ return bgp.RF_OPAQUE // fail
+ }
+ safiRouteFamilyMap := safiRouteFamilyIPv4Map // syscall.AF_INET
+ if family == syscall.AF_INET6 {
+ safiRouteFamilyMap = safiRouteFamilyIPv6Map
+ }
+ rf, ok := safiRouteFamilyMap[safi]
+ if !ok {
+ return bgp.RF_OPAQUE // fail
}
+ log.WithFields(log.Fields{
+ "Topic": "Zebra",
+ "Body": b,
+ }).Debugf("zebra converts safi:%s -> rf: %s", safi.String(), rf.String())
+ return rf // sucess
}
-func (b *IPRouteBody) IsWithdraw(version uint8) bool {
- if version <= 3 {
- switch b.Api {
- case IPV4_ROUTE_DELETE, IPV6_ROUTE_DELETE:
- return true
- }
- } else if version == 4 {
- switch b.Api {
- case FRR_IPV4_ROUTE_DELETE, FRR_IPV6_ROUTE_DELETE, FRR_REDISTRIBUTE_IPV4_DEL, FRR_REDISTRIBUTE_IPV6_DEL:
- return true
- }
- } else if version == 5 {
- switch b.Api {
- case FRR_ZAPI5_ROUTE_DELETE, FRR_ZAPI5_IPV4_ROUTE_DELETE, FRR_ZAPI5_IPV6_ROUTE_DELETE, FRR_ZAPI5_REDISTRIBUTE_ROUTE_DEL:
- return true
- }
- } else if version >= 6 {
- switch b.Api {
- case FRR_ZAPI6_ROUTE_DELETE, FRR_ZAPI6_REDISTRIBUTE_ROUTE_DEL:
- return true
- }
+// IsWithdraw is referred in zclient
+func (b *IPRouteBody) IsWithdraw(version uint8, softwareName string) bool {
+ api := b.API.toCommon(version, softwareName)
+ switch api {
+ case RouteDelete, redistributeRouteDel, BackwardIPv6RouteDelete:
+ return true
+ }
+ if version == 4 && b.API == zapi4RedistributeIPv6Del {
+ return true
}
return false
}
-// Reference: zapi_ipv4_route function in lib/zclient.c of Quagga1.2.x (ZAPI3)
-// Reference: zapi_ipv4_route function in lib/zclient.c of FRR3.x (ZAPI4)
-// Reference: zapi_route_encode function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *IPRouteBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+// Ref: zapi_ipv4_route in lib/zclient.c of Quagga1.2.x&FRR3.x(ZAPI3&4)
+// Ref: zapi_route_encode in lib/zclient.c of FRR5.x (ZAPI5)
+func (b *IPRouteBody) serialize(version uint8, softwareName string) ([]byte, error) {
var buf []byte
+ numNexthop := len(b.Nexthops)
if version <= 3 {
buf = make([]byte, 5)
} else if version == 4 {
@@ -2070,28 +2224,24 @@ func (b *IPRouteBody) Serialize(version uint8, softwareName string) ([]byte, err
buf = make([]byte, 9)
}
buf[0] = uint8(b.Type)
- if version <= 3 {
+ if version < 4 {
buf[1] = uint8(b.Flags)
buf[2] = uint8(b.Message)
- binary.BigEndian.PutUint16(buf[3:5], uint16(b.SAFI))
+ binary.BigEndian.PutUint16(buf[3:5], uint16(b.Safi))
} else { // version >= 4
- binary.BigEndian.PutUint16(buf[1:3], uint16(b.Instance))
+ binary.BigEndian.PutUint16(buf[1:3], uint16(b.instance))
binary.BigEndian.PutUint32(buf[3:7], uint32(b.Flags))
buf[7] = uint8(b.Message)
if version == 4 {
- binary.BigEndian.PutUint16(buf[8:10], uint16(b.SAFI))
+ binary.BigEndian.PutUint16(buf[8:10], uint16(b.Safi))
} else { // version >= 5
- buf[8] = uint8(b.SAFI)
- if b.Flags&FLAG_EVPN_ROUTE > 0 {
+ buf[8] = uint8(b.Safi)
+ if version == 5 && b.Flags&flagEvpnRoute.ToEach(version, softwareName) > 0 {
// size of struct ethaddr is 6 octets defined by ETH_ALEN
- buf = append(buf, b.Rmac[:6]...)
+ buf = append(buf, b.Nexthops[numNexthop-1].rmac[:6]...)
}
if b.Prefix.Family == syscall.AF_UNSPEC {
- if b.Prefix.Prefix.To4() != nil {
- b.Prefix.Family = syscall.AF_INET
- } else if b.Prefix.Prefix.To16() != nil {
- b.Prefix.Family = syscall.AF_INET6
- }
+ b.Prefix.Family = familyFromPrefix(b.Prefix.Prefix)
}
buf = append(buf, b.Prefix.Family)
}
@@ -2100,165 +2250,75 @@ func (b *IPRouteBody) Serialize(version uint8, softwareName string) ([]byte, err
buf = append(buf, b.Prefix.PrefixLen)
buf = append(buf, b.Prefix.Prefix[:byteLen]...)
- if (version == 4 && b.Message&FRR_MESSAGE_SRCPFX > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_SRCPFX > 0) {
- byteLen = (int(b.SrcPrefix.PrefixLen) + 7) / 8
- buf = append(buf, b.SrcPrefix.PrefixLen)
- buf = append(buf, b.SrcPrefix.Prefix[:byteLen]...)
+ if version > 3 && b.Message&messageSRCPFX.ToEach(version) > 0 {
+ byteLen = (int(b.srcPrefix.PrefixLen) + 7) / 8
+ buf = append(buf, b.srcPrefix.PrefixLen)
+ buf = append(buf, b.srcPrefix.Prefix[:byteLen]...)
}
- if (version <= 3 && b.Message&MESSAGE_NEXTHOP > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_NEXTHOP > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_NEXTHOP > 0) {
+ if b.Message&MessageNexthop > 0 {
+ processFlag := nexthopProcessFlagForIPRouteBody(version, softwareName, false)
if version < 5 {
- if b.Flags&FLAG_BLACKHOLE > 0 {
- buf = append(buf, []byte{1, uint8(NEXTHOP_TYPE_BLACKHOLE)}...)
+ if b.Flags&flagBlackhole > 0 {
+ buf = append(buf, []byte{1, uint8(nexthopTypeBlackhole.toEach(version))}...)
} else {
- buf = append(buf, uint8(len(b.Nexthops)))
+ buf = append(buf, uint8(numNexthop))
}
} else { // version >= 5
- bbuf := make([]byte, 2)
- binary.BigEndian.PutUint16(bbuf, uint16(len(b.Nexthops)))
- buf = append(buf, bbuf...)
+ tmpbuf := make([]byte, 2)
+ binary.BigEndian.PutUint16(tmpbuf, uint16(numNexthop))
+ buf = append(buf, tmpbuf...)
}
for _, nexthop := range b.Nexthops {
- if version >= 5 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, nexthop.VrfId)
- buf = append(buf, bbuf...)
- }
-
- if nexthop.Type == NEXTHOP_TYPE(0) {
- if nexthop.Gate.To4() != nil {
- if version <= 3 {
- nexthop.Type = NEXTHOP_TYPE_IPV4
- } else {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV4
- }
- if version >= 5 && nexthop.Ifindex > 0 {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV4_IFINDEX
- }
- } else if nexthop.Gate.To16() != nil {
- if version <= 3 {
- nexthop.Type = NEXTHOP_TYPE_IPV6
- } else {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV6
- }
- if version >= 5 && nexthop.Ifindex > 0 {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV6_IFINDEX
- }
- } else if nexthop.Ifindex > 0 {
- if version <= 3 {
- nexthop.Type = NEXTHOP_TYPE_IFINDEX
- } else {
- nexthop.Type = FRR_NEXTHOP_TYPE_IFINDEX
- }
- } else if version >= 5 {
- nexthop.Type = FRR_NEXTHOP_TYPE_BLACKHOLE
- }
- }
-
- buf = append(buf, uint8(nexthop.Type))
-
- if version == 6 && (softwareName == "frr7.1" || softwareName == "frr7.2") {
- buf = append(buf, nexthop.Onlink)
- }
- if (version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV4) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV4) {
- buf = append(buf, nexthop.Gate.To4()...)
- } else if (version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV6) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV6) {
- buf = append(buf, nexthop.Gate.To16()...)
- } else if (version <= 3 && nexthop.Type == NEXTHOP_TYPE_IFINDEX) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IFINDEX) {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, nexthop.Ifindex)
- buf = append(buf, bbuf...)
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV4_IFINDEX {
- buf = append(buf, nexthop.Gate.To4()...)
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, nexthop.Ifindex)
- buf = append(buf, bbuf...)
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV6_IFINDEX {
- buf = append(buf, nexthop.Gate.To16()...)
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, nexthop.Ifindex)
- buf = append(buf, bbuf...)
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_BLACKHOLE {
- buf = append(buf, uint8(nexthop.BlackholeType))
- }
- if version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_LABEL > 0 {
- buf = append(buf, nexthop.LabelNum)
- for i := uint8(0); i < nexthop.LabelNum; i++ {
- bbuf := make([]byte, 4)
- /* Frr uses stream_put for mpls label array.
- stream_put is unaware of byteorder coversion.
- Therefore LittleEndian is used instead of BigEndian. */
- binary.LittleEndian.PutUint32(bbuf, nexthop.MplsLabels[i])
- buf = append(buf, bbuf...)
-
- }
- }
- }
- if (version <= 3 && b.Message&MESSAGE_DISTANCE > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_DISTANCE > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_DISTANCE > 0) {
- buf = append(buf, b.Distance)
- }
- if (version <= 3 && b.Message&MESSAGE_METRIC > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_METRIC > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_METRIC > 0) {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Metric)
- buf = append(buf, bbuf...)
- }
- if (version <= 3 && b.Message&MESSAGE_MTU > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_MTU > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_MTU > 0) {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Mtu)
- buf = append(buf, bbuf...)
- }
- if (version <= 3 && b.Message&MESSAGE_TAG > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_TAG > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_TAG > 0) {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Tag)
- buf = append(buf, bbuf...)
+ buf = append(buf, nexthop.encode(version, softwareName, processFlag, b.Message, b.Flags)...)
}
}
+ if b.Message&MessageDistance.ToEach(version) > 0 {
+ buf = append(buf, b.Distance)
+ }
+ if b.Message&MessageMetric.ToEach(version) > 0 {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, b.Metric)
+ buf = append(buf, tmpbuf...)
+ }
+ if b.Message&MessageMTU.ToEach(version) > 0 {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, b.Mtu)
+ buf = append(buf, tmpbuf...)
+ }
+ if b.Message&messageTag.ToEach(version) > 0 {
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, b.tag)
+ buf = append(buf, tmpbuf...)
+ }
return buf, nil
}
-// Reference: zebra_read_ipv4 function in bgpd/bgp_zebra.c of Quagga1.2.x (ZAPI3)
-// Reference: zebra_read_ipv4 function in bgpd/bgp_zebra.c of FRR4.x (ZAPI4)
-// Reference: zapi_route_decode function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *IPRouteBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zebra_read_ipv4 in bgpd/bgp_zebra.c of Quagga1.2.x&FRR3.x(ZAPI3&4)
+// Ref: zapi_route_decode in lib/zclient.c of FRR5.x (ZAPI5)
+func (b *IPRouteBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
if b == nil {
return fmt.Errorf("IPRouteBody is nil")
}
- b.Prefix.Family = addressFamilyFromApi(b.Api, version)
- /* REDSTRIBUTE_IPV4_ADD|DEL and REDSITRBUTE_IPV6_ADD|DEL have merged to
- REDISTRIBUTE_ROUTE_ADD|DEL in ZAPI version 5.
- Therefore it can not judge the protocol famiiy from API. */
-
- b.Type = ROUTE_TYPE(data[0])
+ b.Type = RouteType(data[0])
if version <= 3 {
- b.Flags = FLAG(data[1])
+ b.Flags = Flag(data[1])
data = data[2:]
} else { // version >= 4
- b.Instance = binary.BigEndian.Uint16(data[1:3])
- b.Flags = FLAG(binary.BigEndian.Uint32(data[3:7]))
+ b.instance = binary.BigEndian.Uint16(data[1:3])
+ b.Flags = Flag(binary.BigEndian.Uint32(data[3:7]))
data = data[7:]
}
- b.Message = MESSAGE_FLAG(data[0])
- b.SAFI = SAFI(SAFI_UNICAST)
- if version >= 5 {
- b.SAFI = SAFI(data[1])
+ b.Message = MessageFlag(data[0])
+ b.Safi = Safi(SafiUnicast)
+ b.Prefix.Family = b.API.addressFamily(version) // return AF_UNSPEC if version > 4
+ var evpnNexthop Nexthop
+ if version > 4 {
+ b.Safi = Safi(data[1])
data = data[2:]
- if b.Flags&FLAG_EVPN_ROUTE > 0 {
+ if version == 5 && b.Flags&flagEvpnRoute.ToEach(version, softwareName) > 0 {
// size of struct ethaddr is 6 octets defined by ETH_ALEN
- copy(b.Rmac[0:6], data[0:6])
+ copy(evpnNexthop.rmac[0:6], data[0:6])
data = data[6:]
}
b.Prefix.Family = data[0]
@@ -2287,426 +2347,222 @@ func (b *IPRouteBody) DecodeFromBytes(data []byte, version uint8, softwareName s
copy(buf, data[pos:pos+byteLen])
b.Prefix.Prefix = ipFromFamily(b.Prefix.Family, buf)
pos += byteLen
- if (version == 4 && b.Message&FRR_MESSAGE_SRCPFX > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_SRCPFX > 0) {
+ if version > 3 && b.Message&messageSRCPFX.ToEach(version) > 0 {
if pos+1 > rest {
- return fmt.Errorf("MESSAGE_SRCPFX message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageSRCPFX message length invalid pos:%d rest:%d", pos, rest)
}
- b.SrcPrefix.PrefixLen = data[pos]
- if b.SrcPrefix.PrefixLen > addrBitLen {
+ b.srcPrefix.PrefixLen = data[pos]
+ if b.srcPrefix.PrefixLen > addrBitLen {
return fmt.Errorf("prefix length is greater than %d", addrByteLen*8)
}
- pos += 1
+ pos++
buf = make([]byte, addrByteLen)
- byteLen = int((b.SrcPrefix.PrefixLen + 7) / 8)
+ byteLen = int((b.srcPrefix.PrefixLen + 7) / 8)
if pos+byteLen > rest {
- return fmt.Errorf("MESSAGE_SRCPFX message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageSRCPFX message length invalid pos:%d rest:%d", pos, rest)
}
copy(buf, data[pos:pos+byteLen])
- b.SrcPrefix.Prefix = ipFromFamily(b.Prefix.Family, buf)
+ b.srcPrefix.Prefix = ipFromFamily(b.Prefix.Family, buf)
pos += byteLen
}
b.Nexthops = []Nexthop{}
- if (version <= 3 && b.Message&MESSAGE_NEXTHOP > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_NEXTHOP > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_NEXTHOP > 0) {
- var numNexthop uint16
- if version <= 4 {
- if pos+1 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP message length invalid pos:%d rest:%d", pos, rest)
- }
- numNexthop = uint16(data[pos])
- pos += 1
- } else { // version >= 5
- if pos+2 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP message length invalid pos:%d rest:%d", pos, rest)
+ if b.Message&MessageNexthop > 0 {
+ numNexthop := uint16(0)
+ numNexthopDataSize := 2
+ processFlag := nexthopProcessFlagForIPRouteBody(version, softwareName, true)
+ nhType := nexthopType(0)
+ if version < 5 { // frr3 and quagga
+ numNexthopDataSize = 1
+ nhType = nexthopTypeIPv4.toEach(version)
+ if b.Prefix.Family == syscall.AF_INET6 {
+ nhType = nexthopTypeIPv6.toEach(version)
}
+ }
+ if pos+numNexthopDataSize > rest {
+ return fmt.Errorf("MessageNexthop message length invalid pos:%d rest:%d", pos, rest)
+ }
+ if numNexthopDataSize == 2 {
numNexthop = binary.BigEndian.Uint16(data[pos : pos+2])
- pos += 2
+ } else if numNexthopDataSize == 1 {
+ numNexthop = uint16(data[pos])
}
- for i := 0; i < int(numNexthop); i++ {
- var nexthop Nexthop
- if version <= 3 {
- if b.Prefix.Family == syscall.AF_INET {
- nexthop.Type = NEXTHOP_TYPE_IPV4
- } else if b.Prefix.Family == syscall.AF_INET6 {
- nexthop.Type = NEXTHOP_TYPE_IPV6
- }
- } else if version == 4 {
- if b.Prefix.Family == syscall.AF_INET {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV4
- } else if b.Prefix.Family == syscall.AF_INET6 {
- nexthop.Type = FRR_NEXTHOP_TYPE_IPV6
- }
- } else { // version >= 5
- if pos+5 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP message length invalid pos:%d rest:%d", pos, rest)
- }
- nexthop.VrfId = binary.BigEndian.Uint32(data[pos : pos+4])
- nexthop.Type = NEXTHOP_TYPE(data[pos+4])
- pos += 5
- if softwareName == "frr7.1" || softwareName == "frr7.2" {
- nexthop.Onlink = uint8(data[pos])
- pos += 1
- }
- }
+ pos += numNexthopDataSize
- if (version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV4) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV4) {
- if pos+4 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_IPV4 message length invalid pos:%d rest:%d", pos, rest)
- }
- addr := data[pos : pos+4]
- nexthop.Gate = net.IP(addr).To4()
- pos += 4
- } else if (version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV6) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV6) {
- if pos+16 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_IPV6 message length invalid pos:%d rest:%d", pos, rest)
- }
- addr := data[pos : pos+16]
- nexthop.Gate = net.IP(addr).To16()
- pos += 16
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_IFINDEX {
- if pos+4 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_IFINDEX message length invalid pos:%d rest:%d", pos, rest)
- }
- nexthop.Ifindex = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- // barkward compatibility
- if b.Prefix.Family == syscall.AF_INET {
- nexthop.Gate = net.ParseIP("0.0.0.0")
- } else if b.Prefix.Family == syscall.AF_INET6 {
- nexthop.Gate = net.ParseIP("::")
- }
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV4_IFINDEX {
- if pos+8 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_IPV4_IFINDEX message length invalid pos:%d rest:%d", pos, rest)
- }
- addr := data[pos : pos+4]
- nexthop.Gate = net.IP(addr).To4()
- nexthop.Ifindex = binary.BigEndian.Uint32(data[pos+4 : pos+8])
- pos += 8
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_IPV6_IFINDEX {
- if pos+20 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_IPV6_IFINDEX message length invalid pos:%d rest:%d", pos, rest)
- }
- addr := data[pos : pos+16]
- nexthop.Gate = net.IP(addr).To16()
- nexthop.Ifindex = binary.BigEndian.Uint32(data[pos+16 : pos+20])
- pos += 20
- } else if version >= 5 && nexthop.Type == FRR_NEXTHOP_TYPE_BLACKHOLE {
- if pos+1 > rest {
- return fmt.Errorf("MESSAGE_NEXTHOP NEXTHOP_TYPE_BLACKHOLE message length invalid pos:%d rest:%d", pos, rest)
- }
- nexthop.BlackholeType = data[pos]
- pos += 1
- }
- b.Nexthops = append(b.Nexthops, nexthop)
+ nexthopsByteLen, err := decodeNexthops(&b.Nexthops, data[pos:], version, softwareName, b.Prefix.Family, numNexthop, processFlag, b.Message, b.Flags, nhType)
+ if err != nil {
+ return err
}
+ pos += nexthopsByteLen
+ }
+ if version == 5 && b.Flags&flagEvpnRoute.ToEach(version, softwareName) > 0 {
+ b.Nexthops = append(b.Nexthops, evpnNexthop)
}
- if (version <= 3 && b.Message&MESSAGE_IFINDEX > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_IFINDEX > 0) {
+ if version < 5 && b.Message&messageIFIndex > 0 {
if pos+1 > rest {
- return fmt.Errorf("MESSAGE_IFINDEX message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageIFIndex message length invalid pos:%d rest:%d", pos, rest)
}
numIfIndex := uint8(data[pos])
- pos += 1
+ pos++
for i := 0; i < int(numIfIndex); i++ {
if pos+4 > rest {
- return fmt.Errorf("MESSAGE_IFINDEX message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageIFIndex message length invalid pos:%d rest:%d", pos, rest)
}
var nexthop Nexthop
nexthop.Ifindex = binary.BigEndian.Uint32(data[pos : pos+4])
- if version <= 3 {
- nexthop.Type = NEXTHOP_TYPE_IFINDEX
- } else if version == 4 {
- nexthop.Type = FRR_NEXTHOP_TYPE_IFINDEX
- }
+ nexthop.Type = nexthopTypeIFIndex
b.Nexthops = append(b.Nexthops, nexthop)
pos += 4
}
}
- if (version <= 3 && b.Message&MESSAGE_DISTANCE > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_DISTANCE > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_DISTANCE > 0) {
+ if b.Message&MessageDistance.ToEach(version) > 0 {
if pos+1 > rest {
- return fmt.Errorf("MESSAGE_DISTANCE message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageDistance message length invalid pos:%d rest:%d", pos, rest)
}
b.Distance = data[pos]
- pos += 1
+ pos++
}
- if (version <= 3 && b.Message&MESSAGE_METRIC > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_METRIC > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_METRIC > 0) {
+ if b.Message&MessageMetric.ToEach(version) > 0 {
if pos+4 > rest {
- return fmt.Errorf("MESSAGE_METRIC message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageMetric message length invalid pos:%d rest:%d", pos, rest)
}
b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
pos += 4
}
- if (version <= 3 && b.Message&MESSAGE_MTU > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_MTU > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_MTU > 0) {
+ if b.Message&MessageMTU.ToEach(version) > 0 {
if pos+4 > rest {
- return fmt.Errorf("MESSAGE_MTU message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageMTU message length invalid pos:%d rest:%d", pos, rest)
}
b.Mtu = binary.BigEndian.Uint32(data[pos : pos+4])
pos += 4
}
- if (version <= 3 && b.Message&MESSAGE_TAG > 0) ||
- (version == 4 && b.Message&FRR_MESSAGE_TAG > 0) ||
- (version >= 5 && b.Message&FRR_ZAPI5_MESSAGE_TAG > 0) {
+ if b.Message&messageTag.ToEach(version) > 0 {
if pos+4 > rest {
- return fmt.Errorf("MESSAGE_TAG message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("MessageTag message length invalid pos:%d rest:%d", pos, rest)
}
- b.Tag = binary.BigEndian.Uint32(data[pos : pos+4])
+ b.tag = binary.BigEndian.Uint32(data[pos : pos+4])
pos += 4
}
if pos != rest {
- return fmt.Errorf("message length invalid pos:%d rest:%d", pos, rest)
+ return fmt.Errorf("message length invalid (last) pos:%d rest:%d, message:%#x", pos, rest, b.Message)
}
return nil
}
-func (b *IPRouteBody) String(version uint8, softwareName string) string {
+func (b *IPRouteBody) string(version uint8, softwareName string) string {
s := fmt.Sprintf(
- "type: %s, instance: %d, flags: %s, message: %d, safi: %s, prefix: %s/%d, src_prefix: %s/%d",
- b.Type.String(), b.Instance, b.Flags.String(version, softwareName), b.Message, b.SAFI.String(), b.Prefix.Prefix.String(), b.Prefix.PrefixLen, b.SrcPrefix.Prefix.String(), b.SrcPrefix.PrefixLen)
+ "type: %s, instance: %d, flags: %s, message: %d(%s), safi: %s, prefix: %s/%d, src_prefix: %s/%d",
+ b.Type.String(), b.instance, b.Flags.String(version, softwareName), b.Message, b.Message.string(version), b.Safi.String(), b.Prefix.Prefix.String(), b.Prefix.PrefixLen, b.srcPrefix.Prefix.String(), b.srcPrefix.PrefixLen)
for i, nh := range b.Nexthops {
- s += fmt.Sprintf(", nexthops[%d]: %s", i, nh.String())
+ s += fmt.Sprintf(", nexthops[%d]: %s", i, nh.string())
}
return s + fmt.Sprintf(
", distance: %d, metric: %d, mtu: %d, tag: %d",
- b.Distance, b.Metric, b.Mtu, b.Tag)
+ b.Distance, b.Metric, b.Mtu, b.tag)
}
-func decodeNexthopsFromBytes(nexthops *[]Nexthop, data []byte, family uint8, version uint8) (int, error) {
- addrByteLen, err := addressByteLength(family)
- if err != nil {
- return 0, err
- }
-
- numNexthop := int(data[0])
- offset := 1
-
- for i := 0; i < numNexthop; i++ {
- nexthop := Nexthop{}
- nexthop.Type = NEXTHOP_TYPE(data[offset])
- offset += 1
-
- // On Quagga, NEXTHOP_TYPE_IFNAME is same as NEXTHOP_TYPE_IFINDEX,
- // NEXTHOP_TYPE_IPV4_IFNAME is same as NEXTHOP_TYPE_IPV4_IFINDEX,
- // NEXTHOP_TYPE_IPV6_IFNAME is same as NEXTHOP_TYPE_IPV6_IFINDEX
-
- // On FRRouting version 3.0 or later, NEXTHOP_TYPE_IPV4 and NEXTHOP_TYPE_IPV6 have
- // the same structure with NEXTHOP_TYPE_IPV4_IFINDEX and NEXTHOP_TYPE_IPV6_IFINDEX.
-
- if (version <= 3 && (nexthop.Type == NEXTHOP_TYPE_IFINDEX || nexthop.Type == NEXTHOP_TYPE_IFNAME)) ||
- (version >= 4 && nexthop.Type == FRR_NEXTHOP_TYPE_IFINDEX) {
- nexthop.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
- } else if version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV4 {
- nexthop.Gate = net.IP(data[offset : offset+addrByteLen]).To4()
- offset += addrByteLen
- } else if version <= 3 && nexthop.Type == NEXTHOP_TYPE_IPV6 {
- nexthop.Gate = net.IP(data[offset : offset+addrByteLen]).To16()
- offset += addrByteLen
- } else if (version <= 3 && (nexthop.Type == NEXTHOP_TYPE_IPV4_IFINDEX || nexthop.Type == NEXTHOP_TYPE_IPV4_IFNAME)) ||
- (version >= 4 && (nexthop.Type == FRR_NEXTHOP_TYPE_IPV4 || nexthop.Type == FRR_NEXTHOP_TYPE_IPV4_IFINDEX)) {
- nexthop.Gate = net.IP(data[offset : offset+addrByteLen]).To4()
- offset += addrByteLen
- nexthop.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
- } else if (version <= 3 && (nexthop.Type == NEXTHOP_TYPE_IPV6_IFINDEX || nexthop.Type == NEXTHOP_TYPE_IPV6_IFNAME)) ||
- (version >= 4 && (nexthop.Type == FRR_NEXTHOP_TYPE_IPV6 || nexthop.Type == FRR_NEXTHOP_TYPE_IPV6_IFINDEX)) {
- nexthop.Gate = net.IP(data[offset : offset+addrByteLen]).To16()
- offset += addrByteLen
- nexthop.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
- }
- if version >= 5 {
- nexthop.LabelNum = uint8(data[offset])
- offset += 1
- if nexthop.LabelNum > MPLS_MAX_LABEL {
- nexthop.LabelNum = MPLS_MAX_LABEL
- }
- if nexthop.LabelNum > 0 {
- nexthop.MplsLabels = make([]uint32, nexthop.LabelNum)
- for n := uint8(0); n < nexthop.LabelNum; n++ {
- /* Frr uses stream_put for mpls label array.
- stream_put is unaware of byteorder coversion.
- Therefore LittleEndian is used instead of BigEndian. */
- nexthop.MplsLabels[n] = binary.LittleEndian.Uint32(data[offset : offset+4])
- offset += 4
- }
- }
- }
- *nexthops = append(*nexthops, nexthop)
- }
-
- return offset, nil
+// lookupBody is combination of nexthopLookupBody and imporetLookupBody
+type lookupBody struct {
+ api APIType
+ prefixLength uint8 // importLookup serialize only
+ addr net.IP //it is same as prefix (it is deleted from importLookup)
+ distance uint8 // nexthopIPv4LookupMRIB only
+ metric uint32
+ nexthops []Nexthop
}
-type NexthopLookupBody struct {
- Api API_TYPE
- Addr net.IP
- Distance uint8
- Metric uint32
- Nexthops []Nexthop
-}
-
-// Quagga only. Reference: zread_ipv[4|6]_nexthop_lookup in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-func (b *NexthopLookupBody) Serialize(version uint8, softwareName string) ([]byte, error) {
- family := addressFamilyFromApi(b.Api, version)
+// Quagga only. Ref: zread_ipv4_(nexthop|import_lookup) in zebra/zserv.c
+func (b *lookupBody) serialize(version uint8, softwareName string) ([]byte, error) {
buf := make([]byte, 0)
-
- if family == syscall.AF_INET {
- buf = append(buf, b.Addr.To4()...)
- } else if family == syscall.AF_INET6 {
- buf = append(buf, b.Addr.To16()...)
+ if b.api == zapi3IPv4ImportLookup {
+ buf = append(buf, b.prefixLength)
+ }
+ switch b.api {
+ case ipv4NexthopLookupMRIB, zapi3IPv4NexthopLookup, zapi3IPv4ImportLookup:
+ buf = append(buf, b.addr.To4()...)
+ case zapi3IPv6NexthopLookup:
+ buf = append(buf, b.addr.To16()...)
}
return buf, nil
}
-// Quagga only. Reference: zsend_ipv[4|6]_nexthop_lookup in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-func (b *NexthopLookupBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- family := addressFamilyFromApi(b.Api, version)
- addrByteLen, err := addressByteLength(family)
- if err != nil {
- return err
+// Quagga only(except ipv4NexthopLookupMRIB).
+// Ref: zsend_ipv[4|6]_(nexthop|import)_lookup in zebra/zserv.c
+func (b *lookupBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
+ family := uint8(syscall.AF_INET)
+ if b.api == zapi3IPv6NexthopLookup {
+ family = syscall.AF_INET6
}
-
- if len(data) < addrByteLen {
+ addrByteLen, _ := addressByteLength(family)
+ requiredLen := 5 //metric(4), numNexthop(1)
+ hasDistance := false
+ if b.api == ipv4NexthopLookupMRIB.ToEach(version, softwareName) {
+ requiredLen++ //distance
+ hasDistance = true
+ }
+ if len(data) < addrByteLen+requiredLen {
return fmt.Errorf("message length invalid")
}
-
buf := make([]byte, addrByteLen)
copy(buf, data[0:addrByteLen])
pos := addrByteLen
- b.Addr = ipFromFamily(family, buf)
-
- if version >= 4 {
- b.Distance = data[pos]
+ b.addr = ipFromFamily(family, buf)
+ if hasDistance {
+ b.distance = data[pos]
pos++
}
-
- if len(data[pos:]) > int(1+addrByteLen) {
- b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- b.Nexthops = []Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[pos:], family, version); err != nil {
- return err
- } else {
- pos += nexthopsByteLen
- }
- }
-
- return nil
-}
-
-func (b *NexthopLookupBody) String(version uint8, softwareName string) string {
- s := fmt.Sprintf(
- "addr: %s, distance:%d, metric: %d",
- b.Addr.String(), b.Distance, b.Metric)
- if len(b.Nexthops) > 0 {
- for _, nh := range b.Nexthops {
- s = s + fmt.Sprintf(", nexthop:{%s}", nh.String())
- }
- }
- return s
-}
-
-type ImportLookupBody struct {
- Api API_TYPE
- PrefixLength uint8
- Prefix net.IP
- Addr net.IP
- Metric uint32
- Nexthops []Nexthop
-}
-
-// Quagga only. Reference: zread_ipv4_import_lookup in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-func (b *ImportLookupBody) Serialize(version uint8, softwareName string) ([]byte, error) {
- buf := make([]byte, 1)
- buf[0] = b.PrefixLength
- buf = append(buf, b.Addr.To4()...)
- return buf, nil
-}
-
-// Quagga only. Reference: zsend_ipv4_import_lookup in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-func (b *ImportLookupBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- family := addressFamilyFromApi(b.Api, version)
- addrByteLen, err := addressByteLength(family)
+ b.metric = binary.BigEndian.Uint32(data[pos : pos+4])
+ pos += 4
+ numNexthop := uint16(data[pos])
+ pos++
+ b.nexthops = []Nexthop{}
+ processFlag := nexthopHasType | nexthopProcessIFnameToIFindex
+ nexthopsByteLen, err := decodeNexthops(&b.nexthops, data[pos:], version, softwareName, family, numNexthop, processFlag, MessageFlag(0), Flag(0), nexthopType(0))
if err != nil {
return err
}
-
- if len(data) < addrByteLen {
- return fmt.Errorf("message length invalid")
- }
-
- buf := make([]byte, addrByteLen)
- copy(buf, data[0:addrByteLen])
- pos := addrByteLen
-
- b.Addr = net.IP(buf).To4()
-
- if len(data[pos:]) > int(1+addrByteLen) {
- b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- b.Nexthops = []Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[pos:], family, version); err != nil {
- return err
- } else {
- pos += nexthopsByteLen
- }
- }
-
+ pos += nexthopsByteLen
return nil
}
-
-func (b *ImportLookupBody) String(version uint8, softwareName string) string {
+func (b *lookupBody) string(version uint8, softwareName string) string {
s := fmt.Sprintf(
- "prefix: %s/%d, addr: %s, metric: %d",
- b.Prefix.String(), b.PrefixLength, b.Addr.String(), b.Metric)
- if len(b.Nexthops) > 0 {
- for _, nh := range b.Nexthops {
- s = s + fmt.Sprintf(", nexthop:{%s}", nh.String())
+ "addr/prefixLength: %s/%d, distance:%d, metric: %d",
+ b.addr.String(), b.prefixLength, b.distance, b.metric)
+ if len(b.nexthops) > 0 {
+ for _, nh := range b.nexthops {
+ s = s + fmt.Sprintf(", nexthop:{%s}", nh.string())
}
}
return s
}
+// RegisteredNexthop is referred in zclient
type RegisteredNexthop struct {
- Connected uint8
+ connected uint8
Family uint16
- // Note: Ignores PrefixLength (uint8),
- // because this field should be always:
+ // Note: Ignores PrefixLength (uint8), because this field should be always:
// - 32 if Address Family is AF_INET
// - 128 if Address Family is AF_INET6
Prefix net.IP
}
-func (n *RegisteredNexthop) Len() int {
+func (n *RegisteredNexthop) len() int {
// Connected (1 byte) + Address Family (2 bytes) + Prefix Length (1 byte) + Prefix (variable)
if n.Family == uint16(syscall.AF_INET) {
return 4 + net.IPv4len
- } else {
- return 4 + net.IPv6len
}
+ return 4 + net.IPv6len
}
-// Reference: sendmsg_nexthop in bgpd/bgp_nht.c of Quagga1.2.x (ZAPI3)
-// Reference: sendmsg_zebra_rnh in bgpd/bgp_nht.c of FRR3.x (ZAPI4)
-// Reference: zclient_send_rnh function in lib/zclient.c of FRR5.x (ZAPI5)
-func (n *RegisteredNexthop) Serialize() ([]byte, error) {
+// Ref: sendmsg_nexthop in bgpd/bgp_nht.c of Quagga1.2.x (ZAPI3)
+// Ref: sendmsg_zebra_rnh in bgpd/bgp_nht.c of FRR3.x (ZAPI4)
+// Ref: zclient_send_rnh in lib/zclient.c of FRR5.x (ZAPI5)
+func (n *RegisteredNexthop) serialize() ([]byte, error) {
// Connected (1 byte)
buf := make([]byte, 4)
- buf[0] = byte(n.Connected)
+ buf[0] = byte(n.connected)
// Address Family (2 bytes)
binary.BigEndian.PutUint16(buf[1:3], n.Family)
@@ -2730,12 +2586,12 @@ func (n *RegisteredNexthop) Serialize() ([]byte, error) {
return buf, nil
}
-// Reference: zserv_nexthop_register in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-// Reference: zserv_rnh_register in zebra/zserv.c of FRR3.x (ZAPI4)
-// Reference: zread_rnh_register in zebra/zapi_msg.c of FRR5.x (ZAPI5)
-func (n *RegisteredNexthop) DecodeFromBytes(data []byte, softwareName string) error {
+// Ref: zserv_nexthop_register in zebra/zserv.c of Quagga1.2.x (ZAPI3)
+// Ref: zserv_rnh_register in zebra/zserv.c of FRR3.x (ZAPI4)
+// Ref: zread_rnh_register in zebra/zapi_msg.c of FRR5.x (ZAPI5)
+func (n *RegisteredNexthop) decodeFromBytes(data []byte, softwareName string) error {
// Connected (1 byte)
- n.Connected = uint8(data[0])
+ n.connected = uint8(data[0])
// Address Family (2 bytes)
n.Family = binary.BigEndian.Uint16(data[1:3])
// Note: Ignores Prefix Length (1 byte)
@@ -2746,26 +2602,27 @@ func (n *RegisteredNexthop) DecodeFromBytes(data []byte, softwareName string) er
return nil
}
-func (n *RegisteredNexthop) String(version uint8, softwareName string) string {
+func (n *RegisteredNexthop) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"connected: %d, family: %d, prefix: %s",
- n.Connected, n.Family, n.Prefix.String())
+ n.connected, n.Family, n.Prefix.String())
}
+// NexthopRegisterBody us referred in zclient
type NexthopRegisterBody struct {
- Api API_TYPE
+ api APIType
Nexthops []*RegisteredNexthop
}
-// Reference: sendmsg_nexthop in bgpd/bgp_nht.c of Quagga1.2.x (ZAPI3)
-// Reference: sendmsg_zebra_rnh in bgpd/bgp_nht.c of FRR3.x (ZAPI4)
-// Reference: zclient_send_rnh function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *NexthopRegisterBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+// Ref: sendmsg_nexthop in bgpd/bgp_nht.c of Quagga1.2.x (ZAPI3)
+// Ref: sendmsg_zebra_rnh in bgpd/bgp_nht.c of FRR3.x (ZAPI4)
+// Ref: zclient_send_rnh in lib/zclient.c of FRR5.x (ZAPI5)
+func (b *NexthopRegisterBody) serialize(version uint8, softwareName string) ([]byte, error) {
buf := make([]byte, 0)
// List of Registered Nexthops
for _, nh := range b.Nexthops {
- nhBuf, err := nh.Serialize()
+ nhBuf, err := nh.serialize()
if err != nil {
return nil, err
}
@@ -2775,47 +2632,42 @@ func (b *NexthopRegisterBody) Serialize(version uint8, softwareName string) ([]b
return buf, nil
}
-// Reference: zserv_nexthop_register in zebra/zserv.c of Quagga1.2.x (ZAPI3)
-// Reference: zserv_rnh_register in zebra/zserv.c of FRR3.x (ZAPI4)
-// Reference: zread_rnh_register in zebra/zapi_msg.c of FRR5.x (ZAPI5)
-func (b *NexthopRegisterBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zserv_nexthop_register in zebra/zserv.c of Quagga1.2.x (ZAPI3)
+// Ref: zserv_rnh_register in zebra/zserv.c of FRR3.x (ZAPI4)
+// Ref: zread_rnh_register in zebra/zapi_msg.c of FRR5.x (ZAPI5)
+func (b *NexthopRegisterBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
offset := 0
-
// List of Registered Nexthops
b.Nexthops = []*RegisteredNexthop{}
for len(data[offset:]) > 0 {
nh := new(RegisteredNexthop)
- err := nh.DecodeFromBytes(data[offset:], softwareName)
+ err := nh.decodeFromBytes(data[offset:], softwareName)
if err != nil {
return err
}
b.Nexthops = append(b.Nexthops, nh)
- offset += nh.Len()
+ offset += nh.len()
if len(data) < offset {
break
}
}
-
return nil
}
-func (b *NexthopRegisterBody) String(version uint8, softwareName string) string {
+func (b *NexthopRegisterBody) string(version uint8, softwareName string) string {
s := make([]string, 0)
for _, nh := range b.Nexthops {
- s = append(s, fmt.Sprintf("nexthop:{%s}", nh.String(version, softwareName)))
+ s = append(s, fmt.Sprintf("nexthop:{%s}", nh.string(version, softwareName)))
}
return strings.Join(s, ", ")
}
-/* NEXTHOP_UPDATE message uses same data structure as IPRoute (zapi_route)
- in FRR version 4, 5 (ZApi version 5) */
+// NexthopUpdateBody uses same data structure as IPRoute (zapi_route) after frr4 (Zapi5)
type NexthopUpdateBody IPRouteBody
-// Reference: send_client function in zebra/zebra_rnh.c of Quagga1.2.x (ZAPI3)
-// Reference: send_client function in zebra/zebra_rnh.c of FRR3.x (ZAPI4)
-// Reference: send_client function in zebra/zebra_rnh.c of FRR5.x (ZAPI5)
-func (b *NexthopUpdateBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+// Ref: send_client in zebra/zebra_rnh.c of Quagga1.2&FRR3&FRR5(ZAPI3&4$5)
+func (b *NexthopUpdateBody) serialize(version uint8, softwareName string) ([]byte, error) {
// Address Family (2 bytes)
buf := make([]byte, 3)
binary.BigEndian.PutUint16(buf, uint16(b.Prefix.Family))
@@ -2836,31 +2688,29 @@ func (b *NexthopUpdateBody) Serialize(version uint8, softwareName string) ([]byt
}
if version >= 5 {
// Type (1 byte) (if version>=5)
- // Instance (2 bytes) (if version>=5)
+ // instance (2 bytes) (if version>=5)
buf = append(buf, byte(b.Type))
- bbuf := make([]byte, 2)
- binary.BigEndian.PutUint16(bbuf, b.Instance)
- buf = append(buf, bbuf...)
+ tmpbuf := make([]byte, 2)
+ binary.BigEndian.PutUint16(tmpbuf, b.instance)
+ buf = append(buf, tmpbuf...)
}
if version >= 4 {
// Distance (1 byte) (if version>=4)
buf = append(buf, b.Distance)
}
// Metric (4 bytes)
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Metric)
- buf = append(buf, bbuf...)
+ tmpbuf := make([]byte, 4)
+ binary.BigEndian.PutUint32(tmpbuf, b.Metric)
+ buf = append(buf, tmpbuf...)
// Number of Nexthops (1 byte)
buf = append(buf, uint8(0)) // Temporary code
// ToDo Processing Route Entry
-
return buf, nil
}
-// Reference: bgp_parse_nexthop_update function in bgpd/bgp_nht.c of Quagga1.2.x (ZAPI3)
-// Reference: bgp_parse_nexthop_update function in bgpd/bgp_nht.c of FRR3.x (ZAPI4)
-// Reference: zapi_nexthop_update_decode function in lib/zclient.c of FRR5.x (ZAPI5)
-func (b *NexthopUpdateBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: bgp_parse_nexthop_update in bgpd/bgp_nht.c of Quagga1.2&FRR3 (ZAPI3&4)
+// Ref: zapi_nexthop_update_decode in lib/zclient.c of FRR5.x (ZAPI5)
+func (b *NexthopUpdateBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
// Address Family (2 bytes)
prefixFamily := binary.BigEndian.Uint16(data[0:2])
b.Prefix.Family = uint8(prefixFamily)
@@ -2875,505 +2725,310 @@ func (b *NexthopUpdateBody) DecodeFromBytes(data []byte, version uint8, software
b.Prefix.Prefix = ipFromFamily(b.Prefix.Family, data[offset:offset+addrByteLen])
offset += addrByteLen
- if version >= 5 {
- b.Type = ROUTE_TYPE(data[offset])
- b.Instance = binary.BigEndian.Uint16(data[offset+1 : offset+3])
+ if version > 4 {
+ b.Type = RouteType(data[offset])
+ b.instance = binary.BigEndian.Uint16(data[offset+1 : offset+3])
offset += 3
}
// Distance (1 byte) (if version>=4)
- if version >= 4 {
+ if version > 3 {
b.Distance = data[offset]
- offset += 1
+ offset++
}
- // Metric (4 bytes)
- // Number of Nexthops (1 byte)
+ // Metric (4 bytes) & Number of Nexthops (1 byte)
if len(data[offset:]) < 5 {
return fmt.Errorf("invalid message length: missing metric(4 bytes) or nexthops(1 byte): %d<5", len(data[offset:]))
}
b.Metric = binary.BigEndian.Uint32(data[offset : offset+4])
offset += 4
+ numNexthop := uint16(data[offset])
+ offset++
// List of Nexthops
b.Nexthops = []Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[offset:], b.Prefix.Family, version); err != nil {
+
+ processFlag := nexthopProcessFlag(nexthopHasType)
+ if version == 6 {
+ switch softwareName {
+ case "frr7.3", "":
+ processFlag |= (nexthopHasVrfID | nexthopHasFlag | nexthopProcessIPToIPIFindex)
+ case "frr7.0", "frr7.1", "frr7.2":
+ processFlag |= (nexthopHasVrfID | nexthopProcessIPToIPIFindex)
+ case "frr6":
+ processFlag |= nexthopProcessIPToIPIFindex
+ }
+ } else if version == 5 {
+ switch softwareName {
+ case "frr5", "":
+ processFlag |= nexthopProcessIPToIPIFindex
+ }
+ } else if version < 4 { // quagga
+ processFlag |= nexthopProcessIFnameToIFindex
+ }
+
+ message := MessageFlag(0)
+ if (version == 6 && !(softwareName == "frr7.3" || softwareName == "")) ||
+ (version == 5 && (softwareName == "frr5" || softwareName == "")) {
+ message |= MessageLabel
+ }
+
+ nexthopsByteLen, err := decodeNexthops(&b.Nexthops, data[offset:], version, softwareName, b.Prefix.Family, numNexthop, processFlag, message, Flag(0), nexthopType(0))
+ if err != nil {
return err
- } else {
- offset += nexthopsByteLen
}
+ offset += nexthopsByteLen
return nil
}
-func (b *NexthopUpdateBody) String(version uint8, softwareName string) string {
+func (b *NexthopUpdateBody) string(version uint8, softwareName string) string {
s := fmt.Sprintf(
"family: %d, prefix: %s, distance: %d, metric: %d",
b.Prefix.Family, b.Prefix.Prefix.String(), b.Distance, b.Metric)
for _, nh := range b.Nexthops {
- s = s + fmt.Sprintf(", nexthop:{%s}", nh.String())
+ s = s + fmt.Sprintf(", nexthop:{%s}", nh.string())
}
return s
}
-type LabelManagerConnectBody struct {
- RedistDefault ROUTE_TYPE
- Instance uint16
+type labelManagerConnectBody struct {
+ redistDefault RouteType
+ instance uint16
// The followings are used in response from Zebra
- Result uint8 // 0 means success
+ result uint8 // 0 means success
}
-// Reference: lm_label_manager_connect in lib/zclient.c of FRR
-func (b *LabelManagerConnectBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+// Ref: lm_label_manager_connect in lib/zclient.c of FRR
+func (b *labelManagerConnectBody) serialize(version uint8, softwareName string) ([]byte, error) {
buf := make([]byte, 3)
- buf[0] = uint8(b.RedistDefault)
- binary.BigEndian.PutUint16(buf[1:3], b.Instance)
+ buf[0] = uint8(b.redistDefault)
+ binary.BigEndian.PutUint16(buf[1:3], b.instance)
return buf, nil
}
-func (b *LabelManagerConnectBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+func (b *labelManagerConnectBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
size := 1
- // FRR v4 may work incorrectly. It returns result only although it uses ZAPI v5.
- if version >= 4 {
+ if version > 4 && softwareName != "frr4" { // FRR4 returns result only.
size = 4
}
if len(data) < size {
- return fmt.Errorf("invalid message length for LABEL_MANAGER_CONNECT response: %d<%d",
+ return fmt.Errorf("invalid message length for LabelManagerConnect response: %d<%d",
len(data), size)
}
- if version > 4 {
- b.RedistDefault = ROUTE_TYPE(data[0])
- b.Instance = binary.BigEndian.Uint16(data[1:3])
+ if version > 4 && softwareName != "frr4" {
+ b.redistDefault = RouteType(data[0])
+ b.instance = binary.BigEndian.Uint16(data[1:3])
data = data[3:]
}
- b.Result = data[0]
+ b.result = data[0]
return nil
}
-func (b *LabelManagerConnectBody) String(version uint8, softwareName string) string {
+func (b *labelManagerConnectBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"route_type: %s, instance: %d, result: %d",
- b.RedistDefault.String(), b.Instance, b.Result)
+ b.redistDefault.String(), b.instance, b.result)
}
-// Reference: zsend_assign_label_chunk_response in zebra/zserv.c of FRR3.x
-// Reference: zsend_assign_label_chunk_response in zebra/zapi_msg.c of FRR5.x and 6.x
+// GetLabelChunkBody is referred in zclient (Ref: zsend_assign_label_chunk_response)
type GetLabelChunkBody struct {
- Proto uint8 // it is appeared in FRR5.x and 6.x
- Instance uint16 // it is appeared in FRR5.x and 6.x
- Keep uint8
+ proto uint8 // it is appeared in FRR5.x and 6.x
+ instance uint16 // it is appeared in FRR5.x and 6.x
+ keep uint8
ChunkSize uint32
- // The followings are used in response from Zebra
- Start uint32
- End uint32
+ Start uint32 // The followings are used in response from Zebra
+ End uint32
+ base uint32 // it is added in FRR7.2
}
-// Reference: zread_get_label_chunk in zebra/zserv.c of FRR3.x
-// Reference: zread_get_label_chunk in zebra/zapi_msg.c of FRR5.x and 6.x
-func (b *GetLabelChunkBody) Serialize(version uint8, softwareName string) ([]byte, error) {
- buf := make([]byte, 8)
+// Ref: zread_get_label_chunk in zebra/zserv.c of FRR3.x
+// Ref: zread_get_label_chunk in zebra/zapi_msg.c of FRR5.x and 6.x
+func (b *GetLabelChunkBody) serialize(version uint8, softwareName string) ([]byte, error) {
+ buf := make([]byte, 12)
pos := 0
- if version > 4 {
- buf[pos] = b.Proto
- binary.BigEndian.PutUint16(buf[pos+1:pos+3], b.Instance)
+ b.base = 0
+ if version > 4 && softwareName != "frr4" {
+ buf[pos] = b.proto
+ binary.BigEndian.PutUint16(buf[pos+1:pos+3], b.instance)
pos += 3
}
- buf[pos] = b.Keep
+ buf[pos] = b.keep
binary.BigEndian.PutUint32(buf[pos+1:pos+5], b.ChunkSize)
pos += 5
+ if version == 6 && (softwareName == "frr7.2" || softwareName == "frr7.3" || softwareName == "") {
+ binary.BigEndian.PutUint32(buf[pos:pos+4], b.base)
+ pos += 4
+ }
return buf[0:pos], nil
}
-// Reference: zsend_assign_label_chunk_response in zebra/zserv.c of FRR3.x
-// Reference: zsend_assign_label_chunk_response in zebra/zapi_msg.c of FRR5.x and 6.x
-func (b *GetLabelChunkBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zsend_assign_label_chunk_response in zebra/zserv.c of FRR3.x
+// Ref: zsend_assign_label_chunk_response in zebra/zapi_msg.c of FRR5.x and 6.x
+func (b *GetLabelChunkBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
size := 9
- if version > 4 {
+ if version > 4 && softwareName != "frr4" {
size = 12
}
if len(data) < size {
- return fmt.Errorf("invalid message length for GET_LABEL_CHUNK response: %d<%d",
+ return fmt.Errorf("invalid message length for GetLabelChunk response: %d<%d",
len(data), size)
}
- if version > 4 {
- b.Proto = data[0]
- b.Instance = binary.BigEndian.Uint16(data[1:3])
+ if version > 4 && softwareName != "frr4" {
+ b.proto = data[0]
+ b.instance = binary.BigEndian.Uint16(data[1:3])
data = data[3:]
}
- b.Keep = data[0]
+ b.keep = data[0]
b.Start = binary.BigEndian.Uint32(data[1:5])
b.End = binary.BigEndian.Uint32(data[5:9])
return nil
}
-func (b *GetLabelChunkBody) String(version uint8, softwareName string) string {
+func (b *GetLabelChunkBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
"keep: %d, chunk_size: %d, start: %d, end: %d",
- b.Keep, b.ChunkSize, b.Start, b.End)
+ b.keep, b.ChunkSize, b.Start, b.End)
}
-type ReleaseLabelChunkBody struct {
- Proto uint8 // it is appeared in FRR5.x and 6.x
- Instance uint16 // it is appeared in FRR5.x and 6.x
- Start uint32
- End uint32
+type releaseLabelChunkBody struct {
+ proto uint8 // it is appeared in FRR5.x and 6.x
+ instance uint16 // it is appeared in FRR5.x and 6.x
+ start uint32
+ end uint32
}
-func (b *ReleaseLabelChunkBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+func (b *releaseLabelChunkBody) serialize(version uint8, softwareName string) ([]byte, error) {
buf := make([]byte, 11)
pos := 0
- if version > 4 {
- buf[pos] = b.Proto
- binary.BigEndian.PutUint16(buf[pos+1:pos+3], b.Instance)
+ if version > 4 && softwareName != "frr4" {
+ buf[pos] = b.proto
+ binary.BigEndian.PutUint16(buf[pos+1:pos+3], b.instance)
pos += 3
}
- binary.BigEndian.PutUint32(buf[pos:pos+4], b.Start)
- binary.BigEndian.PutUint32(buf[pos+4:pos+8], b.End)
+ binary.BigEndian.PutUint32(buf[pos:pos+4], b.start)
+ binary.BigEndian.PutUint32(buf[pos+4:pos+8], b.end)
pos += 8
return buf[0:pos], nil
}
-func (b *ReleaseLabelChunkBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
- // No response from Zebra
- return nil
+func (b *releaseLabelChunkBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
+ return nil // No response from Zebra
}
-func (b *ReleaseLabelChunkBody) String(version uint8, softwareName string) string {
- return fmt.Sprintf(
- "start: %d, end: %d",
- b.Start, b.End)
+func (b *releaseLabelChunkBody) string(version uint8, softwareName string) string {
+ return fmt.Sprintf("start: %d, end: %d", b.start, b.end)
}
-//go:generate stringer -type=LSP_TYPE
-type LSP_TYPE uint8
+//go:generate stringer -type=lspTYPE
+type lspTYPE uint8
const (
- LSP_NONE LSP_TYPE = iota //defined in FRR3 and over
- LSP_STATIC //defined in FRR3 and over
- LSP_LDP //defined in FRR3 and over
- LSP_BGP //defined in FRR4 and over
- LSP_SR //defined in FRR4 and over
- LSP_SHARP //defined in FRR5 and over
+ lspNone lspTYPE = iota //defined in FRR3 and over
+ lspStatic //defined in FRR3 and over
+ lspLDP //defined in FRR3 and over
+ lspBGP //defined in FRR4 and over
+ lspSR //defined in FRR4 and over
+ lspSHARP //defined in FRR5 and over
)
-type VrfLabelBody struct {
- Label uint32
- Afi AFI
- LabelType LSP_TYPE
+type vrfLabelBody struct {
+ label uint32
+ afi afi
+ labelType lspTYPE
}
-// Reference: zclient_send_vrf_label in lib/zclient.c of FRR 5.x and 6.x
-func (b *VrfLabelBody) Serialize(version uint8, softwareName string) ([]byte, error) {
+// Ref: zclient_send_vrf_label in lib/zclient.c of FRR 5.x and 6.x
+func (b *vrfLabelBody) serialize(version uint8, softwareName string) ([]byte, error) {
buf := make([]byte, 6)
- binary.BigEndian.PutUint32(buf[0:4], b.Label)
- buf[4] = uint8(b.Afi)
- buf[5] = uint8(b.LabelType)
+ binary.BigEndian.PutUint32(buf[0:4], b.label)
+ buf[4] = uint8(b.afi)
+ buf[5] = uint8(b.labelType)
return buf, nil
}
-func (b *VrfLabelBody) DecodeFromBytes(data []byte, version uint8, softwareName string) error {
+// Ref: zread_vrf_label in zebra/zapi_msg.c of FRR 5.x and 6.x
+func (b *vrfLabelBody) decodeFromBytes(data []byte, version uint8, softwareName string) error {
if len(data) < 6 {
- return fmt.Errorf("invalid message length for VRF_LABEL message: %d<6", len(data))
+ return fmt.Errorf("invalid message length for VRFLabel message: %d<6", len(data))
}
- b.Label = binary.BigEndian.Uint32(data[0:4])
- b.Afi = AFI(data[4])
- b.LabelType = LSP_TYPE(data[5])
+ b.label = binary.BigEndian.Uint32(data[0:4])
+ b.afi = afi(data[4])
+ b.labelType = lspTYPE(data[5])
return nil
}
-func (b *VrfLabelBody) String(version uint8, softwareName string) string {
+func (b *vrfLabelBody) string(version uint8, softwareName string) string {
return fmt.Sprintf(
- "label: %d, AFI: %s LSP_type: %s",
- b.Label, b.Afi, b.LabelType)
+ "label: %d, afi: %s LSP type: %s",
+ b.label, b.afi, b.labelType)
}
+// Message is referred in zclient
type Message struct {
Header Header
Body Body
}
-func (m *Message) Serialize(software string) ([]byte, error) {
+func (m *Message) serialize(software string) ([]byte, error) {
var body []byte
if m.Body != nil {
var err error
- body, err = m.Body.Serialize(m.Header.Version, software)
+ body, err = m.Body.serialize(m.Header.Version, software)
if err != nil {
return nil, err
}
}
m.Header.Len = uint16(len(body)) + HeaderSize(m.Header.Version)
- hdr, err := m.Header.Serialize()
+ hdr, err := m.Header.serialize()
if err != nil {
return nil, err
}
return append(hdr, body...), nil
}
-func (m *Message) parseMessage(data []byte, software string) error {
- switch m.Header.Command {
- case INTERFACE_ADD, INTERFACE_DELETE, INTERFACE_UP, INTERFACE_DOWN:
- m.Body = &InterfaceUpdateBody{}
- case INTERFACE_ADDRESS_ADD, INTERFACE_ADDRESS_DELETE:
- m.Body = &InterfaceAddressUpdateBody{}
- case ROUTER_ID_UPDATE:
- m.Body = &RouterIDUpdateBody{}
- case IPV4_ROUTE_ADD, IPV6_ROUTE_ADD, IPV4_ROUTE_DELETE, IPV6_ROUTE_DELETE:
- m.Body = &IPRouteBody{Api: m.Header.Command}
- case IPV4_NEXTHOP_LOOKUP, IPV6_NEXTHOP_LOOKUP:
- m.Body = &NexthopLookupBody{Api: m.Header.Command}
- case IPV4_IMPORT_LOOKUP:
- m.Body = &ImportLookupBody{Api: m.Header.Command}
- case NEXTHOP_UPDATE:
- m.Body = &NexthopUpdateBody{Api: m.Header.Command}
- default:
- m.Body = &UnknownBody{}
- }
- return m.Body.DecodeFromBytes(data, m.Header.Version, software)
-}
-
-func (m *Message) parseFrrMessage(data []byte, software string) error {
- switch m.Header.Command {
- case FRR_INTERFACE_ADD, FRR_INTERFACE_DELETE, FRR_INTERFACE_UP, FRR_INTERFACE_DOWN:
- m.Body = &InterfaceUpdateBody{}
- case FRR_INTERFACE_ADDRESS_ADD, FRR_INTERFACE_ADDRESS_DELETE:
- m.Body = &InterfaceAddressUpdateBody{}
- case FRR_ROUTER_ID_UPDATE:
- m.Body = &RouterIDUpdateBody{}
- case FRR_NEXTHOP_UPDATE:
- m.Body = &NexthopUpdateBody{}
- case FRR_INTERFACE_NBR_ADDRESS_ADD, FRR_INTERFACE_NBR_ADDRESS_DELETE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_INTERFACE_BFD_DEST_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_IMPORT_CHECK_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_BFD_DEST_REPLAY:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_REDISTRIBUTE_IPV4_ADD, FRR_REDISTRIBUTE_IPV4_DEL, FRR_REDISTRIBUTE_IPV6_ADD, FRR_REDISTRIBUTE_IPV6_DEL:
- m.Body = &IPRouteBody{Api: m.Header.Command}
- case FRR_INTERFACE_VRF_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_INTERFACE_LINK_PARAMS:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_PW_STATUS_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_LABEL_MANAGER_CONNECT:
- // Note: Synchronous message
- m.Body = &LabelManagerConnectBody{}
- case FRR_GET_LABEL_CHUNK:
- // Note: Synchronous message
- m.Body = &GetLabelChunkBody{}
- case FRR_RELEASE_LABEL_CHUNK:
- // Note: Synchronous message
- m.Body = &ReleaseLabelChunkBody{}
- default:
- m.Body = &UnknownBody{}
- }
- return m.Body.DecodeFromBytes(data, m.Header.Version, software)
-}
-
-func (m *Message) parseFrrZapi5Message(data []byte, software string) error {
- command := m.Header.Command
- if software == "frr4" {
- if c, err := frr4Zapi5Command(command, software, true); err == nil {
- command = c
- } else {
- return err
- }
- } else if software == "cumulus" {
- if c, err := cumulusZapi5Command(command, software, true); err == nil {
- command = c
- } else {
- return err
- }
- }
+func parseMessage(hdr *Header, data []byte, software string) (m *Message, err error) {
+ m = &Message{Header: *hdr}
+ /* TODO:
+ InterfaceNBRAddressAdd, InterfaceNBRAddressDelete,
+ InterfaceBFDDestUpdate, ImportCheckUpdate, BFDDestReplay,
+ InterfaceVRFUpdate, InterfaceLinkParams, PWStatusUpdate
+ */
+ command := m.Header.Command.toCommon(m.Header.Version, software)
switch command {
- case FRR_ZAPI5_INTERFACE_ADD, FRR_ZAPI5_INTERFACE_DELETE, FRR_ZAPI5_INTERFACE_UP, FRR_ZAPI5_INTERFACE_DOWN:
- m.Body = &InterfaceUpdateBody{}
- case FRR_ZAPI5_INTERFACE_ADDRESS_ADD, FRR_ZAPI5_INTERFACE_ADDRESS_DELETE:
- m.Body = &InterfaceAddressUpdateBody{}
- case FRR_ZAPI5_ROUTER_ID_UPDATE:
- m.Body = &RouterIDUpdateBody{}
- case FRR_ZAPI5_NEXTHOP_UPDATE:
+ case interfaceAdd, interfaceDelete, interfaceUp, interfaceDown:
+ m.Body = &interfaceUpdateBody{}
+ case interfaceAddressAdd, interfaceAddressDelete:
+ m.Body = &interfaceAddressUpdateBody{}
+ case routerIDUpdate:
+ m.Body = &routerIDUpdateBody{}
+ case nexthopUpdate:
m.Body = &NexthopUpdateBody{}
- case FRR_ZAPI5_INTERFACE_NBR_ADDRESS_ADD, FRR_ZAPI5_INTERFACE_NBR_ADDRESS_DELETE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_INTERFACE_BFD_DEST_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_IMPORT_CHECK_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_BFD_DEST_REPLAY:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_REDISTRIBUTE_ROUTE_ADD, FRR_ZAPI5_REDISTRIBUTE_ROUTE_DEL:
- m.Body = &IPRouteBody{Api: m.Header.Command}
- case FRR_ZAPI5_INTERFACE_VRF_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_INTERFACE_LINK_PARAMS:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_PW_STATUS_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI5_LABEL_MANAGER_CONNECT:
- // Note: Synchronous message
- m.Body = &LabelManagerConnectBody{}
- case FRR_ZAPI5_GET_LABEL_CHUNK:
- // Note: Synchronous message
+ case redistributeRouteAdd, redistributeRouteDel: // for frr
+ m.Body = &IPRouteBody{API: m.Header.Command}
+ case labelManagerConnect: // Note: Synchronous message
+ m.Body = &labelManagerConnectBody{}
+ case getLabelChunk: // Note: Synchronous message
m.Body = &GetLabelChunkBody{}
- case FRR_ZAPI5_RELEASE_LABEL_CHUNK:
- // Note: Synchronous message
- m.Body = &ReleaseLabelChunkBody{}
- case FRR_ZAPI5_VRF_LABEL:
- m.Body = &VrfLabelBody{}
+ case releaseLabelChunk: // Note: Synchronous message
+ m.Body = &releaseLabelChunkBody{}
+ case vrfLabel:
+ m.Body = &vrfLabelBody{}
+ case RouteAdd, RouteDelete, BackwardIPv6RouteAdd, BackwardIPv6RouteDelete: // for quagga
+ m.Body = &IPRouteBody{API: m.Header.Command}
+ case ipv4NexthopLookupMRIB:
+ m.Body = &lookupBody{api: m.Header.Command}
default:
- m.Body = &UnknownBody{}
- }
- return m.Body.DecodeFromBytes(data, m.Header.Version, software)
-}
-
-func (m *Message) parseFrrZapi6Message(data []byte, software string) error {
- command := m.Header.Command
- if software == "frr6" {
- if c, err := frr6Zapi6Command(command, software, true); err == nil {
- command = c
- } else {
- return err
- }
- } else if software == "frr7.2" {
- // frr7.2 adds INTERFACE_SET_PROTODOWN between INTERFACE_SET_MASTER(6) and ROUTE_ADD
- if command >= FRR_ZAPI6_ROUTE_ADD {
- command--
+ m.Body = &unknownBody{}
+ if m.Header.Version == 4 {
+ switch m.Header.Command {
+ case zapi4RedistributeIPv6Add, zapi4RedistributeIPv6Del: // for frr3
+ m.Body = &IPRouteBody{API: m.Header.Command}
+ }
+ } else if m.Header.Version < 4 {
+ switch m.Header.Command {
+ case zapi3IPv4NexthopLookup, zapi3IPv6NexthopLookup, zapi3IPv4ImportLookup:
+ m.Body = &lookupBody{api: m.Header.Command}
+ }
}
}
- switch command {
- case FRR_ZAPI6_INTERFACE_ADD, FRR_ZAPI6_INTERFACE_DELETE, FRR_ZAPI6_INTERFACE_UP, FRR_ZAPI6_INTERFACE_DOWN:
- m.Body = &InterfaceUpdateBody{}
- case FRR_ZAPI6_INTERFACE_ADDRESS_ADD, FRR_ZAPI6_INTERFACE_ADDRESS_DELETE:
- m.Body = &InterfaceAddressUpdateBody{}
- case FRR_ZAPI6_ROUTER_ID_UPDATE:
- m.Body = &RouterIDUpdateBody{}
- case FRR_ZAPI6_NEXTHOP_UPDATE:
- m.Body = &NexthopUpdateBody{}
- case FRR_ZAPI6_INTERFACE_NBR_ADDRESS_ADD, FRR_ZAPI6_INTERFACE_NBR_ADDRESS_DELETE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_INTERFACE_BFD_DEST_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_IMPORT_CHECK_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_BFD_DEST_REPLAY:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_REDISTRIBUTE_ROUTE_ADD, FRR_ZAPI6_REDISTRIBUTE_ROUTE_DEL:
- m.Body = &IPRouteBody{Api: command}
- case FRR_ZAPI6_INTERFACE_VRF_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_INTERFACE_LINK_PARAMS:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_PW_STATUS_UPDATE:
- // TODO
- m.Body = &UnknownBody{}
- case FRR_ZAPI6_LABEL_MANAGER_CONNECT:
- // Note: Synchronous message
- m.Body = &LabelManagerConnectBody{}
- case FRR_ZAPI6_GET_LABEL_CHUNK:
- // Note: Synchronous message
- m.Body = &GetLabelChunkBody{}
- case FRR_ZAPI6_RELEASE_LABEL_CHUNK:
- // Note: Synchronous message
- case FRR_ZAPI6_VRF_LABEL:
- m.Body = &VrfLabelBody{}
- default:
- m.Body = &UnknownBody{}
- }
- return m.Body.DecodeFromBytes(data, m.Header.Version, software)
-}
-
-func ParseMessage(hdr *Header, data []byte, software string) (m *Message, err error) {
- m = &Message{Header: *hdr}
- if m.Header.Version == 4 {
- err = m.parseFrrMessage(data, software)
- } else if m.Header.Version == 5 {
- err = m.parseFrrZapi5Message(data, software)
- } else if m.Header.Version == 6 {
- err = m.parseFrrZapi6Message(data, software)
- } else {
- err = m.parseMessage(data, software)
- }
- if err != nil {
- return nil, err
- }
- return m, nil
-}
-
-// frr6Zapi6Command adjust command (API_TYPE) between Frr6 Zebra and frr7 Zapi6
-func frr6Zapi6Command(command API_TYPE, softwareName string, from bool) (API_TYPE, error) {
- if softwareName != "frr6" {
- return command, fmt.Errorf("softwareName %s is not supported", softwareName)
- }
- // frr6 has ZEBRA_IPV4_ROUTE_IPV6_NEXTHOP_ADD (ID:28), frr7 removes it.
- // frr7 adds ZEBRA_DUPLICATE_ADDR_DETECTION (ID:72).
- if from && FRR_ZAPI6_BFD_DEST_REGISTER < command && command < FRR_ZAPI6_PW_ADD {
- // if true, command will be converted from Frr6 Zebra to Frr7 Zapi6 (for parsing)
- return command - 1, nil
- } else if !from && FRR_ZAPI6_IMPORT_CHECK_UPDATE < command && command < FRR_ZAPI6_DUPLICATE_ADDR_DETECTION {
- // if false, command will be converted from Frr7 Zapi6 to Frr6 Zebra (for send)
- return command + 1, nil
- }
- return command, nil
-}
-
-// frr4Zapi5Command adjust command (API_TYPE) between Frr4 Zebra and latest Zapi5
-func frr4Zapi5Command(command API_TYPE, softwareName string, from bool) (API_TYPE, error) {
- if softwareName != "frr4" {
- return command, fmt.Errorf("softwareName %s is not supported", softwareName)
- }
- // if from is true, command will be converted from Frr4 Zebra to latest Zapi5 (for parsing)
- // if from is false, command will be converted from latest Zapi5 to Frr4 Zebra (for send)
- sign := 1
- if !from {
- sign = -1
- }
- /*
- frr5 adds ZEBRA_CAPABILITIES (ID:22), ZEBRA_VRF_LABEL (ID:42),
- ZEBRA_LABEL_MANAGER_CONNECT_ASYNC (ID:53), ZEBRA_ADVERTISE_SUBNET (ID:60),
- ZEBRA_IP_PREFIX_ROUTE_ADD (ID:70), ZEBRA_IP_PREFIX_ROUTE_DEL (ID:71) and
- from ZEBRA_RULE_ADD (ID:79) and ZEBRA_IPTABLE_NOTIFY_OWNER (ID:93)
- */
- if FRR_ZAPI5_HELLO < command { // ZEBRA_HELLO: ID:21 in frr4, ID:21 in frr5
- command = API_TYPE(int(command) + sign)
- }
- if FRR_ZAPI5_VRF_DELETE < command { // ZEBRA_VRF_DELETE: ID:40 in frr4, ID:41 in frr5
- command = API_TYPE(int(command) + sign)
- }
- // ZEBRA_LABEL_MANAGER_CONNECT : ID:50 in frr4, ID:52 in frr5
- if FRR_ZAPI5_LABEL_MANAGER_CONNECT < command {
- command = API_TYPE(int(command) + sign)
- }
- // ZEBRA_ADVERTISE_DEFAULT_GW : ID:56 in frr4, ID:59 in frr5
- if FRR_ZAPI5_ADVERTISE_DEFAULT_GW < command {
- command = API_TYPE(int(command) + sign)
- }
- // ZEBRA_MACIP_DEL : ID:64 in frr4, ID:69 in frr5
- if FRR_ZAPI5_MACIP_DEL < command {
- command = API_TYPE(int(command) + (2 * sign))
- }
- // ZBRA_PW_SATUS_UPDATE: ID:72 in frr4, ID:78 in frr5
- if FRR_ZAPI5_PW_STATUS_UPDATE < command {
- return command, fmt.Errorf("unsupported command")
- }
- return command, nil
+ return m, m.Body.decodeFromBytes(data, m.Header.Version, software)
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-15 14:52:49 +0000