infra, network: Implement of getting bonding information

driver/infra/network.go

@@ -19,5 +19,13 @@ func GetNetworkInfo() (modelNet.Network, error) {
 		return n, errors.New(errMsg)
 	}
 
+	n.Bonding, err = network.GetBondingInfo()
+	if err != nil {
+		errMsg := "BONDING: " + err.Error()
+		logger.Println(logger.DEBUG, true, errMsg)
+
+		return n, errors.New(errMsg)
+	}
+
 	return n, nil
 }

driver/network/bond_linux.go

@@ -0,0 +1,180 @@
+// Getting bonding interfaces for Linux
+
+//go:build linux
+
+package network
+
+import (
+	"bufio"
+	"github.com/cloud-barista/cm-honeybee/model/network"
+	"github.com/jollaman999/utils/fileutil"
+	"github.com/shirou/gopsutil/v3/net"
+	"path/filepath"
+	"strconv"
+	"strings"
+)
+
+var bondingProcBase = "/proc/net/bonding"
+
+func getBondingInterfaces() ([]string, error) {
+	var interfaces []string
+
+	paths, err := filepath.Glob(bondingProcBase + "/*")
+	if err != nil {
+		return nil, err
+	}
+	for _, p := range paths {
+		interfaces = append(interfaces, filepath.Base(p))
+	}
+
+	return interfaces, nil
+}
+
+func parseBondPart(bond *network.Bonding, bondPart string) error {
+	scanner := bufio.NewScanner(strings.NewReader(bondPart))
+
+	for scanner.Scan() {
+		line := scanner.Text()
+		split := strings.Split(line, ":")
+		if len(split) < 2 {
+			continue
+		}
+		name := strings.TrimSpace(split[0])
+		value := strings.TrimSpace(split[1])
+		if strings.Contains(name, "Bonding Mode") {
+			bond.BondingMode = value
+		} else if strings.Contains(name, "Transmit Hash Policy") {
+			bond.TransmitHashPolicy = value
+		} else if strings.Contains(name, "Primary Slave") {
+			bond.SlavesList.PrimarySlave = value
+		} else if strings.Contains(name, "Currently Active Slave") {
+			bond.SlavesList.CurrentlyActiveSlave = value
+		} else if strings.Contains(name, "MII Status") {
+			bond.MIIStatus = value
+		} else if strings.Contains(name, "MII Polling Interval") {
+			bond.MIIPollingInterval = value
+		}
+	}
+	if err := scanner.Err(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func parseSlavePart(bond *network.Bonding, bondPart string) error {
+	var slaveIdx = -1
+	var slaveInterfaces []network.SlaveInterface
+
+	scanner := bufio.NewScanner(strings.NewReader(bondPart))
+
+	for scanner.Scan() {
+		line := scanner.Text()
+		split := strings.Split(line, ":")
+		if len(split) < 2 {
+			continue
+		}
+		name := strings.TrimSpace(split[0])
+		value := strings.TrimSpace(split[1])
+		if strings.Contains(name, "Slave Interface") {
+			var slaveInterface network.SlaveInterface
+
+			slaveInterface.Name = value
+			slaveInterfaces = append(slaveInterfaces, slaveInterface)
+			slaveIdx++
+		} else if strings.Contains(name, "MII Status") {
+			slaveInterfaces[slaveIdx].MIIStatus = value
+		} else if strings.Contains(name, "Speed") {
+			slaveInterfaces[slaveIdx].Speed = value
+		} else if strings.Contains(name, "Duplex") {
+			slaveInterfaces[slaveIdx].Duplex = value
+		} else if strings.Contains(name, "Link Failure Count") {
+			count, _ := strconv.Atoi(value)
+			slaveInterfaces[slaveIdx].LinkFailureCount = uint(count)
+		} else if strings.Contains(name, "Permanent HW addr") {
+			slaveInterfaces[slaveIdx].PermanentHWAddr = strings.Replace(strings.TrimSpace(line), name+":", "", -1)
+		} else if strings.Contains(name, "Aggregator ID") {
+			slaveInterfaces[slaveIdx].AggregatorID = value
+		}
+	}
+	if err := scanner.Err(); err != nil {
+		return err
+	}
+
+	bond.SlaveInterface = slaveInterfaces
+
+	return nil
+}
+
+func parseBondingInfo(bondIface string) (network.Bonding, error) {
+	var bond network.Bonding
+
+	bond.Name = bondIface
+
+	content, err := fileutil.ReadFile(bondingProcBase + "/" + bondIface)
+	if err != nil {
+		return network.Bonding{}, err
+	}
+	content = strings.TrimSpace(content)
+
+	splitIndex := strings.Index(content, "Slave Interface:")
+	if splitIndex == -1 {
+		splitIndex = len(content)
+	}
+	bondPart := content[:splitIndex]
+	slavePart := content[splitIndex:]
+
+	err = parseBondPart(&bond, bondPart)
+	if err != nil {
+		return bond, err
+	}
+	err = parseSlavePart(&bond, slavePart)
+	if err != nil {
+		return bond, err
+	}
+
+	var slaves []string
+	for _, slave := range bond.SlaveInterface {
+		slaves = append(slaves, slave.Name)
+	}
+	bond.SlavesList.Interfaces = slaves
+
+	interfaces, err := net.Interfaces()
+	if err != nil {
+		return bond, err
+	}
+	for _, iface := range interfaces {
+		if iface.Name == bond.Name {
+			var addrs []string
+
+			for _, addr := range iface.Addrs {
+				addrs = append(addrs, addr.Addr)
+			}
+			bond.AddrList = addrs
+
+			break
+		}
+	}
+
+	return bond, nil
+}
+
+func GetBondingInfo() ([]network.Bonding, error) {
+	var bonds []network.Bonding
+
+	bondIfaces, err := getBondingInterfaces()
+	if err != nil {
+		return bonds, err
+	}
+
+	for _, bondIface := range bondIfaces {
+		bond, err := parseBondingInfo(bondIface)
+		if err != nil {
+			return bonds, err
+		}
+
+		bonds = append(bonds, bond)
+	}
+
+	return bonds, nil
+}

driver/network/bond_windows.go

@@ -0,0 +1,19 @@
+// Getting bonding interfaces for Windows
+
+//go:build windows
+
+package network
+
+import (
+	"github.com/cloud-barista/cm-honeybee/model/network"
+	"github.com/jollaman999/utils/logger"
+)
+
+func GetBondingInfo() ([]network.Bonding, error) {
+	var bonds []network.Bonding
+
+	logger.Println(logger.INFO, false,
+		"BONDING: Getting bonding information is not implemented for Windows.")
+
+	return bonds, nil
+}

model/network/bonding.go

@@ -0,0 +1,28 @@
+package network
+
+type SlavesList struct {
+	Interfaces           []string `json:"interfaces"`
+	PrimarySlave         string   `json:"primary_slave"`
+	CurrentlyActiveSlave string   `json:"currently_active_slave"`
+}
+
+type SlaveInterface struct {
+	Name             string `json:"name"`
+	MIIStatus        string `json:"mii_status"`
+	Speed            string `json:"speed"`
+	Duplex           string `json:"duplex"`
+	LinkFailureCount uint   `json:"link_failure_count"`
+	PermanentHWAddr  string `json:"permanent_hw_addr"`
+	AggregatorID     string `json:"aggregator_id"`
+}
+
+type Bonding struct {
+	Name               string           `json:"name"`
+	BondingMode        string           `json:"bonding_mode"`
+	SlavesList         SlavesList       `json:"slaves_list"`
+	TransmitHashPolicy string           `json:"transmit_hash_policy"`
+	AddrList           []string         `json:"addr_list"`
+	MIIStatus          string           `json:"mii_status"`
+	MIIPollingInterval string           `json:"mii_polling_interval"`
+	SlaveInterface     []SlaveInterface `json:"slave_interface"`
+}

model/network/network.go

@@ -1,5 +1,6 @@
 package network
 
 type Network struct {
-	NetworkInterfaces []NIC `json:"network_interfaces"`
+	NetworkInterfaces []NIC     `json:"network_interfaces"`
+	Bonding           []Bonding `json:"bonding"`
 }