mirror of https://github.com/shirou/gopsutil
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
109 lines
2.4 KiB
Go
109 lines
2.4 KiB
Go
// SPDX-License-Identifier: BSD-3-Clause
|
|
//go:build freebsd
|
|
|
|
package net
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/shirou/gopsutil/v4/internal/common"
|
|
)
|
|
|
|
// Deprecated: use process.PidsWithContext instead
|
|
func PidsWithContext(ctx context.Context) ([]int32, error) {
|
|
return nil, common.ErrNotImplementedError
|
|
}
|
|
|
|
func IOCountersWithContext(ctx context.Context, pernic bool) ([]IOCountersStat, error) {
|
|
out, err := invoke.CommandWithContext(ctx, "netstat", "-ibdnW")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
lines := strings.Split(string(out), "\n")
|
|
ret := make([]IOCountersStat, 0, len(lines)-1)
|
|
exists := make([]string, 0, len(ret))
|
|
|
|
for _, line := range lines {
|
|
values := strings.Fields(line)
|
|
if len(values) < 1 || values[0] == "Name" {
|
|
continue
|
|
}
|
|
if common.StringsHas(exists, values[0]) {
|
|
// skip if already get
|
|
continue
|
|
}
|
|
exists = append(exists, values[0])
|
|
|
|
if len(values) < 12 {
|
|
continue
|
|
}
|
|
base := 1
|
|
// sometimes Address is omitted
|
|
if len(values) < 13 {
|
|
base = 0
|
|
}
|
|
|
|
parsed := make([]uint64, 0, 8)
|
|
vv := []string{
|
|
values[base+3], // PacketsRecv
|
|
values[base+4], // Errin
|
|
values[base+5], // Dropin
|
|
values[base+6], // BytesRecvn
|
|
values[base+7], // PacketSent
|
|
values[base+8], // Errout
|
|
values[base+9], // BytesSent
|
|
values[base+11], // Dropout
|
|
}
|
|
for _, target := range vv {
|
|
if target == "-" {
|
|
parsed = append(parsed, 0)
|
|
continue
|
|
}
|
|
|
|
t, err := strconv.ParseUint(target, 10, 64)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
parsed = append(parsed, t)
|
|
}
|
|
|
|
n := IOCountersStat{
|
|
Name: values[0],
|
|
PacketsRecv: parsed[0],
|
|
Errin: parsed[1],
|
|
Dropin: parsed[2],
|
|
BytesRecv: parsed[3],
|
|
PacketsSent: parsed[4],
|
|
Errout: parsed[5],
|
|
BytesSent: parsed[6],
|
|
Dropout: parsed[7],
|
|
}
|
|
ret = append(ret, n)
|
|
}
|
|
|
|
if !pernic {
|
|
return getIOCountersAll(ret), nil
|
|
}
|
|
|
|
return ret, nil
|
|
}
|
|
|
|
func IOCountersByFileWithContext(ctx context.Context, pernic bool, filename string) ([]IOCountersStat, error) {
|
|
return IOCountersWithContext(ctx, pernic)
|
|
}
|
|
|
|
func FilterCountersWithContext(ctx context.Context) ([]FilterStat, error) {
|
|
return nil, common.ErrNotImplementedError
|
|
}
|
|
|
|
func ConntrackStatsWithContext(ctx context.Context, percpu bool) ([]ConntrackStat, error) {
|
|
return nil, common.ErrNotImplementedError
|
|
}
|
|
|
|
func ProtoCountersWithContext(ctx context.Context, protocols []string) ([]ProtoCountersStat, error) {
|
|
return nil, common.ErrNotImplementedError
|
|
}
|