summaryrefslogtreecommitdiffhomepage
path: root/zebra
diff options
context:
space:
mode:
Diffstat (limited to 'zebra')
-rw-r--r--zebra/afi_string.go17
-rw-r--r--zebra/api_type_string.go16
-rw-r--r--zebra/link_type_string.go16
-rw-r--r--zebra/nexthop_flag_string.go17
-rw-r--r--zebra/ptm_enable_string.go16
-rw-r--r--zebra/ptm_status_string.go16
-rw-r--r--zebra/route_type_string.go16
-rw-r--r--zebra/safi_string.go17
-rw-r--r--zebra/zapi.go1917
-rw-r--r--zebra/zapi_bsd.go58
-rw-r--r--zebra/zapi_darwin.go59
-rw-r--r--zebra/zapi_linux.go83
-rw-r--r--zebra/zapi_test.go531
-rw-r--r--zebra/zapi_windows.go38
14 files changed, 0 insertions, 2817 deletions
diff --git a/zebra/afi_string.go b/zebra/afi_string.go
deleted file mode 100644
index 6c07a09d..00000000
--- a/zebra/afi_string.go
+++ /dev/null
@@ -1,17 +0,0 @@
-// Code generated by "stringer -type=AFI"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _AFI_name = "AFI_IPAFI_IP6AFI_ETHERAFI_MAX"
-
-var _AFI_index = [...]uint8{0, 6, 13, 22, 29}
-
-func (i AFI) String() string {
- i -= 1
- if i >= AFI(len(_AFI_index)-1) {
- return fmt.Sprintf("AFI(%d)", i+1)
- }
- return _AFI_name[_AFI_index[i]:_AFI_index[i+1]]
-}
diff --git a/zebra/api_type_string.go b/zebra/api_type_string.go
deleted file mode 100644
index e97059b1..00000000
--- a/zebra/api_type_string.go
+++ /dev/null
@@ -1,16 +0,0 @@
-// Code generated by "stringer -type=API_TYPE"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _API_TYPE_name = "FRR_INTERFACE_ADDINTERFACE_ADDINTERFACE_DELETEINTERFACE_ADDRESS_ADDINTERFACE_ADDRESS_DELETEINTERFACE_UPINTERFACE_DOWNIPV4_ROUTE_ADDIPV4_ROUTE_DELETEIPV6_ROUTE_ADDIPV6_ROUTE_DELETEREDISTRIBUTE_ADDREDISTRIBUTE_DELETEREDISTRIBUTE_DEFAULT_ADDREDISTRIBUTE_DEFAULT_DELETEIPV4_NEXTHOP_LOOKUPIPV6_NEXTHOP_LOOKUPIPV4_IMPORT_LOOKUPIPV6_IMPORT_LOOKUPINTERFACE_RENAMEROUTER_ID_ADDROUTER_ID_DELETEROUTER_ID_UPDATEHELLOIPV4_NEXTHOP_LOOKUP_MRIBVRF_UNREGISTERINTERFACE_LINK_PARAMSNEXTHOP_REGISTERNEXTHOP_UNREGISTERNEXTHOP_UPDATEMESSAGE_MAXFRR_BFD_DEST_REPLAYFRR_REDISTRIBUTE_IPV4_ADDFRR_REDISTRIBUTE_IPV4_DELFRR_REDISTRIBUTE_IPV6_ADDFRR_REDISTRIBUTE_IPV6_DELFRR_VRF_UNREGISTERFRR_VRF_ADDFRR_VRF_DELETEFRR_INTERFACE_VRF_UPDATEFRR_BFD_CLIENT_REGISTERFRR_INTERFACE_ENABLE_RADVFRR_INTERFACE_DISABLE_RADVFRR_IPV4_NEXTHOP_LOOKUP_MRIBFRR_INTERFACE_LINK_PARAMSFRR_MPLS_LABELS_ADDFRR_MPLS_LABELS_DELETEFRR_IPV4_NEXTHOP_ADDFRR_IPV4_NEXTHOP_DELETEFRR_IPV6_NEXTHOP_ADDFRR_IPV6_NEXTHOP_DELETEFRR_IPMR_ROUTE_STATSFRR_LABEL_MANAGER_CONNECTFRR_GET_LABEL_CHUNKFRR_RELEASE_LABEL_CHUNKFRR_PW_ADDFRR_PW_DELETEFRR_PW_SETFRR_PW_UNSETFRR_PW_STATUS_UPDATE"
-
-var _API_TYPE_index = [...]uint16{0, 17, 30, 46, 67, 91, 103, 117, 131, 148, 162, 179, 195, 214, 238, 265, 284, 303, 321, 339, 355, 368, 384, 400, 405, 429, 443, 464, 480, 498, 512, 523, 542, 567, 592, 617, 642, 660, 671, 685, 709, 732, 757, 783, 811, 836, 855, 877, 897, 920, 940, 963, 983, 1008, 1027, 1050, 1060, 1073, 1083, 1095, 1115}
-
-func (i API_TYPE) String() string {
- if i >= API_TYPE(len(_API_TYPE_index)-1) {
- return fmt.Sprintf("API_TYPE(%d)", i)
- }
- return _API_TYPE_name[_API_TYPE_index[i]:_API_TYPE_index[i+1]]
-}
diff --git a/zebra/link_type_string.go b/zebra/link_type_string.go
deleted file mode 100644
index 9db8544b..00000000
--- a/zebra/link_type_string.go
+++ /dev/null
@@ -1,16 +0,0 @@
-// Code generated by "stringer -type=LINK_TYPE"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _LINK_TYPE_name = "LINK_TYPE_UNKNOWNLINK_TYPE_ETHERLINK_TYPE_EETHERLINK_TYPE_AX25LINK_TYPE_PRONETLINK_TYPE_IEEE802LINK_TYPE_ARCNETLINK_TYPE_APPLETLKLINK_TYPE_DLCILINK_TYPE_ATMLINK_TYPE_METRICOMLINK_TYPE_IEEE1394LINK_TYPE_EUI64LINK_TYPE_INFINIBANDLINK_TYPE_SLIPLINK_TYPE_CSLIPLINK_TYPE_SLIP6LINK_TYPE_CSLIP6LINK_TYPE_RSRVDLINK_TYPE_ADAPTLINK_TYPE_ROSELINK_TYPE_X25LINK_TYPE_PPPLINK_TYPE_CHDLCLINK_TYPE_LAPBLINK_TYPE_RAWHDLCLINK_TYPE_IPIPLINK_TYPE_IPIP6LINK_TYPE_FRADLINK_TYPE_SKIPLINK_TYPE_LOOPBACKLINK_TYPE_LOCALTLKLINK_TYPE_FDDILINK_TYPE_SITLINK_TYPE_IPDDPLINK_TYPE_IPGRELINK_TYPE_IP6GRELINK_TYPE_PIMREGLINK_TYPE_HIPPILINK_TYPE_ECONETLINK_TYPE_IRDALINK_TYPE_FCPPLINK_TYPE_FCALLINK_TYPE_FCPLLINK_TYPE_FCFABRICLINK_TYPE_IEEE802_TRLINK_TYPE_IEEE80211LINK_TYPE_IEEE80211_RADIOTAPLINK_TYPE_IEEE802154LINK_TYPE_IEEE802154_PHY"
-
-var _LINK_TYPE_index = [...]uint16{0, 17, 32, 48, 62, 78, 95, 111, 129, 143, 156, 174, 192, 207, 227, 241, 256, 271, 287, 302, 317, 331, 344, 357, 372, 386, 403, 417, 432, 446, 460, 478, 496, 510, 523, 538, 553, 569, 585, 600, 616, 630, 644, 658, 672, 690, 710, 729, 757, 777, 801}
-
-func (i LINK_TYPE) String() string {
- if i >= LINK_TYPE(len(_LINK_TYPE_index)-1) {
- return fmt.Sprintf("LINK_TYPE(%d)", i)
- }
- return _LINK_TYPE_name[_LINK_TYPE_index[i]:_LINK_TYPE_index[i+1]]
-}
diff --git a/zebra/nexthop_flag_string.go b/zebra/nexthop_flag_string.go
deleted file mode 100644
index 38f08b8a..00000000
--- a/zebra/nexthop_flag_string.go
+++ /dev/null
@@ -1,17 +0,0 @@
-// Code generated by "stringer -type=NEXTHOP_FLAG"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _NEXTHOP_FLAG_name = "NEXTHOP_IFINDEXNEXTHOP_IFNAMENEXTHOP_IPV4NEXTHOP_IPV4_IFINDEXNEXTHOP_IPV4_IFNAMENEXTHOP_IPV6NEXTHOP_IPV6_IFINDEXNEXTHOP_IPV6_IFNAMENEXTHOP_BLACKHOLE"
-
-var _NEXTHOP_FLAG_index = [...]uint8{0, 15, 29, 41, 61, 80, 92, 112, 131, 148}
-
-func (i NEXTHOP_FLAG) String() string {
- i -= 1
- if i >= NEXTHOP_FLAG(len(_NEXTHOP_FLAG_index)-1) {
- return fmt.Sprintf("NEXTHOP_FLAG(%d)", i+1)
- }
- return _NEXTHOP_FLAG_name[_NEXTHOP_FLAG_index[i]:_NEXTHOP_FLAG_index[i+1]]
-}
diff --git a/zebra/ptm_enable_string.go b/zebra/ptm_enable_string.go
deleted file mode 100644
index d750542e..00000000
--- a/zebra/ptm_enable_string.go
+++ /dev/null
@@ -1,16 +0,0 @@
-// Code generated by "stringer -type=PTM_ENABLE"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _PTM_ENABLE_name = "PTM_ENABLE_OFFPTM_ENABLE_ONPTM_ENABLE_UNSPEC"
-
-var _PTM_ENABLE_index = [...]uint8{0, 14, 27, 44}
-
-func (i PTM_ENABLE) String() string {
- if i >= PTM_ENABLE(len(_PTM_ENABLE_index)-1) {
- return fmt.Sprintf("PTM_ENABLE(%d)", i)
- }
- return _PTM_ENABLE_name[_PTM_ENABLE_index[i]:_PTM_ENABLE_index[i+1]]
-}
diff --git a/zebra/ptm_status_string.go b/zebra/ptm_status_string.go
deleted file mode 100644
index 464233b7..00000000
--- a/zebra/ptm_status_string.go
+++ /dev/null
@@ -1,16 +0,0 @@
-// Code generated by "stringer -type=PTM_STATUS"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _PTM_STATUS_name = "PTM_STATUS_DOWNPTM_STATUS_UPPTM_STATUS_UNKNOWN"
-
-var _PTM_STATUS_index = [...]uint8{0, 15, 28, 46}
-
-func (i PTM_STATUS) String() string {
- if i >= PTM_STATUS(len(_PTM_STATUS_index)-1) {
- return fmt.Sprintf("PTM_STATUS(%d)", i)
- }
- return _PTM_STATUS_name[_PTM_STATUS_index[i]:_PTM_STATUS_index[i+1]]
-}
diff --git a/zebra/route_type_string.go b/zebra/route_type_string.go
deleted file mode 100644
index e2ad6c97..00000000
--- a/zebra/route_type_string.go
+++ /dev/null
@@ -1,16 +0,0 @@
-// Code generated by "stringer -type=ROUTE_TYPE"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _ROUTE_TYPE_name = "ROUTE_SYSTEMROUTE_KERNELROUTE_CONNECTROUTE_STATICROUTE_RIPROUTE_RIPNGROUTE_OSPFROUTE_OSPF6ROUTE_ISISROUTE_BGPROUTE_PIMROUTE_HSLSROUTE_OLSRROUTE_BABELROUTE_MAXFRR_ROUTE_VNCFRR_ROUTE_VNC_DIRECTFRR_ROUTE_VNC_DIRECT_RHFRR_ROUTE_BGP_DIRECTFRR_ROUTE_BGP_DIRECT_EXTFRR_ROUTE_ALLFRR_ROUTE_MAX"
-
-var _ROUTE_TYPE_index = [...]uint16{0, 12, 24, 37, 49, 58, 69, 79, 90, 100, 109, 118, 128, 138, 149, 158, 171, 191, 214, 234, 258, 271, 284}
-
-func (i ROUTE_TYPE) String() string {
- if i >= ROUTE_TYPE(len(_ROUTE_TYPE_index)-1) {
- return fmt.Sprintf("ROUTE_TYPE(%d)", i)
- }
- return _ROUTE_TYPE_name[_ROUTE_TYPE_index[i]:_ROUTE_TYPE_index[i+1]]
-}
diff --git a/zebra/safi_string.go b/zebra/safi_string.go
deleted file mode 100644
index ab491cb6..00000000
--- a/zebra/safi_string.go
+++ /dev/null
@@ -1,17 +0,0 @@
-// Code generated by "stringer -type=SAFI"; DO NOT EDIT.
-
-package zebra
-
-import "fmt"
-
-const _SAFI_name = "SAFI_UNICASTSAFI_MULTICASTSAFI_RESERVED_3SAFI_MPLS_VPNSAFI_MAX"
-
-var _SAFI_index = [...]uint8{0, 12, 26, 41, 54, 62}
-
-func (i SAFI) String() string {
- i -= 1
- if i >= SAFI(len(_SAFI_index)-1) {
- return fmt.Sprintf("SAFI(%d)", i+1)
- }
- return _SAFI_name[_SAFI_index[i]:_SAFI_index[i+1]]
-}
diff --git a/zebra/zapi.go b/zebra/zapi.go
deleted file mode 100644
index 667cfcd9..00000000
--- a/zebra/zapi.go
+++ /dev/null
@@ -1,1917 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package zebra
-
-import (
- "encoding/binary"
- "fmt"
- "io"
- "net"
- "strings"
- "syscall"
-
- log "github.com/sirupsen/logrus"
-
- "github.com/osrg/gobgp/packet/bgp"
-)
-
-const (
- HEADER_MARKER = 255
- FRR_HEADER_MARKER = 254
- INTERFACE_NAMSIZ = 20
-)
-
-// Internal Interface Status.
-type INTERFACE_STATUS uint8
-
-const (
- INTERFACE_ACTIVE INTERFACE_STATUS = 0x01
- INTERFACE_SUB INTERFACE_STATUS = 0x02
- INTERFACE_LINKDETECTION INTERFACE_STATUS = 0x04
- INTERFACE_VRF_LOOPBACK INTERFACE_STATUS = 0x08
-)
-
-// Interface Link Layer Types.
-//go:generate stringer -type=LINK_TYPE
-type LINK_TYPE 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
-)
-
-const VRF_DEFAULT = 0
-
-func HeaderSize(version uint8) uint16 {
- switch version {
- case 3, 4:
- return 8
- default:
- return 6
- }
-}
-
-func (t INTERFACE_STATUS) String() string {
- ss := make([]string, 0, 3)
- if t&INTERFACE_ACTIVE > 0 {
- ss = append(ss, "ACTIVE")
- }
- if t&INTERFACE_SUB > 0 {
- ss = append(ss, "SUB")
- }
- if t&INTERFACE_LINKDETECTION > 0 {
- ss = append(ss, "LINKDETECTION")
- }
- if t&INTERFACE_VRF_LOOPBACK > 0 {
- ss = append(ss, "VRF_LOOPBACK")
- }
- return strings.Join(ss, "|")
-}
-
-// Interface Connected Address Flags
-type INTERFACE_ADDRESS_FLAG uint8
-
-const (
- INTERFACE_ADDRESS_SECONDARY INTERFACE_ADDRESS_FLAG = 0x01
- INTERFACE_ADDRESS_PEER INTERFACE_ADDRESS_FLAG = 0x02
- INTERFACE_ADDRESS_UNNUMBERED INTERFACE_ADDRESS_FLAG = 0x04
-)
-
-func (t INTERFACE_ADDRESS_FLAG) String() string {
- ss := make([]string, 0, 3)
- if t&INTERFACE_ADDRESS_SECONDARY > 0 {
- ss = append(ss, "SECONDARY")
- }
- if t&INTERFACE_ADDRESS_PEER > 0 {
- ss = append(ss, "PEER")
- }
- if t&INTERFACE_ADDRESS_UNNUMBERED > 0 {
- ss = append(ss, "UNNUMBERED")
- }
- return strings.Join(ss, "|")
-}
-
-// 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
-)
-
-// Subsequent Address Family Identifier.
-//go:generate stringer -type=SAFI
-type SAFI uint8
-
-const (
- _ SAFI = iota
- SAFI_UNICAST
- SAFI_MULTICAST
- SAFI_RESERVED_3
- SAFI_MPLS_VPN
- SAFI_MAX
-)
-
-// API Types.
-//go:generate stringer -type=API_TYPE
-type API_TYPE uint16
-
-// 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
-)
-
-// For FRRouting.
-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
-)
-
-// Route Types.
-//go:generate stringer -type=ROUTE_TYPE
-type ROUTE_TYPE uint8
-
-// For Quagga.
-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_MAX
-)
-
-// For FRRouting.
-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
-)
-
-var routeTypeValueMap = map[string]ROUTE_TYPE{
- "system": ROUTE_SYSTEM,
- "kernel": ROUTE_KERNEL,
- "connect": ROUTE_CONNECT, // hack for backyard 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,
- "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,
-}
-
-func RouteTypeFromString(typ string) (ROUTE_TYPE, error) {
- t, ok := routeTypeValueMap[typ]
- if ok {
- return t, nil
- }
- return t, fmt.Errorf("unknown route type: %s", typ)
-}
-
-// API Message Flags.
-type MESSAGE_FLAG uint8
-
-// 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
-)
-
-func (t MESSAGE_FLAG) String() string {
- var ss []string
- if t&MESSAGE_NEXTHOP > 0 {
- ss = append(ss, "NEXTHOP")
- }
- if t&MESSAGE_IFINDEX > 0 {
- ss = append(ss, "IFINDEX")
- }
- if t&MESSAGE_DISTANCE > 0 {
- ss = append(ss, "DISTANCE")
- }
- if t&MESSAGE_METRIC > 0 {
- ss = append(ss, "METRIC")
- }
- if t&MESSAGE_MTU > 0 {
- ss = append(ss, "MTU")
- }
- if t&MESSAGE_TAG > 0 {
- ss = append(ss, "TAG")
- }
- return strings.Join(ss, "|")
-}
-
-// 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
-)
-
-// Message Flags
-type FLAG uint64
-
-const (
- FLAG_INTERNAL FLAG = 0x01
- FLAG_SELFROUTE FLAG = 0x02
- FLAG_BLACKHOLE FLAG = 0x04
- FLAG_IBGP FLAG = 0x08
- FLAG_SELECTED FLAG = 0x10
- FLAG_CHANGED FLAG = 0x20
- FLAG_STATIC FLAG = 0x40
- FLAG_REJECT FLAG = 0x80
- FLAG_SCOPE_LINK FLAG = 0x100
- FLAG_FIB_OVERRIDE FLAG = 0x200
-)
-
-func (t FLAG) String() string {
- var ss []string
- if t&FLAG_INTERNAL > 0 {
- ss = append(ss, "FLAG_INTERNAL")
- }
- if t&FLAG_SELFROUTE > 0 {
- ss = append(ss, "FLAG_SELFROUTE")
- }
- if t&FLAG_BLACKHOLE > 0 {
- ss = append(ss, "FLAG_BLACKHOLE")
- }
- if t&FLAG_IBGP > 0 {
- ss = append(ss, "FLAG_IBGP")
- }
- if t&FLAG_SELECTED > 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")
- }
- return strings.Join(ss, "|")
-}
-
-// Nexthop Flags.
-//go:generate stringer -type=NEXTHOP_FLAG
-type NEXTHOP_FLAG uint8
-
-// For Quagga.
-const (
- _ NEXTHOP_FLAG = iota
- NEXTHOP_IFINDEX
- NEXTHOP_IFNAME
- NEXTHOP_IPV4
- NEXTHOP_IPV4_IFINDEX
- NEXTHOP_IPV4_IFNAME
- NEXTHOP_IPV6
- NEXTHOP_IPV6_IFINDEX
- NEXTHOP_IPV6_IFNAME
- NEXTHOP_BLACKHOLE
-)
-
-// For FRRouting.
-const (
- _ NEXTHOP_FLAG = iota
- FRR_NEXTHOP_IFINDEX
- FRR_NEXTHOP_IPV4
- FRR_NEXTHOP_IPV4_IFINDEX
- FRR_NEXTHOP_IPV6
- FRR_NEXTHOP_IPV6_IFINDEX
- FRR_NEXTHOP_BLACKHOLE
-)
-
-// Interface PTM Enable Configuration.
-//go:generate stringer -type=PTM_ENABLE
-type PTM_ENABLE uint8
-
-const (
- PTM_ENABLE_OFF PTM_ENABLE = 0
- PTM_ENABLE_ON PTM_ENABLE = 1
- PTM_ENABLE_UNSPEC PTM_ENABLE = 2
-)
-
-// PTM Status.
-//go:generate stringer -type=PTM_STATUS
-type PTM_STATUS uint8
-
-const (
- PTM_STATUS_DOWN PTM_STATUS = 0
- PTM_STATUS_UP PTM_STATUS = 1
- PTM_STATUS_UNKNOWN PTM_STATUS = 2
-)
-
-type Client struct {
- outgoing chan *Message
- incoming chan *Message
- redistDefault ROUTE_TYPE
- conn net.Conn
- Version uint8
-}
-
-func NewClient(network, address string, typ ROUTE_TYPE, version uint8) (*Client, error) {
- conn, err := net.Dial(network, address)
- if err != nil {
- return nil, err
- }
- outgoing := make(chan *Message)
- incoming := make(chan *Message, 64)
- if version < 2 {
- version = 2
- } else if version > 4 {
- version = 4
- }
-
- c := &Client{
- outgoing: outgoing,
- incoming: incoming,
- redistDefault: typ,
- conn: conn,
- Version: version,
- }
-
- go func() {
- for {
- m, more := <-outgoing
- if more {
- b, err := m.Serialize()
- if err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- }).Warnf("failed to serialize: %v", m)
- continue
- }
-
- _, err = conn.Write(b)
- if err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- }).Errorf("failed to write: %s", err)
- close(outgoing)
- }
- } else {
- log.Debug("finish outgoing loop")
- return
- }
- }
- }()
-
- // Send HELLO/ROUTER_ID_ADD messages to negotiate the Zebra message version.
- c.SendHello()
- c.SendRouterIDAdd()
-
- receiveSingleMsg := func() (*Message, error) {
- headerBuf, err := readAll(conn, int(HeaderSize(version)))
- if err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Error": err,
- }).Error("failed to read header")
- return nil, err
- }
-
- hd := &Header{}
- err = hd.DecodeFromBytes(headerBuf)
- if err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Data": headerBuf,
- "Error": err,
- }).Error("failed to decode header")
- return nil, err
- }
-
- bodyBuf, err := readAll(conn, int(hd.Len-HeaderSize(version)))
- if err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Header": hd,
- "Error": err,
- }).Error("failed to read body")
- return nil, err
- }
-
- m, err := ParseMessage(hd, bodyBuf)
- if err != nil {
- // Just outputting warnings (not error message) and ignore this
- // error considering the case that body parser is not implemented
- // yet.
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Header": hd,
- "Data": bodyBuf,
- "Error": err,
- }).Warn("failed to decode body")
- return nil, nil
- }
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Message": m,
- }).Debug("read message from zebra")
-
- return m, nil
- }
-
- // Try to receive the first message from Zebra.
- if m, err := receiveSingleMsg(); err != nil {
- c.Close()
- // Return error explicitly in order to retry connection.
- return nil, err
- } else if m != nil {
- incoming <- m
- }
-
- // Start receive loop only when the first message successfully received.
- go func() {
- defer close(incoming)
- for {
- if m, err := receiveSingleMsg(); err != nil {
- return
- } else if m != nil {
- incoming <- m
- }
- }
- }()
-
- return c, nil
-}
-
-func readAll(conn net.Conn, length int) ([]byte, error) {
- buf := make([]byte, length)
- _, err := io.ReadFull(conn, buf)
- return buf, err
-}
-
-func (c *Client) Receive() chan *Message {
- return c.incoming
-}
-
-func (c *Client) Send(m *Message) {
- defer func() {
- if err := recover(); err != nil {
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- }).Debugf("recovered: %s", err)
- }
- }()
- log.WithFields(log.Fields{
- "Topic": "Zebra",
- "Header": m.Header,
- "Body": m.Body,
- }).Debug("send command to zebra")
- c.outgoing <- m
-}
-
-func (c *Client) SendCommand(command API_TYPE, vrfId uint16, body Body) error {
- var marker uint8 = HEADER_MARKER
- if c.Version >= 4 {
- marker = FRR_HEADER_MARKER
- }
- m := &Message{
- Header: Header{
- Len: HeaderSize(c.Version),
- Marker: marker,
- Version: c.Version,
- VrfId: vrfId,
- Command: command,
- },
- Body: body,
- }
- c.Send(m)
- return nil
-}
-
-func (c *Client) SendHello() error {
- if c.redistDefault > 0 {
- command := HELLO
- body := &HelloBody{
- RedistDefault: c.redistDefault,
- Instance: 0,
- }
- if c.Version >= 4 {
- command = FRR_HELLO
- }
- return c.SendCommand(command, VRF_DEFAULT, body)
- }
- return nil
-}
-
-func (c *Client) SendRouterIDAdd() error {
- command := ROUTER_ID_ADD
- if c.Version >= 4 {
- command = FRR_ROUTER_ID_ADD
- }
- return c.SendCommand(command, VRF_DEFAULT, nil)
-}
-
-func (c *Client) SendInterfaceAdd() error {
- command := INTERFACE_ADD
- if c.Version >= 4 {
- command = FRR_INTERFACE_ADD
- }
- return c.SendCommand(command, VRF_DEFAULT, nil)
-}
-
-func (c *Client) SendRedistribute(t ROUTE_TYPE, vrfId uint16) error {
- command := REDISTRIBUTE_ADD
- if c.redistDefault != t {
- bodies := make([]*RedistributeBody, 0)
- if c.Version <= 3 {
- bodies = append(bodies, &RedistributeBody{
- Redist: t,
- })
- } else { // version >= 4
- command = FRR_REDISTRIBUTE_ADD
- for _, afi := range []AFI{AFI_IP, AFI_IP6} {
- bodies = append(bodies, &RedistributeBody{
- Afi: afi,
- Redist: t,
- Instance: 0,
- })
- }
- }
-
- for _, body := range bodies {
- return c.SendCommand(command, 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
- }
- body := &RedistributeBody{
- Redist: t,
- }
- return c.SendCommand(command, VRF_DEFAULT, body)
- } else {
- return fmt.Errorf("unknown route type: %d", t)
- }
-}
-
-func (c *Client) SendIPRoute(vrfId uint16, body *IPRouteBody, isWithdraw bool) error {
- command := IPV4_ROUTE_ADD
- if c.Version <= 3 {
- if body.Prefix.To4() != nil {
- if isWithdraw {
- command = IPV4_ROUTE_DELETE
- }
- } else {
- if isWithdraw {
- command = IPV6_ROUTE_DELETE
- } else {
- command = IPV6_ROUTE_ADD
- }
- }
- } else { // version >= 4
- if body.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
- }
- }
- }
- return c.SendCommand(command, vrfId, body)
-}
-
-func (c *Client) SendNexthopRegister(vrfId uint16, body *NexthopRegisterBody, isWithdraw bool) error {
- // Note: NEXTHOP_REGISTER and NEXTHOP_UNREGISTER 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)
- }
- command := NEXTHOP_REGISTER
- if c.Version == 3 {
- if isWithdraw {
- command = NEXTHOP_UNREGISTER
- }
- } else { // version >= 4
- if isWithdraw {
- command = FRR_NEXTHOP_UNREGISTER
- } else {
- command = FRR_NEXTHOP_REGISTER
- }
- }
- return c.SendCommand(command, vrfId, body)
-}
-
-func (c *Client) Close() error {
- close(c.outgoing)
- return c.conn.Close()
-}
-
-type Header struct {
- Len uint16
- Marker uint8
- Version uint8
- VrfId uint16
- Command API_TYPE
-}
-
-func (h *Header) Serialize() ([]byte, error) {
- buf := make([]byte, HeaderSize(h.Version))
- binary.BigEndian.PutUint16(buf[0:2], h.Len)
- buf[2] = h.Marker
- buf[3] = h.Version
- switch h.Version {
- 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[6:8], uint16(h.Command))
- default:
- return nil, fmt.Errorf("Unsupported ZAPI version: %d", h.Version)
- }
- return buf, nil
-}
-
-func (h *Header) DecodeFromBytes(data []byte) error {
- if uint16(len(data)) < 4 {
- return fmt.Errorf("Not all ZAPI message header")
- }
- h.Len = binary.BigEndian.Uint16(data[0:2])
- h.Marker = data[2]
- h.Version = data[3]
- if uint16(len(data)) < HeaderSize(h.Version) {
- return fmt.Errorf("Not all ZAPI message header")
- }
- switch h.Version {
- case 2:
- h.Command = API_TYPE(binary.BigEndian.Uint16(data[4:6]))
- case 3, 4:
- h.VrfId = binary.BigEndian.Uint16(data[4:6])
- h.Command = API_TYPE(binary.BigEndian.Uint16(data[6:8]))
- default:
- return fmt.Errorf("Unsupported ZAPI version: %d", h.Version)
- }
- return nil
-}
-
-type Body interface {
- DecodeFromBytes([]byte, uint8) error
- Serialize(uint8) ([]byte, error)
- String() string
-}
-
-type UnknownBody struct {
- Data []byte
-}
-
-func (b *UnknownBody) DecodeFromBytes(data []byte, version uint8) error {
- b.Data = data
- return nil
-}
-
-func (b *UnknownBody) Serialize(version uint8) ([]byte, error) {
- return b.Data, nil
-}
-
-func (b *UnknownBody) String() string {
- return fmt.Sprintf("data: %v", b.Data)
-}
-
-type HelloBody struct {
- RedistDefault ROUTE_TYPE
- Instance uint16
-}
-
-func (b *HelloBody) DecodeFromBytes(data []byte, version uint8) error {
- b.RedistDefault = ROUTE_TYPE(data[0])
- if version >= 4 {
- b.Instance = binary.BigEndian.Uint16(data[1:3])
- }
- return nil
-}
-
-func (b *HelloBody) Serialize(version uint8) ([]byte, error) {
- if version <= 3 {
- return []byte{uint8(b.RedistDefault)}, nil
- } else { // version >= 4
- buf := make([]byte, 3)
- buf[0] = uint8(b.RedistDefault)
- binary.BigEndian.PutUint16(buf[1:3], b.Instance)
- return buf, nil
-
- }
-}
-
-func (b *HelloBody) String() string {
- return fmt.Sprintf(
- "route_type: %s, instance :%d",
- b.RedistDefault.String(), b.Instance)
-}
-
-type RedistributeBody struct {
- Afi AFI
- Redist ROUTE_TYPE
- Instance uint16
-}
-
-func (b *RedistributeBody) DecodeFromBytes(data []byte, version uint8) error {
- if version <= 3 {
- b.Redist = ROUTE_TYPE(data[0])
- } else { // version >= 4
- b.Afi = AFI(data[0])
- b.Redist = ROUTE_TYPE(data[1])
- b.Instance = binary.BigEndian.Uint16(data[2:4])
- }
- return nil
-}
-
-func (b *RedistributeBody) Serialize(version uint8) ([]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
- }
-}
-
-func (b *RedistributeBody) String() string {
- return fmt.Sprintf(
- "afi: %s, route_type: %s, instance :%d",
- b.Afi.String(), b.Redist.String(), b.Instance)
-}
-
-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
- Linktype LINK_TYPE
- HardwareAddr net.HardwareAddr
-}
-
-func (b *InterfaceUpdateBody) DecodeFromBytes(data []byte, version uint8) error {
- if len(data) < INTERFACE_NAMSIZ+29 {
- 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])
- data = data[23:]
- } else {
- 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])
- if version >= 3 {
- b.Linktype = LINK_TYPE(binary.BigEndian.Uint32(data[12:16]))
- data = data[16:]
- } else {
- data = data[12:]
- }
- l := binary.BigEndian.Uint32(data[:4])
- if l > 0 {
- if len(data) < 4+int(l) {
- return fmt.Errorf("lack of bytes. need %d but %d", 4+l, len(data))
- }
- b.HardwareAddr = data[4 : 4+l]
- }
- return nil
-}
-
-func (b *InterfaceUpdateBody) Serialize(version uint8) ([]byte, error) {
- return []byte{}, nil
-}
-
-func (b *InterfaceUpdateBody) 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())
- }
- return s
-}
-
-type InterfaceAddressUpdateBody struct {
- Index uint32
- Flags INTERFACE_ADDRESS_FLAG
- Prefix net.IP
- Length uint8
- Destination net.IP
-}
-
-func (b *InterfaceAddressUpdateBody) DecodeFromBytes(data []byte, version uint8) error {
- b.Index = binary.BigEndian.Uint32(data[:4])
- b.Flags = INTERFACE_ADDRESS_FLAG(data[4])
- family := data[5]
- var addrlen int8
- switch family {
- case syscall.AF_INET:
- addrlen = net.IPv4len
- case syscall.AF_INET6:
- addrlen = net.IPv6len
- default:
- return fmt.Errorf("unknown address family: %d", family)
- }
- 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) ([]byte, error) {
- return []byte{}, nil
-}
-
-func (b *InterfaceAddressUpdateBody) String() string {
- return fmt.Sprintf(
- "idx: %d, flags: %s, addr: %s/%d",
- b.Index, b.Flags.String(), b.Prefix.String(), b.Length)
-}
-
-type RouterIDUpdateBody struct {
- Length uint8
- Prefix net.IP
-}
-
-func (b *RouterIDUpdateBody) DecodeFromBytes(data []byte, version uint8) error {
- family := data[0]
- var addrlen int8
- switch family {
- case syscall.AF_INET:
- addrlen = net.IPv4len
- case syscall.AF_INET6:
- addrlen = net.IPv6len
- default:
- return fmt.Errorf("unknown address family: %d", family)
- }
- b.Prefix = data[1 : 1+addrlen]
- b.Length = data[1+addrlen]
- return nil
-}
-
-func (b *RouterIDUpdateBody) Serialize(version uint8) ([]byte, error) {
- return []byte{}, nil
-}
-
-func (b *RouterIDUpdateBody) String() string {
- return fmt.Sprintf("id: %s/%d", b.Prefix.String(), b.Length)
-}
-
-type IPRouteBody struct {
- Type ROUTE_TYPE
- Instance uint16
- Flags FLAG
- Message MESSAGE_FLAG
- SAFI SAFI
- Prefix net.IP
- PrefixLength uint8
- SrcPrefix net.IP
- SrcPrefixLength uint8
- Nexthops []net.IP
- Ifindexs []uint32
- Distance uint8
- Metric uint32
- Mtu uint32
- Tag uint32
- Api API_TYPE
-}
-
-func (b *IPRouteBody) RouteFamily() bgp.RouteFamily {
- switch b.Api {
- case IPV4_ROUTE_ADD, IPV4_ROUTE_DELETE, FRR_REDISTRIBUTE_IPV4_ADD, FRR_REDISTRIBUTE_IPV4_DEL:
- return bgp.RF_IPv4_UC
- case IPV6_ROUTE_ADD, IPV6_ROUTE_DELETE, FRR_REDISTRIBUTE_IPV6_ADD, FRR_REDISTRIBUTE_IPV6_DEL:
- return bgp.RF_IPv6_UC
- default:
- return bgp.RF_OPAQUE
- }
-}
-
-func (b *IPRouteBody) IsWithdraw() bool {
- switch b.Api {
- case IPV4_ROUTE_DELETE, FRR_REDISTRIBUTE_IPV4_DEL, IPV6_ROUTE_DELETE, FRR_REDISTRIBUTE_IPV6_DEL:
- return true
- default:
- return false
- }
-}
-
-func (b *IPRouteBody) Serialize(version uint8) ([]byte, error) {
-
- var buf []byte
- nhfIPv4 := uint8(NEXTHOP_IPV4)
- nhfIPv6 := uint8(NEXTHOP_IPV6)
- nhfIndx := uint8(NEXTHOP_IFINDEX)
- nhfBlkH := uint8(NEXTHOP_BLACKHOLE)
- if version <= 3 {
- buf = make([]byte, 5)
- buf[0] = uint8(b.Type)
- buf[1] = uint8(b.Flags)
- buf[2] = uint8(b.Message)
- binary.BigEndian.PutUint16(buf[3:5], uint16(b.SAFI))
- } else { // version >= 4
- buf = make([]byte, 10)
- buf[0] = uint8(b.Type)
- binary.BigEndian.PutUint16(buf[1:3], uint16(b.Instance))
- binary.BigEndian.PutUint32(buf[3:7], uint32(b.Flags))
- buf[7] = uint8(b.Message)
- binary.BigEndian.PutUint16(buf[8:10], uint16(b.SAFI))
- nhfIPv4 = uint8(FRR_NEXTHOP_IPV4)
- nhfIPv6 = uint8(FRR_NEXTHOP_IPV6)
- nhfIndx = uint8(FRR_NEXTHOP_IFINDEX)
- nhfBlkH = uint8(FRR_NEXTHOP_BLACKHOLE)
- }
- byteLen := (int(b.PrefixLength) + 7) / 8
- buf = append(buf, b.PrefixLength)
- buf = append(buf, b.Prefix[:byteLen]...)
- if b.Message&FRR_MESSAGE_SRCPFX > 0 {
- byteLen = (int(b.SrcPrefixLength) + 7) / 8
- buf = append(buf, b.SrcPrefixLength)
- buf = append(buf, b.SrcPrefix[:byteLen]...)
- }
-
- if b.Message&MESSAGE_NEXTHOP > 0 {
- if b.Flags&FLAG_BLACKHOLE > 0 {
- buf = append(buf, []byte{1, nhfBlkH}...)
- } else {
- buf = append(buf, uint8(len(b.Nexthops)+len(b.Ifindexs)))
- }
-
- for _, v := range b.Nexthops {
- if v.To4() != nil {
- buf = append(buf, nhfIPv4)
- buf = append(buf, v.To4()...)
- } else {
- buf = append(buf, nhfIPv6)
- buf = append(buf, v.To16()...)
- }
- }
-
- for _, v := range b.Ifindexs {
- buf = append(buf, nhfIndx)
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, v)
- buf = append(buf, bbuf...)
- }
- }
-
- if b.Message&MESSAGE_DISTANCE > 0 {
- buf = append(buf, b.Distance)
- }
- if b.Message&MESSAGE_METRIC > 0 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Metric)
- buf = append(buf, bbuf...)
- }
- if version <= 3 {
- if b.Message&MESSAGE_MTU > 0 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Mtu)
- buf = append(buf, bbuf...)
- }
- if b.Message&MESSAGE_TAG > 0 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Tag)
- buf = append(buf, bbuf...)
- }
- } else { // version >= 4
- if b.Message&FRR_MESSAGE_TAG > 0 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Tag)
- buf = append(buf, bbuf...)
- }
- if b.Message&FRR_MESSAGE_MTU > 0 {
- bbuf := make([]byte, 4)
- binary.BigEndian.PutUint32(bbuf, b.Mtu)
- buf = append(buf, bbuf...)
- }
- }
- return buf, nil
-}
-
-func (b *IPRouteBody) DecodeFromBytes(data []byte, version uint8) error {
- isV4 := true
- if version <= 3 {
- isV4 = b.Api == IPV4_ROUTE_ADD || b.Api == IPV4_ROUTE_DELETE
- } else {
- isV4 = b.Api == FRR_REDISTRIBUTE_IPV4_ADD || b.Api == FRR_REDISTRIBUTE_IPV4_DEL
- }
- var addrLen uint8 = net.IPv4len
- if !isV4 {
- addrLen = net.IPv6len
- }
-
- b.Type = ROUTE_TYPE(data[0])
- if version <= 3 {
- 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]))
- data = data[7:]
- }
-
- b.Message = MESSAGE_FLAG(data[0])
- b.SAFI = SAFI(SAFI_UNICAST)
-
- b.PrefixLength = data[1]
- if b.PrefixLength > addrLen*8 {
- return fmt.Errorf("prefix length is greater than %d", addrLen*8)
- }
- pos := 2
- buf := make([]byte, addrLen)
- byteLen := int((b.PrefixLength + 7) / 8)
- copy(buf, data[pos:pos+byteLen])
- if isV4 {
- b.Prefix = net.IP(buf).To4()
- } else {
- b.Prefix = net.IP(buf).To16()
- }
- pos += byteLen
-
- if b.Message&FRR_MESSAGE_SRCPFX > 0 {
- b.SrcPrefixLength = data[pos]
- pos += 1
- buf = make([]byte, addrLen)
- byteLen = int((b.SrcPrefixLength + 7) / 8)
- copy(buf, data[pos:pos+byteLen])
- if isV4 {
- b.SrcPrefix = net.IP(buf).To4()
- } else {
- b.SrcPrefix = net.IP(buf).To16()
- }
- pos += byteLen
- }
-
- rest := 0
- var numNexthop int
- if b.Message&MESSAGE_NEXTHOP > 0 {
- numNexthop = int(data[pos])
- // rest = numNexthop(1) + (nexthop(4 or 16) + placeholder(1) + ifindex(4)) * numNexthop
- rest += 1 + numNexthop*(int(addrLen)+5)
- }
- if b.Message&MESSAGE_DISTANCE > 0 {
- // distance(1)
- rest += 1
- }
- if b.Message&MESSAGE_METRIC > 0 {
- // metric(4)
- rest += 4
- }
- if version <= 3 {
- if b.Message&MESSAGE_MTU > 0 {
- // mtu(4)
- rest += 4
- }
- if b.Message&MESSAGE_TAG > 0 {
- // tag(4)
- rest += 4
- }
- } else { // version >= 4
- if b.Message&FRR_MESSAGE_TAG > 0 {
- // tag(4)
- rest += 4
- }
- if b.Message&FRR_MESSAGE_MTU > 0 {
- // mtu(4)
- rest += 4
- }
- }
-
- if len(data[pos:]) != rest {
- return fmt.Errorf("message length invalid")
- }
-
- b.Nexthops = []net.IP{}
- b.Ifindexs = []uint32{}
-
- if b.Message&MESSAGE_NEXTHOP > 0 {
- pos += 1
- for i := 0; i < numNexthop; i++ {
- addr := data[pos : pos+int(addrLen)]
- var nexthop net.IP
- if isV4 {
- nexthop = net.IP(addr).To4()
- } else {
- nexthop = net.IP(addr).To16()
- }
- b.Nexthops = append(b.Nexthops, nexthop)
-
- // skip nexthop and 1byte place holder
- pos += int(addrLen + 1)
- ifidx := binary.BigEndian.Uint32(data[pos : pos+4])
- b.Ifindexs = append(b.Ifindexs, ifidx)
- pos += 4
- }
- }
-
- if b.Message&MESSAGE_DISTANCE > 0 {
- b.Distance = data[pos]
- pos += 1
- }
- if b.Message&MESSAGE_METRIC > 0 {
- b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- }
- if version <= 3 {
- if b.Message&MESSAGE_MTU > 0 {
- b.Mtu = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- }
- if b.Message&MESSAGE_TAG > 0 {
- b.Tag = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- }
- } else {
- if b.Message&FRR_MESSAGE_TAG > 0 {
- b.Tag = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- }
- if b.Message&FRR_MESSAGE_MTU > 0 {
- b.Mtu = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- }
- }
-
- return nil
-}
-
-func (b *IPRouteBody) 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(), b.Message, b.SAFI.String(), b.Prefix.String(), b.PrefixLength, b.SrcPrefix.String(), b.SrcPrefixLength)
- for i, nh := range b.Nexthops {
- s += fmt.Sprintf(", nexthops[%d]: %s", i, nh.String())
- }
- for i, idx := range b.Ifindexs {
- s += fmt.Sprintf(", ifindex[%d]: %d", i, idx)
- }
- return s + fmt.Sprintf(
- ", distance: %d, metric: %d, mtu: %d, tag: %d",
- b.Distance, b.Metric, b.Mtu, b.Tag)
-}
-
-type NexthopLookupBody struct {
- Api API_TYPE
- Addr net.IP
- Distance uint8
- Metric uint32
- Nexthops []*Nexthop
-}
-
-type Nexthop struct {
- Ifname string
- Ifindex uint32
- Type NEXTHOP_FLAG
- Addr net.IP
-}
-
-func (n *Nexthop) String() string {
- s := fmt.Sprintf(
- "type: %s, addr: %s, ifindex: %d, ifname: %s",
- n.Type.String(), n.Addr.String(), n.Ifindex, n.Ifname)
- return s
-}
-
-func decodeNexthopsFromBytes(nexthops *[]*Nexthop, data []byte, isV4 bool, version uint8) (int, error) {
- addrLen := net.IPv4len
- if !isV4 {
- addrLen = net.IPv6len
- }
- nhIfindex := NEXTHOP_IFINDEX
- nhIfname := NEXTHOP_IFNAME
- nhIPv4 := NEXTHOP_IPV4
- nhIPv4Ifindex := NEXTHOP_IPV4_IFINDEX
- nhIPv4Ifname := NEXTHOP_IPV4_IFNAME
- nhIPv6 := NEXTHOP_IPV6
- nhIPv6Ifindex := NEXTHOP_IPV6_IFINDEX
- nhIPv6Ifname := NEXTHOP_IPV6_IFNAME
- if version >= 4 {
- nhIfindex = FRR_NEXTHOP_IFINDEX
- nhIfname = NEXTHOP_FLAG(0)
- nhIPv4 = FRR_NEXTHOP_IPV4
- nhIPv4Ifindex = FRR_NEXTHOP_IPV4_IFINDEX
- nhIPv4Ifname = NEXTHOP_FLAG(0)
- nhIPv6 = FRR_NEXTHOP_IPV6
- nhIPv6Ifindex = FRR_NEXTHOP_IPV6_IFINDEX
- nhIPv6Ifname = NEXTHOP_FLAG(0)
- }
-
- numNexthop := int(data[0])
- offset := 1
-
- for i := 0; i < numNexthop; i++ {
- nh := &Nexthop{}
- nh.Type = NEXTHOP_FLAG(data[offset])
- offset += 1
-
- switch nh.Type {
- case nhIfindex, nhIfname:
- nh.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
-
- case nhIPv4, nhIPv6:
- if isV4 {
- nh.Addr = net.IP(data[offset : offset+addrLen]).To4()
- } else {
- nh.Addr = net.IP(data[offset : offset+addrLen]).To16()
- }
- offset += addrLen
- if version >= 4 {
- // On FRRouting version 3.0 or later, NEXTHOP_IPV4 and
- // NEXTHOP_IPV6 have the same structure with
- // NEXTHOP_TYPE_IPV4_IFINDEX and NEXTHOP_TYPE_IPV6_IFINDEX.
- nh.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
- }
-
- case nhIPv4Ifindex, nhIPv4Ifname, nhIPv6Ifindex, nhIPv6Ifname:
- if isV4 {
- nh.Addr = net.IP(data[offset : offset+addrLen]).To4()
- } else {
- nh.Addr = net.IP(data[offset : offset+addrLen]).To16()
- }
- offset += addrLen
- nh.Ifindex = binary.BigEndian.Uint32(data[offset : offset+4])
- offset += 4
- }
- *nexthops = append(*nexthops, nh)
- }
-
- return offset, nil
-}
-
-func (b *NexthopLookupBody) Serialize(version uint8) ([]byte, error) {
- isV4 := false
- if version <= 3 {
- isV4 = b.Api == IPV4_NEXTHOP_LOOKUP
- } else { // version >= 4
- isV4 = b.Api == FRR_IPV4_NEXTHOP_LOOKUP_MRIB
- }
-
- buf := make([]byte, 0)
-
- if isV4 {
- buf = append(buf, b.Addr.To4()...)
- } else {
- buf = append(buf, b.Addr.To16()...)
- }
- return buf, nil
-}
-
-func (b *NexthopLookupBody) DecodeFromBytes(data []byte, version uint8) error {
- isV4 := false
- if version <= 3 {
- isV4 = b.Api == IPV4_NEXTHOP_LOOKUP
- } else { // version >= 4
- isV4 = b.Api == FRR_IPV4_NEXTHOP_LOOKUP_MRIB
- }
- addrLen := net.IPv4len
- if !isV4 {
- addrLen = net.IPv6len
- }
-
- if len(data) < addrLen {
- return fmt.Errorf("message length invalid")
- }
-
- buf := make([]byte, addrLen)
- copy(buf, data[0:addrLen])
- pos := addrLen
-
- if isV4 {
- b.Addr = net.IP(buf).To4()
- } else {
- b.Addr = net.IP(buf).To16()
- }
-
- if version >= 4 {
- b.Distance = data[pos]
- pos++
- }
-
- if len(data[pos:]) > int(1+addrLen) {
- b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- b.Nexthops = []*Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[pos:], isV4, version); err != nil {
- return err
- } else {
- pos += nexthopsByteLen
- }
- }
-
- return nil
-}
-
-func (b *NexthopLookupBody) 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
-}
-
-func (b *ImportLookupBody) Serialize(version uint8) ([]byte, error) {
- buf := make([]byte, 1)
- buf[0] = b.PrefixLength
- buf = append(buf, b.Addr.To4()...)
- return buf, nil
-}
-
-func (b *ImportLookupBody) DecodeFromBytes(data []byte, version uint8) error {
- isV4 := b.Api == IPV4_IMPORT_LOOKUP
- addrLen := net.IPv4len
- if !isV4 {
- addrLen = net.IPv6len
- }
-
- if len(data) < addrLen {
- return fmt.Errorf("message length invalid")
- }
-
- buf := make([]byte, addrLen)
- copy(buf, data[0:addrLen])
- pos := addrLen
-
- b.Addr = net.IP(buf).To4()
-
- if len(data[pos:]) > int(1+addrLen) {
- b.Metric = binary.BigEndian.Uint32(data[pos : pos+4])
- pos += 4
- b.Nexthops = []*Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[pos:], isV4, version); err != nil {
- return err
- } else {
- pos += nexthopsByteLen
- }
- }
-
- return nil
-}
-
-func (b *ImportLookupBody) 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())
- }
- }
- return s
-}
-
-type RegisteredNexthop struct {
- Connected uint8
- Family uint16
- // 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 {
- // 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
- }
-}
-
-func (n *RegisteredNexthop) Serialize() ([]byte, error) {
- // Connected (1 byte)
- buf := make([]byte, 4)
- buf[0] = byte(n.Connected)
-
- // Address Family (2 bytes)
- binary.BigEndian.PutUint16(buf[1:3], n.Family)
-
- // Prefix Length (1 byte) + Prefix (variable)
- switch n.Family {
- case uint16(syscall.AF_INET):
- buf[3] = byte(net.IPv4len * 8)
- buf = append(buf, n.Prefix.To4()...)
- case uint16(syscall.AF_INET6):
- buf[3] = byte(net.IPv6len * 8)
- buf = append(buf, n.Prefix.To16()...)
- default:
- return nil, fmt.Errorf("invalid address family: %d", n.Family)
- }
-
- return buf, nil
-}
-
-func (n *RegisteredNexthop) DecodeFromBytes(data []byte) error {
- // Connected (1 byte)
- n.Connected = uint8(data[0])
- offset := 1
-
- // Address Family (2 bytes)
- n.Family = binary.BigEndian.Uint16(data[offset : offset+2])
- isV4 := n.Family == uint16(syscall.AF_INET)
- addrLen := int(net.IPv4len)
- if !isV4 {
- addrLen = net.IPv6len
- }
- // Note: Ignores Prefix Length (1 byte)
- offset += 3
-
- // Prefix (variable)
- if isV4 {
- n.Prefix = net.IP(data[offset : offset+addrLen]).To4()
- } else {
- n.Prefix = net.IP(data[offset : offset+addrLen]).To16()
- }
-
- return nil
-}
-
-func (n *RegisteredNexthop) String() string {
- return fmt.Sprintf(
- "connected: %d, family: %d, prefix: %s",
- n.Connected, n.Family, n.Prefix.String())
-}
-
-type NexthopRegisterBody struct {
- Api API_TYPE
- Nexthops []*RegisteredNexthop
-}
-
-func (b *NexthopRegisterBody) Serialize(version uint8) ([]byte, error) {
- buf := make([]byte, 0)
-
- // List of Registered Nexthops
- for _, nh := range b.Nexthops {
- nhBuf, err := nh.Serialize()
- if err != nil {
- return nil, err
- }
- buf = append(buf, nhBuf...)
- }
-
- return buf, nil
-}
-
-func (b *NexthopRegisterBody) DecodeFromBytes(data []byte, version uint8) error {
- offset := 0
-
- // List of Registered Nexthops
- b.Nexthops = []*RegisteredNexthop{}
- for len(data[offset:]) > 0 {
- nh := new(RegisteredNexthop)
- err := nh.DecodeFromBytes(data[offset:])
- if err != nil {
- return err
- }
- b.Nexthops = append(b.Nexthops, nh)
-
- offset += nh.Len()
- if len(data) < offset {
- break
- }
- }
-
- return nil
-}
-
-func (b *NexthopRegisterBody) String() string {
- s := make([]string, 0)
- for _, nh := range b.Nexthops {
- s = append(s, fmt.Sprintf("nexthop:{%s}", nh.String()))
- }
- return strings.Join(s, ", ")
-}
-
-type NexthopUpdateBody struct {
- Api API_TYPE
- Family uint16
- // 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
- Distance uint8
- Metric uint32
- Nexthops []*Nexthop
-}
-
-func (b *NexthopUpdateBody) Serialize(version uint8) ([]byte, error) {
- // Address Family (2 bytes)
- buf := make([]byte, 3)
- binary.BigEndian.PutUint16(buf, b.Family)
-
- // Prefix Length (1 byte) + Prefix (variable)
- switch b.Family {
- case uint16(syscall.AF_INET):
- buf[2] = byte(net.IPv4len * 8)
- buf = append(buf, b.Prefix.To4()...)
- case uint16(syscall.AF_INET6):
- buf[2] = byte(net.IPv6len * 8)
- buf = append(buf, b.Prefix.To16()...)
- default:
- return nil, fmt.Errorf("invalid address family: %d", b.Family)
- }
-
- return buf, nil
-}
-
-func (b *NexthopUpdateBody) DecodeFromBytes(data []byte, version uint8) error {
- // Address Family (2 bytes)
- b.Family = binary.BigEndian.Uint16(data[0:2])
- isV4 := b.Family == uint16(syscall.AF_INET)
- addrLen := int(net.IPv4len)
- if !isV4 {
- addrLen = net.IPv6len
- }
- // Note: Ignores Prefix Length (1 byte)
- offset := 3
-
- // Prefix (variable)
- if isV4 {
- b.Prefix = net.IP(data[offset : offset+addrLen]).To4()
- } else {
- b.Prefix = net.IP(data[offset : offset+addrLen]).To16()
- }
- offset += addrLen
-
- // Distance (1 byte) (if version>=4)
- // Metric (4 bytes)
- // Number of Nexthops (1 byte)
- if version >= 4 {
- if len(data[offset:]) < 6 {
- return fmt.Errorf("invalid message length: missing distance(1 byte), metric(4 bytes) or nexthops(1 byte): %d<6", len(data[offset:]))
- }
- b.Distance = data[offset]
- offset += 1
- } else 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
-
- // List of Nexthops
- b.Nexthops = []*Nexthop{}
- if nexthopsByteLen, err := decodeNexthopsFromBytes(&b.Nexthops, data[offset:], isV4, version); err != nil {
- return err
- } else {
- offset += nexthopsByteLen
- }
-
- return nil
-}
-
-func (b *NexthopUpdateBody) String() string {
- s := fmt.Sprintf(
- "family: %d, prefix: %s, distance: %d, metric: %d",
- b.Family, b.Prefix.String(), b.Distance, b.Metric)
- for _, nh := range b.Nexthops {
- s = s + fmt.Sprintf(", nexthop:{%s}", nh.String())
- }
- return s
-}
-
-type Message struct {
- Header Header
- Body Body
-}
-
-func (m *Message) Serialize() ([]byte, error) {
- var body []byte
- if m.Body != nil {
- var err error
- body, err = m.Body.Serialize(m.Header.Version)
- if err != nil {
- return nil, err
- }
- }
- m.Header.Len = uint16(len(body)) + HeaderSize(m.Header.Version)
- hdr, err := m.Header.Serialize()
- if err != nil {
- return nil, err
- }
- return append(hdr, body...), nil
-}
-
-func (m *Message) parseMessage(data []byte) 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)
-}
-
-func (m *Message) parseFrrMessage(data []byte) 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{}
- default:
- m.Body = &UnknownBody{}
- }
- return m.Body.DecodeFromBytes(data, m.Header.Version)
-}
-
-func ParseMessage(hdr *Header, data []byte) (m *Message, err error) {
- m = &Message{Header: *hdr}
- if m.Header.Version == 4 {
- err = m.parseFrrMessage(data)
- } else {
- err = m.parseMessage(data)
- }
- if err != nil {
- return nil, err
- }
- return m, nil
-}
diff --git a/zebra/zapi_bsd.go b/zebra/zapi_bsd.go
deleted file mode 100644
index 8960e796..00000000
--- a/zebra/zapi_bsd.go
+++ /dev/null
@@ -1,58 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-// +build freebsd netbsd openbsd
-
-package zebra
-
-import (
- "strings"
- "syscall"
-)
-
-func intfflag2string(flag uint64) string {
- ss := make([]string, 0, 10)
- if flag&syscall.IFF_UP > 0 {
- ss = append(ss, "UP")
- }
- if flag&syscall.IFF_BROADCAST > 0 {
- ss = append(ss, "BROADCAST")
- }
- if flag&syscall.IFF_DEBUG > 0 {
- ss = append(ss, "DEBUG")
- }
- if flag&syscall.IFF_LOOPBACK > 0 {
- ss = append(ss, "LOOPBACK")
- }
- if flag&syscall.IFF_POINTOPOINT > 0 {
- ss = append(ss, "POINTOPOINT")
- }
- if flag&syscall.IFF_RUNNING > 0 {
- ss = append(ss, "RUNNING")
- }
- if flag&syscall.IFF_NOARP > 0 {
- ss = append(ss, "NOARP")
- }
- if flag&syscall.IFF_PROMISC > 0 {
- ss = append(ss, "PROMISC")
- }
- if flag&syscall.IFF_ALLMULTI > 0 {
- ss = append(ss, "ALLMULTI")
- }
- if flag&syscall.IFF_MULTICAST > 0 {
- ss = append(ss, "MULTICAST")
- }
- return strings.Join(ss, " | ")
-}
diff --git a/zebra/zapi_darwin.go b/zebra/zapi_darwin.go
deleted file mode 100644
index a2536913..00000000
--- a/zebra/zapi_darwin.go
+++ /dev/null
@@ -1,59 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package zebra
-
-import (
- "strings"
- "syscall"
-)
-
-func intfflag2string(flag uint64) string {
- ss := make([]string, 0, 10)
- if flag&syscall.IFF_UP > 0 {
- ss = append(ss, "UP")
- }
- if flag&syscall.IFF_BROADCAST > 0 {
- ss = append(ss, "BROADCAST")
- }
- if flag&syscall.IFF_DEBUG > 0 {
- ss = append(ss, "DEBUG")
- }
- if flag&syscall.IFF_LOOPBACK > 0 {
- ss = append(ss, "LOOPBACK")
- }
- if flag&syscall.IFF_POINTOPOINT > 0 {
- ss = append(ss, "POINTOPOINT")
- }
- if flag&syscall.IFF_NOTRAILERS > 0 {
- ss = append(ss, "NOTRAILERS")
- }
- if flag&syscall.IFF_RUNNING > 0 {
- ss = append(ss, "RUNNING")
- }
- if flag&syscall.IFF_NOARP > 0 {
- ss = append(ss, "NOARP")
- }
- if flag&syscall.IFF_PROMISC > 0 {
- ss = append(ss, "PROMISC")
- }
- if flag&syscall.IFF_ALLMULTI > 0 {
- ss = append(ss, "ALLMULTI")
- }
- if flag&syscall.IFF_MULTICAST > 0 {
- ss = append(ss, "MULTICAST")
- }
- return strings.Join(ss, " | ")
-}
diff --git a/zebra/zapi_linux.go b/zebra/zapi_linux.go
deleted file mode 100644
index 66fccb74..00000000
--- a/zebra/zapi_linux.go
+++ /dev/null
@@ -1,83 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package zebra
-
-import (
- "strings"
- "syscall"
-)
-
-func intfflag2string(flag uint64) string {
- ss := make([]string, 0, 10)
- if flag&syscall.IFF_UP > 0 {
- ss = append(ss, "UP")
- }
- if flag&syscall.IFF_BROADCAST > 0 {
- ss = append(ss, "BROADCAST")
- }
- if flag&syscall.IFF_DEBUG > 0 {
- ss = append(ss, "DEBUG")
- }
- if flag&syscall.IFF_LOOPBACK > 0 {
- ss = append(ss, "LOOPBACK")
- }
- if flag&syscall.IFF_POINTOPOINT > 0 {
- ss = append(ss, "POINTOPOINT")
- }
- if flag&syscall.IFF_NOTRAILERS > 0 {
- ss = append(ss, "NOTRAILERS")
- }
- if flag&syscall.IFF_RUNNING > 0 {
- ss = append(ss, "RUNNING")
- }
- if flag&syscall.IFF_NOARP > 0 {
- ss = append(ss, "NOARP")
- }
- if flag&syscall.IFF_PROMISC > 0 {
- ss = append(ss, "PROMISC")
- }
- if flag&syscall.IFF_ALLMULTI > 0 {
- ss = append(ss, "ALLMULTI")
- }
- if flag&syscall.IFF_MASTER > 0 {
- ss = append(ss, "MASTER")
- }
- if flag&syscall.IFF_SLAVE > 0 {
- ss = append(ss, "SLAVE")
- }
- if flag&syscall.IFF_MULTICAST > 0 {
- ss = append(ss, "MULTICAST")
- }
- if flag&syscall.IFF_PORTSEL > 0 {
- ss = append(ss, "PORTSEL")
- }
- if flag&syscall.IFF_AUTOMEDIA > 0 {
- ss = append(ss, "AUTOMEDIA")
- }
- if flag&syscall.IFF_DYNAMIC > 0 {
- ss = append(ss, "DYNAMIC")
- }
- // if flag&syscall.IFF_LOWER_UP > 0 {
- // ss = append(ss, "LOWER_UP")
- // }
- // if flag&syscall.IFF_DORMANT > 0 {
- // ss = append(ss, "DORMANT")
- // }
- // if flag&syscall.IFF_ECHO > 0 {
- // ss = append(ss, "ECHO")
- // }
- return strings.Join(ss, " | ")
-}
diff --git a/zebra/zapi_test.go b/zebra/zapi_test.go
deleted file mode 100644
index 9fda5416..00000000
--- a/zebra/zapi_test.go
+++ /dev/null
@@ -1,531 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package zebra
-
-import (
- "encoding/binary"
- "net"
- "syscall"
- "testing"
-
- "github.com/stretchr/testify/require"
-
- "github.com/stretchr/testify/assert"
-)
-
-func Test_Header(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes
- buf := make([]byte, 6)
- binary.BigEndian.PutUint16(buf[0:], 10)
- buf[2] = HEADER_MARKER
- buf[3] = 2
- binary.BigEndian.PutUint16(buf[4:], uint16(IPV4_ROUTE_ADD))
- h := &Header{}
- err := h.DecodeFromBytes(buf)
- assert.Equal(nil, err)
-
- //Serialize
- buf, err = h.Serialize()
- assert.Equal(nil, err)
- h2 := &Header{}
- err = h2.DecodeFromBytes(buf)
- assert.Equal(nil, err)
- assert.Equal(h, h2)
-
- // header_size mismatch
- buf = make([]byte, HeaderSize(2)-1)
- binary.BigEndian.PutUint16(buf[0:], 10)
- buf[2] = 0xff
- buf[3] = 0x02
- h3 := &Header{}
- err = h3.DecodeFromBytes(buf)
- assert.NotEqual(nil, err)
-}
-
-func Test_InterfaceUpdateBody(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes
- buf := make([]byte, INTERFACE_NAMSIZ+49)
- pos := INTERFACE_NAMSIZ
- binary.BigEndian.PutUint32(buf[pos:], 1)
- pos += 4
- buf[pos] = byte(INTERFACE_ACTIVE)
- pos += 1
- binary.BigEndian.PutUint64(buf[pos:], 1)
- pos += 8 // flags
- binary.BigEndian.PutUint32(buf[pos:], 1)
- pos += 4 // metric
- binary.BigEndian.PutUint32(buf[pos:], 1500)
- pos += 4 // MTU
- binary.BigEndian.PutUint32(buf[pos:], 1500)
- pos += 4 // MTU6
- binary.BigEndian.PutUint32(buf[pos:], 200)
- pos += 4 // bandwidth
- binary.BigEndian.PutUint32(buf[pos:], 6)
- pos += 4 // hwaddr_len
- mac, _ := net.ParseMAC("01:23:45:67:89:ab")
- copy(buf[pos:pos+6], []byte(mac))
- pos += 4
- b := &InterfaceUpdateBody{}
- err := b.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
- assert.Equal("01:23:45:67:89:ab", b.HardwareAddr.String())
-
- buf = make([]byte, INTERFACE_NAMSIZ+28)
- b = &InterfaceUpdateBody{}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-}
-
-func Test_InterfaceAddressUpdateBody(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes
- buf := make([]byte, 15)
- pos := 0
- binary.BigEndian.PutUint32(buf[pos:], 0) // index
- pos += 4
- buf[pos] = 0x01 // flags
- pos += 1
- buf[pos] = 0x2 // family
- pos += 1
- ip := net.ParseIP("192.168.100.1").To4() // prefix
- copy(buf[pos:pos+4], []byte(ip))
- pos += 4
- buf[pos] = byte(24) // prefix len
- pos += 1
- dst := net.ParseIP("192.168.100.255").To4() // destination
- copy(buf[pos:pos+4], []byte(dst))
-
- b := &InterfaceAddressUpdateBody{}
- err := b.DecodeFromBytes(buf, 2)
- require.NoError(t, err)
-
- assert.Equal(uint32(0), b.Index)
- assert.Equal(INTERFACE_ADDRESS_FLAG(1), b.Flags)
- assert.Equal("192.168.100.1", b.Prefix.String())
- assert.Equal(uint8(24), b.Length)
- assert.Equal("192.168.100.255", b.Destination.String())
-
- // af invalid
- buf[5] = 0x4
- pos += 1
- b = &InterfaceAddressUpdateBody{}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-}
-
-func Test_RouterIDUpdateBody(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes
- buf := make([]byte, 6)
- pos := 0
- buf[pos] = 0x2
- pos += 1
- ip := net.ParseIP("192.168.100.1").To4()
- copy(buf[pos:pos+4], []byte(ip))
- pos += 4
- buf[pos] = byte(32)
-
- b := &RouterIDUpdateBody{}
- err := b.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
- assert.Equal("192.168.100.1", b.Prefix.String())
- assert.Equal(uint8(32), b.Length)
-
- // af invalid
- buf[0] = 0x4
- pos += 1
- b = &RouterIDUpdateBody{}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-}
-
-func Test_IPRouteBody_IPv4(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes IPV4_ROUTE
- buf := make([]byte, 26)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_NEXTHOP | MESSAGE_DISTANCE | MESSAGE_METRIC | MESSAGE_MTU)
- buf[3] = 24
- ip := net.ParseIP("192.168.100.0").To4()
- copy(buf[4:7], []byte(ip))
-
- buf[7] = 1
- nexthop := net.ParseIP("0.0.0.0").To4()
- copy(buf[8:12], []byte(nexthop))
-
- buf[12] = 1
- binary.BigEndian.PutUint32(buf[13:], 1)
- buf[17] = 0 // distance
- binary.BigEndian.PutUint32(buf[18:], 1)
- binary.BigEndian.PutUint32(buf[22:], 1)
- r := &IPRouteBody{Api: IPV4_ROUTE_ADD}
- err := r.DecodeFromBytes(buf, 2)
-
- assert.Equal(nil, err)
- assert.Equal("192.168.100.0", r.Prefix.String())
- assert.Equal(uint8(0x18), r.PrefixLength)
- assert.Equal(MESSAGE_NEXTHOP|MESSAGE_DISTANCE|MESSAGE_METRIC|MESSAGE_MTU, r.Message)
- assert.Equal("0.0.0.0", r.Nexthops[0].String())
- assert.Equal(uint32(1), r.Ifindexs[0])
- assert.Equal(uint8(0), r.Distance)
- assert.Equal(uint32(1), r.Metric)
- assert.Equal(uint32(1), r.Mtu)
-
- //Serialize
- buf, err = r.Serialize(2)
- assert.Equal(nil, err)
- assert.Equal([]byte{0x2, 0x10, 0x1d}, buf[0:3])
- assert.Equal([]byte{0x0, 0x1}, buf[3:5])
- assert.Equal(byte(24), buf[5])
- ip = net.ParseIP("192.168.100.0").To4()
- assert.Equal([]byte(ip)[0:3], buf[6:9])
- assert.Equal(byte(NEXTHOP_IPV4), buf[10])
- assert.Equal(byte(NEXTHOP_IFINDEX), buf[15])
- assert.Equal(byte(0x0), buf[20])
-
- bi := make([]byte, 4)
- binary.BigEndian.PutUint32(bi, 1)
- assert.Equal(bi, buf[21:25])
- assert.Equal(bi, buf[25:])
-
- // length invalid
- buf = make([]byte, 18)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_NEXTHOP | MESSAGE_DISTANCE | MESSAGE_METRIC)
- buf[3] = 24
- ip = net.ParseIP("192.168.100.0").To4()
- copy(buf[4:7], []byte(ip))
- buf[7] = 1
- nexthop = net.ParseIP("0.0.0.0").To4()
- copy(buf[8:12], []byte(nexthop))
- buf[12] = 1
- binary.BigEndian.PutUint32(buf[13:], 1)
-
- r = &IPRouteBody{Api: IPV4_ROUTE_ADD}
- err = r.DecodeFromBytes(buf, 2)
- assert.Equal("message length invalid", err.Error())
-
- // no nexthop
- buf = make([]byte, 12)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_DISTANCE | MESSAGE_METRIC)
- buf[3] = 24
- ip = net.ParseIP("192.168.100.0").To4()
- copy(buf[4:7], []byte(ip))
- buf[7] = 1
- binary.BigEndian.PutUint32(buf[8:], 0)
- r = &IPRouteBody{Api: IPV4_ROUTE_ADD}
- err = r.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
-
-}
-
-func Test_IPRouteBody_IPv6(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes IPV6_ROUTE
- buf := make([]byte, 43)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_NEXTHOP | MESSAGE_DISTANCE | MESSAGE_METRIC | MESSAGE_MTU)
- buf[3] = 64
- ip := net.ParseIP("2001:db8:0:f101::").To16()
- copy(buf[4:12], []byte(ip))
-
- buf[12] = 1
- nexthop := net.ParseIP("::").To16()
- copy(buf[13:29], []byte(nexthop))
- // ifindex
- buf[29] = 1
- binary.BigEndian.PutUint32(buf[30:], 1)
-
- buf[34] = 0 // distance
- binary.BigEndian.PutUint32(buf[35:], 1)
- binary.BigEndian.PutUint32(buf[39:], 1)
- r := &IPRouteBody{Api: IPV6_ROUTE_ADD}
- err := r.DecodeFromBytes(buf, 2)
-
- assert.Equal(nil, err)
- assert.Equal("2001:db8:0:f101::", r.Prefix.String())
- assert.Equal(uint8(64), r.PrefixLength)
- assert.Equal(MESSAGE_NEXTHOP|MESSAGE_DISTANCE|MESSAGE_METRIC|MESSAGE_MTU, r.Message)
- assert.Equal("::", r.Nexthops[0].String())
- assert.Equal(uint32(1), r.Ifindexs[0])
- assert.Equal(uint8(0), r.Distance)
- assert.Equal(uint32(1), r.Metric)
- assert.Equal(uint32(1), r.Mtu)
-
- //Serialize
- buf, err = r.Serialize(2)
- assert.Equal(nil, err)
- assert.Equal([]byte{0x2, 0x10, 0x1d}, buf[0:3])
- assert.Equal([]byte{0x0, 0x1}, buf[3:5])
- assert.Equal(byte(64), buf[5])
- ip = net.ParseIP("2001:db8:0:f101::").To16()
- assert.Equal([]byte(ip)[0:8], buf[6:14])
- assert.Equal(byte(2), buf[14])
- assert.Equal(byte(NEXTHOP_IPV6), buf[15])
- ip = net.ParseIP("::").To16()
- assert.Equal([]byte(ip), buf[16:32])
- assert.Equal(byte(NEXTHOP_IFINDEX), buf[32])
- bi := make([]byte, 4)
- binary.BigEndian.PutUint32(bi, 1)
- assert.Equal(bi, buf[33:37])
-
- //distance
- assert.Equal(byte(0), buf[37])
- bi = make([]byte, 4)
- binary.BigEndian.PutUint32(bi, 1)
- assert.Equal(bi, buf[38:42])
- assert.Equal(bi, buf[42:])
-
- // length invalid
- buf = make([]byte, 50)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_NEXTHOP | MESSAGE_DISTANCE | MESSAGE_METRIC)
- buf[3] = 24
- ip = net.ParseIP("2001:db8:0:f101::").To4()
- copy(buf[4:12], []byte(ip))
- buf[13] = 1
- nexthop = net.ParseIP("::").To16()
- copy(buf[14:30], []byte(nexthop))
- buf[31] = 1
- binary.BigEndian.PutUint32(buf[32:], 1)
-
- r = &IPRouteBody{Api: IPV6_ROUTE_ADD}
- err = r.DecodeFromBytes(buf, 2)
- assert.Equal("message length invalid", err.Error())
-
- // no nexthop
- buf = make([]byte, 11)
- buf[0] = byte(ROUTE_CONNECT)
- buf[1] = byte(FLAG_SELECTED)
- buf[2] = byte(MESSAGE_DISTANCE | MESSAGE_METRIC)
- buf[3] = 16
- ip = net.ParseIP("2501::").To16()
- copy(buf[4:6], []byte(ip))
- buf[6] = 1
- binary.BigEndian.PutUint32(buf[7:], 0)
- r = &IPRouteBody{Api: IPV6_ROUTE_ADD}
- err = r.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
-}
-
-func Test_NexthopLookupBody(t *testing.T) {
- assert := assert.New(t)
-
- //ipv4
- //DecodeFromBytes
- pos := 0
- buf := make([]byte, 18)
- ip := net.ParseIP("192.168.50.0").To4()
- copy(buf[0:4], []byte(ip))
- pos += 4
- binary.BigEndian.PutUint32(buf[pos:], 10)
- pos += 4
- buf[pos] = byte(1)
- pos += 1
- buf[pos] = byte(4)
- pos += 1
- ip = net.ParseIP("172.16.1.101").To4()
- copy(buf[pos:pos+4], []byte(ip))
- pos += 4
- binary.BigEndian.PutUint32(buf[pos:], 3)
-
- b := &NexthopLookupBody{Api: IPV4_NEXTHOP_LOOKUP}
- err := b.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
- assert.Equal("192.168.50.0", b.Addr.String())
- assert.Equal(uint32(10), b.Metric)
- assert.Equal(uint32(3), b.Nexthops[0].Ifindex)
- assert.Equal(NEXTHOP_FLAG(4), b.Nexthops[0].Type)
- assert.Equal("172.16.1.101", b.Nexthops[0].Addr.String())
-
- //Serialize
- buf, err = b.Serialize(2)
- ip = net.ParseIP("192.168.50.0").To4()
- assert.Equal(nil, err)
- assert.Equal([]byte(ip)[0:4], buf[0:4])
-
- // length invalid
- buf = make([]byte, 3)
- b = &NexthopLookupBody{Api: IPV4_NEXTHOP_LOOKUP}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-
- //ipv6
- //DecodeFromBytes
- pos = 0
- buf = make([]byte, 46)
- ip = net.ParseIP("2001:db8:0:f101::").To16()
- copy(buf[0:16], []byte(ip))
- pos += 16
- binary.BigEndian.PutUint32(buf[pos:], 10)
- pos += 4
- buf[pos] = byte(1)
- pos += 1
- buf[pos] = byte(4)
- pos += 1
- ip = net.ParseIP("2001:db8:0:1111::1").To16()
- copy(buf[pos:pos+16], []byte(ip))
- pos += 16
- binary.BigEndian.PutUint32(buf[pos:], 3)
-
- b = &NexthopLookupBody{Api: IPV6_NEXTHOP_LOOKUP}
- err = b.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
- assert.Equal("2001:db8:0:f101::", b.Addr.String())
- assert.Equal(uint32(10), b.Metric)
- assert.Equal(uint32(3), b.Nexthops[0].Ifindex)
- assert.Equal(NEXTHOP_FLAG(4), b.Nexthops[0].Type)
- assert.Equal("2001:db8:0:1111::1", b.Nexthops[0].Addr.String())
-
- //Serialize
- buf, err = b.Serialize(2)
- ip = net.ParseIP("2001:db8:0:f101::").To16()
- assert.Equal(nil, err)
- assert.Equal([]byte(ip)[0:16], buf[0:16])
-
- // length invalid
- buf = make([]byte, 15)
- b = &NexthopLookupBody{Api: IPV6_NEXTHOP_LOOKUP}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-}
-
-func Test_ImportLookupBody(t *testing.T) {
- assert := assert.New(t)
-
- //DecodeFromBytes
- pos := 0
- buf := make([]byte, 18)
- ip := net.ParseIP("192.168.50.0").To4()
- copy(buf[0:4], []byte(ip))
- pos += 4
- binary.BigEndian.PutUint32(buf[pos:], 10)
- pos += 4
- buf[pos] = byte(1)
- pos += 1
- buf[pos] = byte(4)
- pos += 1
- ip = net.ParseIP("172.16.1.101").To4()
- copy(buf[pos:pos+4], []byte(ip))
- pos += 4
- binary.BigEndian.PutUint32(buf[pos:], 3)
-
- b := &ImportLookupBody{Api: IPV4_IMPORT_LOOKUP}
- err := b.DecodeFromBytes(buf, 2)
- assert.Equal(nil, err)
- assert.Equal("192.168.50.0", b.Addr.String())
- assert.Equal(uint32(10), b.Metric)
- assert.Equal(uint32(3), b.Nexthops[0].Ifindex)
- assert.Equal(NEXTHOP_FLAG(4), b.Nexthops[0].Type)
- assert.Equal("172.16.1.101", b.Nexthops[0].Addr.String())
-
- //Serialize
- b.PrefixLength = uint8(24)
- buf, err = b.Serialize(2)
- ip = net.ParseIP("192.168.50.0").To4()
- assert.Equal(nil, err)
- assert.Equal(uint8(24), buf[0])
- assert.Equal([]byte(ip)[0:4], buf[1:5])
-
- // length invalid
- buf = make([]byte, 3)
- b = &ImportLookupBody{Api: IPV4_IMPORT_LOOKUP}
- err = b.DecodeFromBytes(buf, 2)
- assert.NotEqual(nil, err)
-}
-
-func Test_NexthopRegisterBody(t *testing.T) {
- assert := assert.New(t)
-
- // Input binary
- bufIn := []byte{
- 0x01, 0x00, 0x02, 0x20, // connected(1 byte)=1, afi(2 bytes)=AF_INET, prefix_len(1 byte)=32
- 0xc0, 0xa8, 0x01, 0x01, // prefix(4 bytes)="192.168.1.1"
- 0x00, 0x00, 0x0a, 0x80, // connected(1 byte)=0, afi(2 bytes)=AF_INET6, prefix_len(1 byte)=128
- 0x20, 0x01, 0x0d, 0xb8, // prefix(16 bytes)="2001:db8:1:1::1"
- 0x00, 0x01, 0x00, 0x01,
- 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x01,
- }
- binary.BigEndian.PutUint16(bufIn[1:], syscall.AF_INET)
- binary.BigEndian.PutUint16(bufIn[9:], syscall.AF_INET6)
-
- // Test DecodeFromBytes()
- b := &NexthopRegisterBody{Api: NEXTHOP_REGISTER}
- err := b.DecodeFromBytes(bufIn, 3)
- assert.Nil(err)
-
- // Test decoded values
- assert.Equal(uint8(1), b.Nexthops[0].Connected)
- assert.Equal(uint16(syscall.AF_INET), b.Nexthops[0].Family)
- assert.Equal(net.ParseIP("192.168.1.1").To4(), b.Nexthops[0].Prefix)
- assert.Equal(uint8(0), b.Nexthops[1].Connected)
- assert.Equal(uint16(syscall.AF_INET6), b.Nexthops[1].Family)
- assert.Equal(net.ParseIP("2001:db8:1:1::1").To16(), b.Nexthops[1].Prefix)
-
- // Test Serialize()
- bufOut, err := b.Serialize(3)
- assert.Nil(err)
-
- // Test serialised value
- assert.Equal(bufIn, bufOut)
-}
-
-func Test_NexthopUpdateBody(t *testing.T) {
- assert := assert.New(t)
-
- // Input binary
- bufIn := []byte{
- 0x00, 0x02, 0x20, // afi(2 bytes)=AF_INET, prefix_len(1 byte)=32
- 0xc0, 0xa8, 0x01, 0x01, // prefix(4 bytes)="192.168.1.1"
- 0x00, 0x00, 0x00, 0x01, // metric(4 bytes)=1
- 0x01, // nexthops(1 byte)=1
- 0x04, // nexthop_type(1 byte)=NEXTHOP_IPV4_IFINDEX
- 0xc0, 0xa8, 0x01, 0x01, // nexthop_ip(4 bytes)="192.168.0.1"
- 0x00, 0x00, 0x00, 0x02, // nexthop_ifindex(4 byte)=2
- }
-
- // Test DecodeFromBytes()
- b := &NexthopUpdateBody{Api: NEXTHOP_UPDATE}
- err := b.DecodeFromBytes(bufIn, 2)
- assert.Nil(err)
-
- // Test decoded values
- assert.Equal(uint16(syscall.AF_INET), b.Family)
- assert.Equal(net.ParseIP("192.168.1.1").To4(), b.Prefix)
- assert.Equal(uint32(1), b.Metric)
- nexthop := &Nexthop{
- Type: NEXTHOP_FLAG(NEXTHOP_IPV4_IFINDEX),
- Addr: net.ParseIP("192.168.1.1").To4(),
- Ifindex: uint32(2),
- }
- assert.Equal(1, len(b.Nexthops))
- assert.Equal(nexthop, b.Nexthops[0])
-}
diff --git a/zebra/zapi_windows.go b/zebra/zapi_windows.go
deleted file mode 100644
index d55525db..00000000
--- a/zebra/zapi_windows.go
+++ /dev/null
@@ -1,38 +0,0 @@
-// Copyright (C) 2014, 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package zebra
-
-import (
- "strings"
- "syscall"
-)
-
-func intfflag2string(flag uint64) string {
- ss := make([]string, 0, 10)
- if flag&syscall.IFF_UP > 0 {
- ss = append(ss, "UP")
- }
- if flag&syscall.IFF_BROADCAST > 0 {
- ss = append(ss, "BROADCAST")
- }
- if flag&syscall.IFF_LOOPBACK > 0 {
- ss = append(ss, "LOOPBACK")
- }
- if flag&syscall.IFF_MULTICAST > 0 {
- ss = append(ss, "MULTICAST")
- }
- return strings.Join(ss, " | ")
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-16 12:23:44 +0000