Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Introduce parsing for
/proc/<pid>/net/snmp, /proc/<pid>/net/snmp6…
… and `/proc/<pid>/net/netstat`. Signed-off-by: Nikos Kakavas <nikakis@protonmail.com>
- Loading branch information
Showing
10 changed files
with
857 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1 @@ | ||
| /fixtures/ | ||
| /fixtures/ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,223 @@ | ||
| // 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" | ||
| "fmt" | ||
| "io" | ||
| "strconv" | ||
| "strings" | ||
|
|
||
| "github.com/mitchellh/mapstructure" | ||
| "github.com/prometheus/procfs/internal/util" | ||
| ) | ||
|
|
||
| // ProcNetstat models the content of /proc/<pid>/net/netstat. | ||
| type ProcNetstat struct { | ||
| // The process ID. | ||
| PID int | ||
| TcpExt | ||
| IpExt | ||
| } | ||
|
|
||
| type TcpExt struct { | ||
| SyncookiesSent float64 | ||
| SyncookiesRecv float64 | ||
| SyncookiesFailed float64 | ||
| EmbryonicRsts float64 | ||
| PruneCalled float64 | ||
| RcvPruned float64 | ||
| OfoPruned float64 | ||
| OutOfWindowIcmps float64 | ||
| LockDroppedIcmps float64 | ||
| ArpFilter float64 | ||
| TW float64 | ||
| TWRecycled float64 | ||
| TWKilled float64 | ||
| PAWSActive float64 | ||
| PAWSEstab float64 | ||
| DelayedACKs float64 | ||
| DelayedACKLocked float64 | ||
| DelayedACKLost float64 | ||
| ListenOverflows float64 | ||
| ListenDrops float64 | ||
| TCPHPHits float64 | ||
| TCPPureAcks float64 | ||
| TCPHPAcks float64 | ||
| TCPRenoRecovery float64 | ||
| TCPSackRecovery float64 | ||
| TCPSACKReneging float64 | ||
| TCPSACKReorder float64 | ||
| TCPRenoReorder float64 | ||
| TCPTSReorder float64 | ||
| TCPFullUndo float64 | ||
| TCPPartialUndo float64 | ||
| TCPDSACKUndo float64 | ||
| TCPLossUndo float64 | ||
| TCPLostRetransmit float64 | ||
| TCPRenoFailures float64 | ||
| TCPSackFailures float64 | ||
| TCPLossFailures float64 | ||
| TCPFastRetrans float64 | ||
| TCPSlowStartRetrans float64 | ||
| TCPTimeouts float64 | ||
| TCPLossProbes float64 | ||
| TCPLossProbeRecovery float64 | ||
| TCPRenoRecoveryFail float64 | ||
| TCPSackRecoveryFail float64 | ||
| TCPRcvCollapsed float64 | ||
| TCPDSACKOldSent float64 | ||
| TCPDSACKOfoSent float64 | ||
| TCPDSACKRecv float64 | ||
| TCPDSACKOfoRecv float64 | ||
| TCPAbortOnData float64 | ||
| TCPAbortOnClose float64 | ||
| TCPAbortOnMemory float64 | ||
| TCPAbortOnTimeout float64 | ||
| TCPAbortOnLinger float64 | ||
| TCPAbortFailed float64 | ||
| TCPMemoryPressures float64 | ||
| TCPMemoryPressuresChrono float64 | ||
| TCPSACKDiscard float64 | ||
| TCPDSACKIgnoredOld float64 | ||
| TCPDSACKIgnoredNoUndo float64 | ||
| TCPSpuriousRTOs float64 | ||
| TCPMD5NotFound float64 | ||
| TCPMD5Unexpected float64 | ||
| TCPMD5Failure float64 | ||
| TCPSackShifted float64 | ||
| TCPSackMerged float64 | ||
| TCPSackShiftFallback float64 | ||
| TCPBacklogDrop float64 | ||
| PFMemallocDrop float64 | ||
| TCPMinTTLDrop float64 | ||
| TCPDeferAcceptDrop float64 | ||
| IPReversePathFilter float64 | ||
| TCPTimeWaitOverflow float64 | ||
| TCPReqQFullDoCookies float64 | ||
| TCPReqQFullDrop float64 | ||
| TCPRetransFail float64 | ||
| TCPRcvCoalesce float64 | ||
| TCPOFOQueue float64 | ||
| TCPOFODrop float64 | ||
| TCPOFOMerge float64 | ||
| TCPChallengeACK float64 | ||
| TCPSYNChallenge float64 | ||
| TCPFastOpenActive float64 | ||
| TCPFastOpenActiveFail float64 | ||
| TCPFastOpenPassive float64 | ||
| TCPFastOpenPassiveFail float64 | ||
| TCPFastOpenListenOverflow float64 | ||
| TCPFastOpenCookieReqd float64 | ||
| TCPFastOpenBlackhole float64 | ||
| TCPSpuriousRtxHostQueues float64 | ||
| BusyPollRxPackets float64 | ||
| TCPAutoCorking float64 | ||
| TCPFromZeroWindowAdv float64 | ||
| TCPToZeroWindowAdv float64 | ||
| TCPWantZeroWindowAdv float64 | ||
| TCPSynRetrans float64 | ||
| TCPOrigDataSent float64 | ||
| TCPHystartTrainDetect float64 | ||
| TCPHystartTrainCwnd float64 | ||
| TCPHystartDelayDetect float64 | ||
| TCPHystartDelayCwnd float64 | ||
| TCPACKSkippedSynRecv float64 | ||
| TCPACKSkippedPAWS float64 | ||
| TCPACKSkippedSeq float64 | ||
| TCPACKSkippedFinWait2 float64 | ||
| TCPACKSkippedTimeWait float64 | ||
| TCPACKSkippedChallenge float64 | ||
| TCPWinProbe float64 | ||
| TCPKeepAlive float64 | ||
| TCPMTUPFail float64 | ||
| TCPMTUPSuccess float64 | ||
| TCPWqueueTooBig float64 | ||
| } | ||
|
|
||
| type IpExt struct { | ||
| InNoRoutes float64 | ||
| InTruncatedPkts float64 | ||
| InMcastPkts float64 | ||
| OutMcastPkts float64 | ||
| InBcastPkts float64 | ||
| OutBcastPkts float64 | ||
| InOctets float64 | ||
| OutOctets float64 | ||
| InMcastOctets float64 | ||
| OutMcastOctets float64 | ||
| InBcastOctets float64 | ||
| OutBcastOctets float64 | ||
| InCsumErrors float64 | ||
| InNoECTPkts float64 | ||
| InECT1Pkts float64 | ||
| InECT0Pkts float64 | ||
| InCEPkts float64 | ||
| ReasmOverlaps float64 | ||
| } | ||
|
|
||
| func (p Proc) Netstat() (ProcNetstat, error) { | ||
| filename := p.path("net/netstat") | ||
| procNetstat := ProcNetstat{PID: p.PID} | ||
|
|
||
| data, err := util.ReadFileNoStat(filename) | ||
| if err != nil { | ||
| return procNetstat, err | ||
| } | ||
|
|
||
| netStats, err := parseNetstat(bytes.NewReader(data), filename) | ||
| if err != nil { | ||
| return procNetstat, err | ||
| } | ||
|
|
||
| mapStructureErr := mapstructure.Decode(netStats, &procNetstat) | ||
| if mapStructureErr != nil { | ||
| return procNetstat, mapStructureErr | ||
| } | ||
|
|
||
| return procNetstat, nil | ||
| } | ||
|
|
||
| // parseNetstat parses the metrics from proc/<pid>/net/netstat file | ||
| // and returns a map contains those metrics (e.g. {"TcpExt": {"SyncookiesSent": 0}}). | ||
| func parseNetstat(r io.Reader, fileName string) (map[string]map[string]float64, error) { | ||
| var ( | ||
| netStats = map[string]map[string]float64{} | ||
| scanner = bufio.NewScanner(r) | ||
| ) | ||
|
|
||
| for scanner.Scan() { | ||
| nameParts := strings.Split(scanner.Text(), " ") | ||
| scanner.Scan() | ||
| valueParts := strings.Split(scanner.Text(), " ") | ||
| // Remove trailing :. | ||
| protocol := nameParts[0][:len(nameParts[0])-1] | ||
| netStats[protocol] = map[string]float64{} | ||
| if len(nameParts) != len(valueParts) { | ||
| return nil, fmt.Errorf("mismatch field count mismatch in %s: %s", | ||
| fileName, protocol) | ||
| } | ||
| for i := 1; i < len(nameParts); i++ { | ||
| var err error | ||
| netStats[protocol][nameParts[i]], err = strconv.ParseFloat(valueParts[i], 64) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return netStats, scanner.Err() | ||
| } |
Oops, something went wrong.