ceph-csi/vendor/github.com/prometheus/procfs/proc_snmp6.go

// Copyright 2022 The Prometheus Authors
// 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 procfs

import (
	"bufio"
	"bytes"
	"errors"
	"io"
	"os"
	"strconv"
	"strings"

	"github.com/prometheus/procfs/internal/util"
)

// ProcSnmp6 models the content of /proc/<pid>/net/snmp6.
type ProcSnmp6 struct {
	// The process ID.
	PID int
	Ip6
	Icmp6
	Udp6
	UdpLite6
}

type Ip6 struct { // nolint:revive
	InReceives       float64
	InHdrErrors      float64
	InTooBigErrors   float64
	InNoRoutes       float64
	InAddrErrors     float64
	InUnknownProtos  float64
	InTruncatedPkts  float64
	InDiscards       float64
	InDelivers       float64
	OutForwDatagrams float64
	OutRequests      float64
	OutDiscards      float64
	OutNoRoutes      float64
	ReasmTimeout     float64
	ReasmReqds       float64
	ReasmOKs         float64
	ReasmFails       float64
	FragOKs          float64
	FragFails        float64
	FragCreates      float64
	InMcastPkts      float64
	OutMcastPkts     float64
	InOctets         float64
	OutOctets        float64
	InMcastOctets    float64
	OutMcastOctets   float64
	InBcastOctets    float64
	OutBcastOctets   float64
	InNoECTPkts      float64
	InECT1Pkts       float64
	InECT0Pkts       float64
	InCEPkts         float64
}

type Icmp6 struct {
	InMsgs                    float64
	InErrors                  float64
	OutMsgs                   float64
	OutErrors                 float64
	InCsumErrors              float64
	InDestUnreachs            float64
	InPktTooBigs              float64
	InTimeExcds               float64
	InParmProblems            float64
	InEchos                   float64
	InEchoReplies             float64
	InGroupMembQueries        float64
	InGroupMembResponses      float64
	InGroupMembReductions     float64
	InRouterSolicits          float64
	InRouterAdvertisements    float64
	InNeighborSolicits        float64
	InNeighborAdvertisements  float64
	InRedirects               float64
	InMLDv2Reports            float64
	OutDestUnreachs           float64
	OutPktTooBigs             float64
	OutTimeExcds              float64
	OutParmProblems           float64
	OutEchos                  float64
	OutEchoReplies            float64
	OutGroupMembQueries       float64
	OutGroupMembResponses     float64
	OutGroupMembReductions    float64
	OutRouterSolicits         float64
	OutRouterAdvertisements   float64
	OutNeighborSolicits       float64
	OutNeighborAdvertisements float64
	OutRedirects              float64
	OutMLDv2Reports           float64
	InType1                   float64
	InType134                 float64
	InType135                 float64
	InType136                 float64
	InType143                 float64
	OutType133                float64
	OutType135                float64
	OutType136                float64
	OutType143                float64
}

type Udp6 struct { // nolint:revive
	InDatagrams  float64
	NoPorts      float64
	InErrors     float64
	OutDatagrams float64
	RcvbufErrors float64
	SndbufErrors float64
	InCsumErrors float64
	IgnoredMulti float64
}

type UdpLite6 struct { // nolint:revive
	InDatagrams  float64
	NoPorts      float64
	InErrors     float64
	OutDatagrams float64
	RcvbufErrors float64
	SndbufErrors float64
	InCsumErrors float64
}

func (p Proc) Snmp6() (ProcSnmp6, error) {
	filename := p.path("net/snmp6")
	data, err := util.ReadFileNoStat(filename)
	if err != nil {
		// On systems with IPv6 disabled, this file won't exist.
		// Do nothing.
		if errors.Is(err, os.ErrNotExist) {
			return ProcSnmp6{PID: p.PID}, nil
		}

		return ProcSnmp6{PID: p.PID}, err
	}

	procSnmp6, err := parseSNMP6Stats(bytes.NewReader(data))
	procSnmp6.PID = p.PID
	return procSnmp6, err
}

// parseSnmp6 parses the metrics from proc/<pid>/net/snmp6 file
// and returns a map contains those metrics.
func parseSNMP6Stats(r io.Reader) (ProcSnmp6, error) {
	var (
		scanner   = bufio.NewScanner(r)
		procSnmp6 = ProcSnmp6{}
	)

	for scanner.Scan() {
		stat := strings.Fields(scanner.Text())
		if len(stat) < 2 {
			continue
		}
		// Expect to have "6" in metric name, skip line otherwise
		if sixIndex := strings.Index(stat[0], "6"); sixIndex != -1 {
			protocol := stat[0][:sixIndex+1]
			key := stat[0][sixIndex+1:]
			value, err := strconv.ParseFloat(stat[1], 64)
			if err != nil {
				return procSnmp6, err
			}

			switch protocol {
			case "Ip6":
				switch key {
				case "InReceives":
					procSnmp6.Ip6.InReceives = value
				case "InHdrErrors":
					procSnmp6.Ip6.InHdrErrors = value
				case "InTooBigErrors":
					procSnmp6.Ip6.InTooBigErrors = value
				case "InNoRoutes":
					procSnmp6.Ip6.InNoRoutes = value
				case "InAddrErrors":
					procSnmp6.Ip6.InAddrErrors = value
				case "InUnknownProtos":
					procSnmp6.Ip6.InUnknownProtos = value
				case "InTruncatedPkts":
					procSnmp6.Ip6.InTruncatedPkts = value
				case "InDiscards":
					procSnmp6.Ip6.InDiscards = value
				case "InDelivers":
					procSnmp6.Ip6.InDelivers = value
				case "OutForwDatagrams":
					procSnmp6.Ip6.OutForwDatagrams = value
				case "OutRequests":
					procSnmp6.Ip6.OutRequests = value
				case "OutDiscards":
					procSnmp6.Ip6.OutDiscards = value
				case "OutNoRoutes":
					procSnmp6.Ip6.OutNoRoutes = value
				case "ReasmTimeout":
					procSnmp6.Ip6.ReasmTimeout = value
				case "ReasmReqds":
					procSnmp6.Ip6.ReasmReqds = value
				case "ReasmOKs":
					procSnmp6.Ip6.ReasmOKs = value
				case "ReasmFails":
					procSnmp6.Ip6.ReasmFails = value
				case "FragOKs":
					procSnmp6.Ip6.FragOKs = value
				case "FragFails":
					procSnmp6.Ip6.FragFails = value
				case "FragCreates":
					procSnmp6.Ip6.FragCreates = value
				case "InMcastPkts":
					procSnmp6.Ip6.InMcastPkts = value
				case "OutMcastPkts":
					procSnmp6.Ip6.OutMcastPkts = value
				case "InOctets":
					procSnmp6.Ip6.InOctets = value
				case "OutOctets":
					procSnmp6.Ip6.OutOctets = value
				case "InMcastOctets":
					procSnmp6.Ip6.InMcastOctets = value
				case "OutMcastOctets":
					procSnmp6.Ip6.OutMcastOctets = value
				case "InBcastOctets":
					procSnmp6.Ip6.InBcastOctets = value
				case "OutBcastOctets":
					procSnmp6.Ip6.OutBcastOctets = value
				case "InNoECTPkts":
					procSnmp6.Ip6.InNoECTPkts = value
				case "InECT1Pkts":
					procSnmp6.Ip6.InECT1Pkts = value
				case "InECT0Pkts":
					procSnmp6.Ip6.InECT0Pkts = value
				case "InCEPkts":
					procSnmp6.Ip6.InCEPkts = value

				}
			case "Icmp6":
				switch key {
				case "InMsgs":
					procSnmp6.Icmp6.InMsgs = value
				case "InErrors":
					procSnmp6.Icmp6.InErrors = value
				case "OutMsgs":
					procSnmp6.Icmp6.OutMsgs = value
				case "OutErrors":
					procSnmp6.Icmp6.OutErrors = value
				case "InCsumErrors":
					procSnmp6.Icmp6.InCsumErrors = value
				case "InDestUnreachs":
					procSnmp6.Icmp6.InDestUnreachs = value
				case "InPktTooBigs":
					procSnmp6.Icmp6.InPktTooBigs = value
				case "InTimeExcds":
					procSnmp6.Icmp6.InTimeExcds = value
				case "InParmProblems":
					procSnmp6.Icmp6.InParmProblems = value
				case "InEchos":
					procSnmp6.Icmp6.InEchos = value
				case "InEchoReplies":
					procSnmp6.Icmp6.InEchoReplies = value
				case "InGroupMembQueries":
					procSnmp6.Icmp6.InGroupMembQueries = value
				case "InGroupMembResponses":
					procSnmp6.Icmp6.InGroupMembResponses = value
				case "InGroupMembReductions":
					procSnmp6.Icmp6.InGroupMembReductions = value
				case "InRouterSolicits":
					procSnmp6.Icmp6.InRouterSolicits = value
				case "InRouterAdvertisements":
					procSnmp6.Icmp6.InRouterAdvertisements = value
				case "InNeighborSolicits":
					procSnmp6.Icmp6.InNeighborSolicits = value
				case "InNeighborAdvertisements":
					procSnmp6.Icmp6.InNeighborAdvertisements = value
				case "InRedirects":
					procSnmp6.Icmp6.InRedirects = value
				case "InMLDv2Reports":
					procSnmp6.Icmp6.InMLDv2Reports = value
				case "OutDestUnreachs":
					procSnmp6.Icmp6.OutDestUnreachs = value
				case "OutPktTooBigs":
					procSnmp6.Icmp6.OutPktTooBigs = value
				case "OutTimeExcds":
					procSnmp6.Icmp6.OutTimeExcds = value
				case "OutParmProblems":
					procSnmp6.Icmp6.OutParmProblems = value
				case "OutEchos":
					procSnmp6.Icmp6.OutEchos = value
				case "OutEchoReplies":
					procSnmp6.Icmp6.OutEchoReplies = value
				case "OutGroupMembQueries":
					procSnmp6.Icmp6.OutGroupMembQueries = value
				case "OutGroupMembResponses":
					procSnmp6.Icmp6.OutGroupMembResponses = value
				case "OutGroupMembReductions":
					procSnmp6.Icmp6.OutGroupMembReductions = value
				case "OutRouterSolicits":
					procSnmp6.Icmp6.OutRouterSolicits = value
				case "OutRouterAdvertisements":
					procSnmp6.Icmp6.OutRouterAdvertisements = value
				case "OutNeighborSolicits":
					procSnmp6.Icmp6.OutNeighborSolicits = value
				case "OutNeighborAdvertisements":
					procSnmp6.Icmp6.OutNeighborAdvertisements = value
				case "OutRedirects":
					procSnmp6.Icmp6.OutRedirects = value
				case "OutMLDv2Reports":
					procSnmp6.Icmp6.OutMLDv2Reports = value
				case "InType1":
					procSnmp6.Icmp6.InType1 = value
				case "InType134":
					procSnmp6.Icmp6.InType134 = value
				case "InType135":
					procSnmp6.Icmp6.InType135 = value
				case "InType136":
					procSnmp6.Icmp6.InType136 = value
				case "InType143":
					procSnmp6.Icmp6.InType143 = value
				case "OutType133":
					procSnmp6.Icmp6.OutType133 = value
				case "OutType135":
					procSnmp6.Icmp6.OutType135 = value
				case "OutType136":
					procSnmp6.Icmp6.OutType136 = value
				case "OutType143":
					procSnmp6.Icmp6.OutType143 = value
				}
			case "Udp6":
				switch key {
				case "InDatagrams":
					procSnmp6.Udp6.InDatagrams = value
				case "NoPorts":
					procSnmp6.Udp6.NoPorts = value
				case "InErrors":
					procSnmp6.Udp6.InErrors = value
				case "OutDatagrams":
					procSnmp6.Udp6.OutDatagrams = value
				case "RcvbufErrors":
					procSnmp6.Udp6.RcvbufErrors = value
				case "SndbufErrors":
					procSnmp6.Udp6.SndbufErrors = value
				case "InCsumErrors":
					procSnmp6.Udp6.InCsumErrors = value
				case "IgnoredMulti":
					procSnmp6.Udp6.IgnoredMulti = value
				}
			case "UdpLite6":
				switch key {
				case "InDatagrams":
					procSnmp6.UdpLite6.InDatagrams = value
				case "NoPorts":
					procSnmp6.UdpLite6.NoPorts = value
				case "InErrors":
					procSnmp6.UdpLite6.InErrors = value
				case "OutDatagrams":
					procSnmp6.UdpLite6.OutDatagrams = value
				case "RcvbufErrors":
					procSnmp6.UdpLite6.RcvbufErrors = value
				case "SndbufErrors":
					procSnmp6.UdpLite6.SndbufErrors = value
				case "InCsumErrors":
					procSnmp6.UdpLite6.InCsumErrors = value
				}
			}
		}
	}
	return procSnmp6, scanner.Err()
}