source: code/trunk/vendor/github.com/prometheus/procfs/proc_netstat.go@ 822

Last change on this file since 822 was 822, checked in by yakumo.izuru, 22 months ago

Prefer immortal.run over runit and rc.d, use vendored modules
for convenience.

Signed-off-by: Izuru Yakumo <yakumo.izuru@…>
File size: 14.5 KB
Line 
1// Copyright 2022 The Prometheus Authors
2// Licensed under the Apache License, Version 2.0 (the "License");
3// you may not use this file except in compliance with the License.
4// You may obtain a copy of the License at
5//
6// http://www.apache.org/licenses/LICENSE-2.0
7//
8// Unless required by applicable law or agreed to in writing, software
9// distributed under the License is distributed on an "AS IS" BASIS,
10// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11// See the License for the specific language governing permissions and
12// limitations under the License.
13
14package procfs
15
16import (
17 "bufio"
18 "bytes"
19 "fmt"
20 "io"
21 "strconv"
22 "strings"
23
24 "github.com/prometheus/procfs/internal/util"
25)
26
27// ProcNetstat models the content of /proc/<pid>/net/netstat.
28type ProcNetstat struct {
29 // The process ID.
30 PID int
31 TcpExt
32 IpExt
33}
34
35type TcpExt struct { // nolint:revive
36 SyncookiesSent float64
37 SyncookiesRecv float64
38 SyncookiesFailed float64
39 EmbryonicRsts float64
40 PruneCalled float64
41 RcvPruned float64
42 OfoPruned float64
43 OutOfWindowIcmps float64
44 LockDroppedIcmps float64
45 ArpFilter float64
46 TW float64
47 TWRecycled float64
48 TWKilled float64
49 PAWSActive float64
50 PAWSEstab float64
51 DelayedACKs float64
52 DelayedACKLocked float64
53 DelayedACKLost float64
54 ListenOverflows float64
55 ListenDrops float64
56 TCPHPHits float64
57 TCPPureAcks float64
58 TCPHPAcks float64
59 TCPRenoRecovery float64
60 TCPSackRecovery float64
61 TCPSACKReneging float64
62 TCPSACKReorder float64
63 TCPRenoReorder float64
64 TCPTSReorder float64
65 TCPFullUndo float64
66 TCPPartialUndo float64
67 TCPDSACKUndo float64
68 TCPLossUndo float64
69 TCPLostRetransmit float64
70 TCPRenoFailures float64
71 TCPSackFailures float64
72 TCPLossFailures float64
73 TCPFastRetrans float64
74 TCPSlowStartRetrans float64
75 TCPTimeouts float64
76 TCPLossProbes float64
77 TCPLossProbeRecovery float64
78 TCPRenoRecoveryFail float64
79 TCPSackRecoveryFail float64
80 TCPRcvCollapsed float64
81 TCPDSACKOldSent float64
82 TCPDSACKOfoSent float64
83 TCPDSACKRecv float64
84 TCPDSACKOfoRecv float64
85 TCPAbortOnData float64
86 TCPAbortOnClose float64
87 TCPAbortOnMemory float64
88 TCPAbortOnTimeout float64
89 TCPAbortOnLinger float64
90 TCPAbortFailed float64
91 TCPMemoryPressures float64
92 TCPMemoryPressuresChrono float64
93 TCPSACKDiscard float64
94 TCPDSACKIgnoredOld float64
95 TCPDSACKIgnoredNoUndo float64
96 TCPSpuriousRTOs float64
97 TCPMD5NotFound float64
98 TCPMD5Unexpected float64
99 TCPMD5Failure float64
100 TCPSackShifted float64
101 TCPSackMerged float64
102 TCPSackShiftFallback float64
103 TCPBacklogDrop float64
104 PFMemallocDrop float64
105 TCPMinTTLDrop float64
106 TCPDeferAcceptDrop float64
107 IPReversePathFilter float64
108 TCPTimeWaitOverflow float64
109 TCPReqQFullDoCookies float64
110 TCPReqQFullDrop float64
111 TCPRetransFail float64
112 TCPRcvCoalesce float64
113 TCPOFOQueue float64
114 TCPOFODrop float64
115 TCPOFOMerge float64
116 TCPChallengeACK float64
117 TCPSYNChallenge float64
118 TCPFastOpenActive float64
119 TCPFastOpenActiveFail float64
120 TCPFastOpenPassive float64
121 TCPFastOpenPassiveFail float64
122 TCPFastOpenListenOverflow float64
123 TCPFastOpenCookieReqd float64
124 TCPFastOpenBlackhole float64
125 TCPSpuriousRtxHostQueues float64
126 BusyPollRxPackets float64
127 TCPAutoCorking float64
128 TCPFromZeroWindowAdv float64
129 TCPToZeroWindowAdv float64
130 TCPWantZeroWindowAdv float64
131 TCPSynRetrans float64
132 TCPOrigDataSent float64
133 TCPHystartTrainDetect float64
134 TCPHystartTrainCwnd float64
135 TCPHystartDelayDetect float64
136 TCPHystartDelayCwnd float64
137 TCPACKSkippedSynRecv float64
138 TCPACKSkippedPAWS float64
139 TCPACKSkippedSeq float64
140 TCPACKSkippedFinWait2 float64
141 TCPACKSkippedTimeWait float64
142 TCPACKSkippedChallenge float64
143 TCPWinProbe float64
144 TCPKeepAlive float64
145 TCPMTUPFail float64
146 TCPMTUPSuccess float64
147 TCPWqueueTooBig float64
148}
149
150type IpExt struct { // nolint:revive
151 InNoRoutes float64
152 InTruncatedPkts float64
153 InMcastPkts float64
154 OutMcastPkts float64
155 InBcastPkts float64
156 OutBcastPkts float64
157 InOctets float64
158 OutOctets float64
159 InMcastOctets float64
160 OutMcastOctets float64
161 InBcastOctets float64
162 OutBcastOctets float64
163 InCsumErrors float64
164 InNoECTPkts float64
165 InECT1Pkts float64
166 InECT0Pkts float64
167 InCEPkts float64
168 ReasmOverlaps float64
169}
170
171func (p Proc) Netstat() (ProcNetstat, error) {
172 filename := p.path("net/netstat")
173 data, err := util.ReadFileNoStat(filename)
174 if err != nil {
175 return ProcNetstat{PID: p.PID}, err
176 }
177 procNetstat, err := parseNetstat(bytes.NewReader(data), filename)
178 procNetstat.PID = p.PID
179 return procNetstat, err
180}
181
182// parseNetstat parses the metrics from proc/<pid>/net/netstat file
183// and returns a ProcNetstat structure.
184func parseNetstat(r io.Reader, fileName string) (ProcNetstat, error) {
185 var (
186 scanner = bufio.NewScanner(r)
187 procNetstat = ProcNetstat{}
188 )
189
190 for scanner.Scan() {
191 nameParts := strings.Split(scanner.Text(), " ")
192 scanner.Scan()
193 valueParts := strings.Split(scanner.Text(), " ")
194 // Remove trailing :.
195 protocol := strings.TrimSuffix(nameParts[0], ":")
196 if len(nameParts) != len(valueParts) {
197 return procNetstat, fmt.Errorf("mismatch field count mismatch in %s: %s",
198 fileName, protocol)
199 }
200 for i := 1; i < len(nameParts); i++ {
201 value, err := strconv.ParseFloat(valueParts[i], 64)
202 if err != nil {
203 return procNetstat, err
204 }
205 key := nameParts[i]
206
207 switch protocol {
208 case "TcpExt":
209 switch key {
210 case "SyncookiesSent":
211 procNetstat.TcpExt.SyncookiesSent = value
212 case "SyncookiesRecv":
213 procNetstat.TcpExt.SyncookiesRecv = value
214 case "SyncookiesFailed":
215 procNetstat.TcpExt.SyncookiesFailed = value
216 case "EmbryonicRsts":
217 procNetstat.TcpExt.EmbryonicRsts = value
218 case "PruneCalled":
219 procNetstat.TcpExt.PruneCalled = value
220 case "RcvPruned":
221 procNetstat.TcpExt.RcvPruned = value
222 case "OfoPruned":
223 procNetstat.TcpExt.OfoPruned = value
224 case "OutOfWindowIcmps":
225 procNetstat.TcpExt.OutOfWindowIcmps = value
226 case "LockDroppedIcmps":
227 procNetstat.TcpExt.LockDroppedIcmps = value
228 case "ArpFilter":
229 procNetstat.TcpExt.ArpFilter = value
230 case "TW":
231 procNetstat.TcpExt.TW = value
232 case "TWRecycled":
233 procNetstat.TcpExt.TWRecycled = value
234 case "TWKilled":
235 procNetstat.TcpExt.TWKilled = value
236 case "PAWSActive":
237 procNetstat.TcpExt.PAWSActive = value
238 case "PAWSEstab":
239 procNetstat.TcpExt.PAWSEstab = value
240 case "DelayedACKs":
241 procNetstat.TcpExt.DelayedACKs = value
242 case "DelayedACKLocked":
243 procNetstat.TcpExt.DelayedACKLocked = value
244 case "DelayedACKLost":
245 procNetstat.TcpExt.DelayedACKLost = value
246 case "ListenOverflows":
247 procNetstat.TcpExt.ListenOverflows = value
248 case "ListenDrops":
249 procNetstat.TcpExt.ListenDrops = value
250 case "TCPHPHits":
251 procNetstat.TcpExt.TCPHPHits = value
252 case "TCPPureAcks":
253 procNetstat.TcpExt.TCPPureAcks = value
254 case "TCPHPAcks":
255 procNetstat.TcpExt.TCPHPAcks = value
256 case "TCPRenoRecovery":
257 procNetstat.TcpExt.TCPRenoRecovery = value
258 case "TCPSackRecovery":
259 procNetstat.TcpExt.TCPSackRecovery = value
260 case "TCPSACKReneging":
261 procNetstat.TcpExt.TCPSACKReneging = value
262 case "TCPSACKReorder":
263 procNetstat.TcpExt.TCPSACKReorder = value
264 case "TCPRenoReorder":
265 procNetstat.TcpExt.TCPRenoReorder = value
266 case "TCPTSReorder":
267 procNetstat.TcpExt.TCPTSReorder = value
268 case "TCPFullUndo":
269 procNetstat.TcpExt.TCPFullUndo = value
270 case "TCPPartialUndo":
271 procNetstat.TcpExt.TCPPartialUndo = value
272 case "TCPDSACKUndo":
273 procNetstat.TcpExt.TCPDSACKUndo = value
274 case "TCPLossUndo":
275 procNetstat.TcpExt.TCPLossUndo = value
276 case "TCPLostRetransmit":
277 procNetstat.TcpExt.TCPLostRetransmit = value
278 case "TCPRenoFailures":
279 procNetstat.TcpExt.TCPRenoFailures = value
280 case "TCPSackFailures":
281 procNetstat.TcpExt.TCPSackFailures = value
282 case "TCPLossFailures":
283 procNetstat.TcpExt.TCPLossFailures = value
284 case "TCPFastRetrans":
285 procNetstat.TcpExt.TCPFastRetrans = value
286 case "TCPSlowStartRetrans":
287 procNetstat.TcpExt.TCPSlowStartRetrans = value
288 case "TCPTimeouts":
289 procNetstat.TcpExt.TCPTimeouts = value
290 case "TCPLossProbes":
291 procNetstat.TcpExt.TCPLossProbes = value
292 case "TCPLossProbeRecovery":
293 procNetstat.TcpExt.TCPLossProbeRecovery = value
294 case "TCPRenoRecoveryFail":
295 procNetstat.TcpExt.TCPRenoRecoveryFail = value
296 case "TCPSackRecoveryFail":
297 procNetstat.TcpExt.TCPSackRecoveryFail = value
298 case "TCPRcvCollapsed":
299 procNetstat.TcpExt.TCPRcvCollapsed = value
300 case "TCPDSACKOldSent":
301 procNetstat.TcpExt.TCPDSACKOldSent = value
302 case "TCPDSACKOfoSent":
303 procNetstat.TcpExt.TCPDSACKOfoSent = value
304 case "TCPDSACKRecv":
305 procNetstat.TcpExt.TCPDSACKRecv = value
306 case "TCPDSACKOfoRecv":
307 procNetstat.TcpExt.TCPDSACKOfoRecv = value
308 case "TCPAbortOnData":
309 procNetstat.TcpExt.TCPAbortOnData = value
310 case "TCPAbortOnClose":
311 procNetstat.TcpExt.TCPAbortOnClose = value
312 case "TCPDeferAcceptDrop":
313 procNetstat.TcpExt.TCPDeferAcceptDrop = value
314 case "IPReversePathFilter":
315 procNetstat.TcpExt.IPReversePathFilter = value
316 case "TCPTimeWaitOverflow":
317 procNetstat.TcpExt.TCPTimeWaitOverflow = value
318 case "TCPReqQFullDoCookies":
319 procNetstat.TcpExt.TCPReqQFullDoCookies = value
320 case "TCPReqQFullDrop":
321 procNetstat.TcpExt.TCPReqQFullDrop = value
322 case "TCPRetransFail":
323 procNetstat.TcpExt.TCPRetransFail = value
324 case "TCPRcvCoalesce":
325 procNetstat.TcpExt.TCPRcvCoalesce = value
326 case "TCPOFOQueue":
327 procNetstat.TcpExt.TCPOFOQueue = value
328 case "TCPOFODrop":
329 procNetstat.TcpExt.TCPOFODrop = value
330 case "TCPOFOMerge":
331 procNetstat.TcpExt.TCPOFOMerge = value
332 case "TCPChallengeACK":
333 procNetstat.TcpExt.TCPChallengeACK = value
334 case "TCPSYNChallenge":
335 procNetstat.TcpExt.TCPSYNChallenge = value
336 case "TCPFastOpenActive":
337 procNetstat.TcpExt.TCPFastOpenActive = value
338 case "TCPFastOpenActiveFail":
339 procNetstat.TcpExt.TCPFastOpenActiveFail = value
340 case "TCPFastOpenPassive":
341 procNetstat.TcpExt.TCPFastOpenPassive = value
342 case "TCPFastOpenPassiveFail":
343 procNetstat.TcpExt.TCPFastOpenPassiveFail = value
344 case "TCPFastOpenListenOverflow":
345 procNetstat.TcpExt.TCPFastOpenListenOverflow = value
346 case "TCPFastOpenCookieReqd":
347 procNetstat.TcpExt.TCPFastOpenCookieReqd = value
348 case "TCPFastOpenBlackhole":
349 procNetstat.TcpExt.TCPFastOpenBlackhole = value
350 case "TCPSpuriousRtxHostQueues":
351 procNetstat.TcpExt.TCPSpuriousRtxHostQueues = value
352 case "BusyPollRxPackets":
353 procNetstat.TcpExt.BusyPollRxPackets = value
354 case "TCPAutoCorking":
355 procNetstat.TcpExt.TCPAutoCorking = value
356 case "TCPFromZeroWindowAdv":
357 procNetstat.TcpExt.TCPFromZeroWindowAdv = value
358 case "TCPToZeroWindowAdv":
359 procNetstat.TcpExt.TCPToZeroWindowAdv = value
360 case "TCPWantZeroWindowAdv":
361 procNetstat.TcpExt.TCPWantZeroWindowAdv = value
362 case "TCPSynRetrans":
363 procNetstat.TcpExt.TCPSynRetrans = value
364 case "TCPOrigDataSent":
365 procNetstat.TcpExt.TCPOrigDataSent = value
366 case "TCPHystartTrainDetect":
367 procNetstat.TcpExt.TCPHystartTrainDetect = value
368 case "TCPHystartTrainCwnd":
369 procNetstat.TcpExt.TCPHystartTrainCwnd = value
370 case "TCPHystartDelayDetect":
371 procNetstat.TcpExt.TCPHystartDelayDetect = value
372 case "TCPHystartDelayCwnd":
373 procNetstat.TcpExt.TCPHystartDelayCwnd = value
374 case "TCPACKSkippedSynRecv":
375 procNetstat.TcpExt.TCPACKSkippedSynRecv = value
376 case "TCPACKSkippedPAWS":
377 procNetstat.TcpExt.TCPACKSkippedPAWS = value
378 case "TCPACKSkippedSeq":
379 procNetstat.TcpExt.TCPACKSkippedSeq = value
380 case "TCPACKSkippedFinWait2":
381 procNetstat.TcpExt.TCPACKSkippedFinWait2 = value
382 case "TCPACKSkippedTimeWait":
383 procNetstat.TcpExt.TCPACKSkippedTimeWait = value
384 case "TCPACKSkippedChallenge":
385 procNetstat.TcpExt.TCPACKSkippedChallenge = value
386 case "TCPWinProbe":
387 procNetstat.TcpExt.TCPWinProbe = value
388 case "TCPKeepAlive":
389 procNetstat.TcpExt.TCPKeepAlive = value
390 case "TCPMTUPFail":
391 procNetstat.TcpExt.TCPMTUPFail = value
392 case "TCPMTUPSuccess":
393 procNetstat.TcpExt.TCPMTUPSuccess = value
394 case "TCPWqueueTooBig":
395 procNetstat.TcpExt.TCPWqueueTooBig = value
396 }
397 case "IpExt":
398 switch key {
399 case "InNoRoutes":
400 procNetstat.IpExt.InNoRoutes = value
401 case "InTruncatedPkts":
402 procNetstat.IpExt.InTruncatedPkts = value
403 case "InMcastPkts":
404 procNetstat.IpExt.InMcastPkts = value
405 case "OutMcastPkts":
406 procNetstat.IpExt.OutMcastPkts = value
407 case "InBcastPkts":
408 procNetstat.IpExt.InBcastPkts = value
409 case "OutBcastPkts":
410 procNetstat.IpExt.OutBcastPkts = value
411 case "InOctets":
412 procNetstat.IpExt.InOctets = value
413 case "OutOctets":
414 procNetstat.IpExt.OutOctets = value
415 case "InMcastOctets":
416 procNetstat.IpExt.InMcastOctets = value
417 case "OutMcastOctets":
418 procNetstat.IpExt.OutMcastOctets = value
419 case "InBcastOctets":
420 procNetstat.IpExt.InBcastOctets = value
421 case "OutBcastOctets":
422 procNetstat.IpExt.OutBcastOctets = value
423 case "InCsumErrors":
424 procNetstat.IpExt.InCsumErrors = value
425 case "InNoECTPkts":
426 procNetstat.IpExt.InNoECTPkts = value
427 case "InECT1Pkts":
428 procNetstat.IpExt.InECT1Pkts = value
429 case "InECT0Pkts":
430 procNetstat.IpExt.InECT0Pkts = value
431 case "InCEPkts":
432 procNetstat.IpExt.InCEPkts = value
433 case "ReasmOverlaps":
434 procNetstat.IpExt.ReasmOverlaps = value
435 }
436 }
437 }
438 }
439 return procNetstat, scanner.Err()
440}
Note: See TracBrowser for help on using the repository browser.