Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 nfs.go // Copyright 2018 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 nfs implements parsing of /proc/net/rpc/nfsd. // Fields are documented in https://www.svennd.be/nfsd-stats-explained-procnetrpcnfsd/ package nfs import ( "os" "strings" "github.com/prometheus/procfs/internal/fs" ) // ReplyCache models the "rc" line. type ReplyCache struct { Hits uint64 Misses uint64 NoCache uint64 } // FileHandles models the "fh" line. type FileHandles struct { Stale uint64 TotalLookups uint64 AnonLookups uint64 DirNoCache uint64 NoDirNoCache uint64 } // InputOutput models the "io" line. type InputOutput struct { Read uint64 Write uint64 } // Threads models the "th" line. type Threads struct { Threads uint64 FullCnt uint64 } // ReadAheadCache models the "ra" line. type ReadAheadCache struct { CacheSize uint64 CacheHistogram []uint64 NotFound uint64 } // Network models the "net" line. type Network struct { NetCount uint64 UDPCount uint64 TCPCount uint64 TCPConnect uint64 } // ClientRPC models the nfs "rpc" line. type ClientRPC struct { RPCCount uint64 Retransmissions uint64 AuthRefreshes uint64 } // ServerRPC models the nfsd "rpc" line. type ServerRPC struct { RPCCount uint64 BadCnt uint64 BadFmt uint64 BadAuth uint64 BadcInt uint64 } // V2Stats models the "proc2" line. type V2Stats struct { Null uint64 GetAttr uint64 SetAttr uint64 Root uint64 Lookup uint64 ReadLink uint64 Read uint64 WrCache uint64 Write uint64 Create uint64 Remove uint64 Rename uint64 Link uint64 SymLink uint64 MkDir uint64 RmDir uint64 ReadDir uint64 FsStat uint64 } // V3Stats models the "proc3" line. type V3Stats struct { Null uint64 GetAttr uint64 SetAttr uint64 Lookup uint64 Access uint64 ReadLink uint64 Read uint64 Write uint64 Create uint64 MkDir uint64 SymLink uint64 MkNod uint64 Remove uint64 RmDir uint64 Rename uint64 Link uint64 ReadDir uint64 ReadDirPlus uint64 FsStat uint64 FsInfo uint64 PathConf uint64 Commit uint64 } // ClientV4Stats models the nfs "proc4" line. type ClientV4Stats struct { Null uint64 Read uint64 Write uint64 Commit uint64 Open uint64 OpenConfirm uint64 OpenNoattr uint64 OpenDowngrade uint64 Close uint64 Setattr uint64 FsInfo uint64 Renew uint64 SetClientID uint64 SetClientIDConfirm uint64 Lock uint64 Lockt uint64 Locku uint64 Access uint64 Getattr uint64 Lookup uint64 LookupRoot uint64 Remove uint64 Rename uint64 Link uint64 Symlink uint64 Create uint64 Pathconf uint64 StatFs uint64 ReadLink uint64 ReadDir uint64 ServerCaps uint64 DelegReturn uint64 GetACL uint64 SetACL uint64 FsLocations uint64 ReleaseLockowner uint64 Secinfo uint64 FsidPresent uint64 ExchangeID uint64 CreateSession uint64 DestroySession uint64 Sequence uint64 GetLeaseTime uint64 ReclaimComplete uint64 LayoutGet uint64 GetDeviceInfo uint64 LayoutCommit uint64 LayoutReturn uint64 SecinfoNoName uint64 TestStateID uint64 FreeStateID uint64 GetDeviceList uint64 BindConnToSession uint64 DestroyClientID uint64 Seek uint64 Allocate uint64 DeAllocate uint64 LayoutStats uint64 Clone uint64 } // ServerV4Stats models the nfsd "proc4" line. type ServerV4Stats struct { Null uint64 Compound uint64 } // V4Ops models the "proc4ops" line: NFSv4 operations // Variable list. // See: // - v4.0 https://tools.ietf.org/html/rfc3010 (38/39 operations) // - nfs == v2.5.x 38 field : https://elixir.bootlin.com/linux/v2.5.75/source/include/linux/nfs4.h#L52 // - nfs >= v2.6.x 39 field : https://elixir.bootlin.com/linux/v2.6.39.4/source/include/linux/nfs4.h#L233 // // - v4.1 https://tools.ietf.org/html/rfc5661 (58 operations) // - v4.2 https://tools.ietf.org/html/draft-ietf-nfsv4-minorversion2-41 (71 operations) // //nolint:godot type V4Ops struct { //Values uint64 // Variable depending on v4.x sub-version. TODO: Will this always at least include the fields in this struct? Op0Unused uint64 Op1Unused uint64 Op2Future uint64 Access uint64 Close uint64 Commit uint64 Create uint64 DelegPurge uint64 DelegReturn uint64 GetAttr uint64 GetFH uint64 Link uint64 Lock uint64 Lockt uint64 Locku uint64 Lookup uint64 LookupRoot uint64 Nverify uint64 Open uint64 OpenAttr uint64 OpenConfirm uint64 OpenDgrd uint64 PutFH uint64 PutPubFH uint64 PutRootFH uint64 Read uint64 ReadDir uint64 ReadLink uint64 Remove uint64 Rename uint64 Renew uint64 RestoreFH uint64 SaveFH uint64 SecInfo uint64 SetAttr uint64 SetClientID uint64 SetClientIDConfirm uint64 Verify uint64 Write uint64 RelLockOwner uint64 } // ClientRPCStats models all stats from /proc/net/rpc/nfs. type ClientRPCStats struct { Network Network ClientRPC ClientRPC V2Stats V2Stats V3Stats V3Stats ClientV4Stats ClientV4Stats } // ServerRPCStats models all stats from /proc/net/rpc/nfsd. type ServerRPCStats struct { ReplyCache ReplyCache FileHandles FileHandles InputOutput InputOutput Threads Threads ReadAheadCache ReadAheadCache Network Network ServerRPC ServerRPC V2Stats V2Stats V3Stats V3Stats ServerV4Stats ServerV4Stats V4Ops V4Ops WdelegGetattr uint64 } // FS represents the pseudo-filesystem proc, which provides an interface to // kernel data structures. type FS struct { proc fs.FS } // NewDefaultFS returns a new FS mounted under the default mountPoint. It will error // if the mount point can't be read. func NewDefaultFS() (FS, error) { return NewFS(fs.DefaultProcMountPoint) } // NewFS returns a new FS mounted under the given mountPoint. It will error // if the mount point can't be read. func NewFS(mountPoint string) (FS, error) { if strings.TrimSpace(mountPoint) == "" { mountPoint = fs.DefaultProcMountPoint } fs, err := fs.NewFS(mountPoint) if err != nil { return FS{}, err } return FS{&fs}, nil } // ClientRPCStats retrieves NFS client RPC statistics // from proc/net/rpc/nfs. func (fs FS) ClientRPCStats() (ClientRPCStats, error) { f, err := os.Open(fs.proc.Path("net/rpc/nfs")) if err != nil { return nil, err } defer f.Close() return ParseClientRPCStats(f) } // ServerRPCStats retrieves NFS daemon RPC statistics // from proc/net/rpc/nfsd. func (fs FS) ServerRPCStats() (*ServerRPCStats, error) { f, err := os.Open(fs.proc.Path("net/rpc/nfsd")) if err != nil { return nil, err } defer f.Close() return ParseServerRPCStats(f) }	7.93 KB	2025-05-25 12:27
📄 parse.go // Copyright 2018 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 nfs import ( "fmt" ) func parseReplyCache(v []uint64) (ReplyCache, error) { if len(v) != 3 { return ReplyCache{}, fmt.Errorf("invalid ReplyCache line %q", v) } return ReplyCache{ Hits: v[0], Misses: v[1], NoCache: v[2], }, nil } func parseFileHandles(v []uint64) (FileHandles, error) { if len(v) != 5 { return FileHandles{}, fmt.Errorf("invalid FileHandles, line %q", v) } return FileHandles{ Stale: v[0], TotalLookups: v[1], AnonLookups: v[2], DirNoCache: v[3], NoDirNoCache: v[4], }, nil } func parseInputOutput(v []uint64) (InputOutput, error) { if len(v) != 2 { return InputOutput{}, fmt.Errorf("invalid InputOutput line %q", v) } return InputOutput{ Read: v[0], Write: v[1], }, nil } func parseThreads(v []uint64) (Threads, error) { if len(v) != 2 { return Threads{}, fmt.Errorf("invalid Threads line %q", v) } return Threads{ Threads: v[0], FullCnt: v[1], }, nil } func parseReadAheadCache(v []uint64) (ReadAheadCache, error) { if len(v) != 12 { return ReadAheadCache{}, fmt.Errorf("invalid ReadAheadCache line %q", v) } return ReadAheadCache{ CacheSize: v[0], CacheHistogram: v[1:11], NotFound: v[11], }, nil } func parseNetwork(v []uint64) (Network, error) { if len(v) != 4 { return Network{}, fmt.Errorf("invalid Network line %q", v) } return Network{ NetCount: v[0], UDPCount: v[1], TCPCount: v[2], TCPConnect: v[3], }, nil } func parseServerRPC(v []uint64) (ServerRPC, error) { if len(v) != 5 { return ServerRPC{}, fmt.Errorf("invalid RPC line %q", v) } return ServerRPC{ RPCCount: v[0], BadCnt: v[1], BadFmt: v[2], BadAuth: v[3], BadcInt: v[4], }, nil } func parseClientRPC(v []uint64) (ClientRPC, error) { if len(v) != 3 { return ClientRPC{}, fmt.Errorf("invalid RPC line %q", v) } return ClientRPC{ RPCCount: v[0], Retransmissions: v[1], AuthRefreshes: v[2], }, nil } func parseV2Stats(v []uint64) (V2Stats, error) { values := int(v[0]) if len(v[1:]) != values \|\| values < 18 { return V2Stats{}, fmt.Errorf("invalid V2Stats line %q", v) } return V2Stats{ Null: v[1], GetAttr: v[2], SetAttr: v[3], Root: v[4], Lookup: v[5], ReadLink: v[6], Read: v[7], WrCache: v[8], Write: v[9], Create: v[10], Remove: v[11], Rename: v[12], Link: v[13], SymLink: v[14], MkDir: v[15], RmDir: v[16], ReadDir: v[17], FsStat: v[18], }, nil } func parseV3Stats(v []uint64) (V3Stats, error) { values := int(v[0]) if len(v[1:]) != values \|\| values < 22 { return V3Stats{}, fmt.Errorf("invalid V3Stats line %q", v) } return V3Stats{ Null: v[1], GetAttr: v[2], SetAttr: v[3], Lookup: v[4], Access: v[5], ReadLink: v[6], Read: v[7], Write: v[8], Create: v[9], MkDir: v[10], SymLink: v[11], MkNod: v[12], Remove: v[13], RmDir: v[14], Rename: v[15], Link: v[16], ReadDir: v[17], ReadDirPlus: v[18], FsStat: v[19], FsInfo: v[20], PathConf: v[21], Commit: v[22], }, nil } func parseClientV4Stats(v []uint64) (ClientV4Stats, error) { values := int(v[0]) if len(v[1:]) != values { return ClientV4Stats{}, fmt.Errorf("invalid ClientV4Stats line %q", v) } // This function currently supports mapping 59 NFS v4 client stats. Older // kernels may emit fewer stats, so we must detect this and pad out the // values to match the expected slice size. if values < 59 { newValues := make([]uint64, 60) copy(newValues, v) v = newValues } return ClientV4Stats{ Null: v[1], Read: v[2], Write: v[3], Commit: v[4], Open: v[5], OpenConfirm: v[6], OpenNoattr: v[7], OpenDowngrade: v[8], Close: v[9], Setattr: v[10], FsInfo: v[11], Renew: v[12], SetClientID: v[13], SetClientIDConfirm: v[14], Lock: v[15], Lockt: v[16], Locku: v[17], Access: v[18], Getattr: v[19], Lookup: v[20], LookupRoot: v[21], Remove: v[22], Rename: v[23], Link: v[24], Symlink: v[25], Create: v[26], Pathconf: v[27], StatFs: v[28], ReadLink: v[29], ReadDir: v[30], ServerCaps: v[31], DelegReturn: v[32], GetACL: v[33], SetACL: v[34], FsLocations: v[35], ReleaseLockowner: v[36], Secinfo: v[37], FsidPresent: v[38], ExchangeID: v[39], CreateSession: v[40], DestroySession: v[41], Sequence: v[42], GetLeaseTime: v[43], ReclaimComplete: v[44], LayoutGet: v[45], GetDeviceInfo: v[46], LayoutCommit: v[47], LayoutReturn: v[48], SecinfoNoName: v[49], TestStateID: v[50], FreeStateID: v[51], GetDeviceList: v[52], BindConnToSession: v[53], DestroyClientID: v[54], Seek: v[55], Allocate: v[56], DeAllocate: v[57], LayoutStats: v[58], Clone: v[59], }, nil } func parseServerV4Stats(v []uint64) (ServerV4Stats, error) { values := int(v[0]) if len(v[1:]) != values \|\| values != 2 { return ServerV4Stats{}, fmt.Errorf("invalid V4Stats line %q", v) } return ServerV4Stats{ Null: v[1], Compound: v[2], }, nil } func parseV4Ops(v []uint64) (V4Ops, error) { values := int(v[0]) if len(v[1:]) != values \|\| values < 39 { return V4Ops{}, fmt.Errorf("invalid V4Ops line %q", v) } // nfs v2.5.x 39field and >=v2.6.x 40 field; v40 := uint64(0) if values > 39 { v40 = v[40] } stats := V4Ops{ Op0Unused: v[1], Op1Unused: v[2], Op2Future: v[3], Access: v[4], Close: v[5], Commit: v[6], Create: v[7], DelegPurge: v[8], DelegReturn: v[9], GetAttr: v[10], GetFH: v[11], Link: v[12], Lock: v[13], Lockt: v[14], Locku: v[15], Lookup: v[16], LookupRoot: v[17], Nverify: v[18], Open: v[19], OpenAttr: v[20], OpenConfirm: v[21], OpenDgrd: v[22], PutFH: v[23], PutPubFH: v[24], PutRootFH: v[25], Read: v[26], ReadDir: v[27], ReadLink: v[28], Remove: v[29], Rename: v[30], Renew: v[31], RestoreFH: v[32], SaveFH: v[33], SecInfo: v[34], SetAttr: v[35], SetClientID: v[36], SetClientIDConfirm: v[37], Verify: v[38], Write: v[39], RelLockOwner: v40, } return stats, nil }	7.52 KB	2025-05-25 12:27
📄 parse_nfs.go // Copyright 2018 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 nfs import ( "bufio" "fmt" "io" "strings" "github.com/prometheus/procfs/internal/util" ) // ParseClientRPCStats returns stats read from /proc/net/rpc/nfs. func ParseClientRPCStats(r io.Reader) (*ClientRPCStats, error) { stats := &ClientRPCStats{} scanner := bufio.NewScanner(r) for scanner.Scan() { line := scanner.Text() parts := strings.Fields(scanner.Text()) // require at least <key> <value> if len(parts) < 2 { return nil, fmt.Errorf("invalid NFS metric line %q", line) } values, err := util.ParseUint64s(parts[1:]) if err != nil { return nil, fmt.Errorf("error parsing NFS metric line: %w", err) } switch metricLine := parts[0]; metricLine { case "net": stats.Network, err = parseNetwork(values) case "rpc": stats.ClientRPC, err = parseClientRPC(values) case "proc2": stats.V2Stats, err = parseV2Stats(values) case "proc3": stats.V3Stats, err = parseV3Stats(values) case "proc4": stats.ClientV4Stats, err = parseClientV4Stats(values) default: return nil, fmt.Errorf("unknown NFS metric line %q", metricLine) } if err != nil { return nil, fmt.Errorf("errors parsing NFS metric line: %w", err) } } if err := scanner.Err(); err != nil { return nil, fmt.Errorf("error scanning NFS file: %w", err) } return stats, nil }	1.86 KB	2025-05-25 12:27
📄 parse_nfs_test.go // Copyright 2018 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 nfs_test import ( "reflect" "strings" "testing" "github.com/prometheus/procfs/nfs" ) func TestNewNFSClientRPCStats(t testing.T) { tests := []struct { name string content string stats nfs.ClientRPCStats invalid bool }{ { name: "invalid file", content: "invalid", invalid: true, }, { name: "good old kernel version file", content: `net 70 70 69 45 rpc 1218785755 374636 1218815394 proc2 18 16 57 74 52 71 73 45 86 0 52 83 61 17 53 50 23 70 82 proc3 22 0 1061909262 48906 4077635 117661341 5 29391916 2570425 2993289 590 0 0 7815 15 1130 0 3983 92385 13332 2 1 23729 proc4 48 98 51 54 83 85 23 24 1 28 73 68 83 12 84 39 68 59 58 88 29 74 69 96 21 84 15 53 86 54 66 56 97 36 49 32 85 81 11 58 32 67 13 28 35 90 1 26 1337 `, stats: &nfs.ClientRPCStats{ Network: nfs.Network{ NetCount: 70, UDPCount: 70, TCPCount: 69, TCPConnect: 45, }, ClientRPC: nfs.ClientRPC{ RPCCount: 1218785755, Retransmissions: 374636, AuthRefreshes: 1218815394, }, V2Stats: nfs.V2Stats{ Null: 16, GetAttr: 57, SetAttr: 74, Root: 52, Lookup: 71, ReadLink: 73, Read: 45, WrCache: 86, Write: 0, Create: 52, Remove: 83, Rename: 61, Link: 17, SymLink: 53, MkDir: 50, RmDir: 23, ReadDir: 70, FsStat: 82, }, V3Stats: nfs.V3Stats{ Null: 0, GetAttr: 1061909262, SetAttr: 48906, Lookup: 4077635, Access: 117661341, ReadLink: 5, Read: 29391916, Write: 2570425, Create: 2993289, MkDir: 590, SymLink: 0, MkNod: 0, Remove: 7815, RmDir: 15, Rename: 1130, Link: 0, ReadDir: 3983, ReadDirPlus: 92385, FsStat: 13332, FsInfo: 2, PathConf: 1, Commit: 23729}, ClientV4Stats: nfs.ClientV4Stats{ Null: 98, Read: 51, Write: 54, Commit: 83, Open: 85, OpenConfirm: 23, OpenNoattr: 24, OpenDowngrade: 1, Close: 28, Setattr: 73, FsInfo: 68, Renew: 83, SetClientID: 12, SetClientIDConfirm: 84, Lock: 39, Lockt: 68, Locku: 59, Access: 58, Getattr: 88, Lookup: 29, LookupRoot: 74, Remove: 69, Rename: 96, Link: 21, Symlink: 84, Create: 15, Pathconf: 53, StatFs: 86, ReadLink: 54, ReadDir: 66, ServerCaps: 56, DelegReturn: 97, GetACL: 36, SetACL: 49, FsLocations: 32, ReleaseLockowner: 85, Secinfo: 81, FsidPresent: 11, ExchangeID: 58, CreateSession: 32, DestroySession: 67, Sequence: 13, GetLeaseTime: 28, ReclaimComplete: 35, LayoutGet: 90, GetDeviceInfo: 1, LayoutCommit: 26, LayoutReturn: 1337, SecinfoNoName: 0, TestStateID: 0, FreeStateID: 0, GetDeviceList: 0, BindConnToSession: 0, DestroyClientID: 0, Seek: 0, Allocate: 0, DeAllocate: 0, LayoutStats: 0, Clone: 0, }, }, }, { name: "good file", content: `net 18628 0 18628 6 rpc 4329785 0 4338291 proc2 18 2 69 0 0 4410 0 0 0 0 0 0 0 0 0 0 0 99 2 proc3 22 1 4084749 29200 94754 32580 186 47747 7981 8639 0 6356 0 6962 0 7958 0 0 241 4 4 2 39 proc4 61 1 0 0 0 0 0 0 0 0 0 0 0 1 1 0 0 0 0 0 0 0 2 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 `, stats: &nfs.ClientRPCStats{ Network: nfs.Network{ NetCount: 18628, UDPCount: 0, TCPCount: 18628, TCPConnect: 6, }, ClientRPC: nfs.ClientRPC{ RPCCount: 4329785, Retransmissions: 0, AuthRefreshes: 4338291, }, V2Stats: nfs.V2Stats{ Null: 2, GetAttr: 69, SetAttr: 0, Root: 0, Lookup: 4410, ReadLink: 0, Read: 0, WrCache: 0, Write: 0, Create: 0, Remove: 0, Rename: 0, Link: 0, SymLink: 0, MkDir: 0, RmDir: 0, ReadDir: 99, FsStat: 2, }, V3Stats: nfs.V3Stats{ Null: 1, GetAttr: 4084749, SetAttr: 29200, Lookup: 94754, Access: 32580, ReadLink: 186, Read: 47747, Write: 7981, Create: 8639, MkDir: 0, SymLink: 6356, MkNod: 0, Remove: 6962, RmDir: 0, Rename: 7958, Link: 0, ReadDir: 0, ReadDirPlus: 241, FsStat: 4, FsInfo: 4, PathConf: 2, Commit: 39, }, ClientV4Stats: nfs.ClientV4Stats{ Null: 1, Read: 0, Write: 0, Commit: 0, Open: 0, OpenConfirm: 0, OpenNoattr: 0, OpenDowngrade: 0, Close: 0, Setattr: 0, FsInfo: 0, Renew: 0, SetClientID: 1, SetClientIDConfirm: 1, Lock: 0, Lockt: 0, Locku: 0, Access: 0, Getattr: 0, Lookup: 0, LookupRoot: 0, Remove: 2, Rename: 0, Link: 0, Symlink: 0, Create: 0, Pathconf: 0, StatFs: 0, ReadLink: 0, ReadDir: 0, ServerCaps: 0, DelegReturn: 0, GetACL: 0, SetACL: 0, FsLocations: 0, ReleaseLockowner: 0, Secinfo: 0, FsidPresent: 0, ExchangeID: 0, CreateSession: 0, DestroySession: 0, Sequence: 0, GetLeaseTime: 0, ReclaimComplete: 0, LayoutGet: 0, GetDeviceInfo: 0, LayoutCommit: 0, LayoutReturn: 0, SecinfoNoName: 0, TestStateID: 0, FreeStateID: 0, GetDeviceList: 0, BindConnToSession: 0, DestroyClientID: 0, Seek: 0, Allocate: 0, DeAllocate: 0, LayoutStats: 0, Clone: 0, }, }, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { stats, err := nfs.ParseClientRPCStats(strings.NewReader(tt.content)) if tt.invalid && err == nil { t.Fatal("expected an error, but none occurred") } if !tt.invalid && err != nil { t.Fatalf("unexpected error: %v", err) } if want, have := tt.stats, stats; !reflect.DeepEqual(want, have) { t.Fatalf("unexpected NFS stats:\nwant:\n%v\nhave:\n%v", want, have) } }) } }	7.86 KB	2025-05-25 12:27
📄 parse_nfsd.go // Copyright 2018 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 nfs import ( "bufio" "fmt" "io" "strings" "github.com/prometheus/procfs/internal/util" ) // ParseServerRPCStats returns stats read from /proc/net/rpc/nfsd. func ParseServerRPCStats(r io.Reader) (*ServerRPCStats, error) { stats := &ServerRPCStats{} scanner := bufio.NewScanner(r) for scanner.Scan() { line := scanner.Text() parts := strings.Fields(scanner.Text()) // require at least <key> <value> if len(parts) < 2 { return nil, fmt.Errorf("invalid NFSd metric line %q", line) } label := parts[0] var values []uint64 var err error if label == "th" { if len(parts) < 3 { return nil, fmt.Errorf("invalid NFSd th metric line %q", line) } values, err = util.ParseUint64s(parts[1:3]) } else { values, err = util.ParseUint64s(parts[1:]) } if err != nil { return nil, fmt.Errorf("error parsing NFSd metric line: %w", err) } switch metricLine := parts[0]; metricLine { case "rc": stats.ReplyCache, err = parseReplyCache(values) case "fh": stats.FileHandles, err = parseFileHandles(values) case "io": stats.InputOutput, err = parseInputOutput(values) case "th": stats.Threads, err = parseThreads(values) case "ra": stats.ReadAheadCache, err = parseReadAheadCache(values) case "net": stats.Network, err = parseNetwork(values) case "rpc": stats.ServerRPC, err = parseServerRPC(values) case "proc2": stats.V2Stats, err = parseV2Stats(values) case "proc3": stats.V3Stats, err = parseV3Stats(values) case "proc4": stats.ServerV4Stats, err = parseServerV4Stats(values) case "proc4ops": stats.V4Ops, err = parseV4Ops(values) case "wdeleg_getattr": stats.WdelegGetattr = values[0] default: return nil, fmt.Errorf("unknown NFSd metric line %q", metricLine) } if err != nil { return nil, fmt.Errorf("errors parsing NFSd metric line: %w", err) } } if err := scanner.Err(); err != nil { return nil, fmt.Errorf("error scanning NFSd file: %w", err) } return stats, nil }	2.53 KB	2025-05-25 12:27
📄 parse_nfsd_test.go // Copyright 2018 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 nfs_test import ( "reflect" "strings" "testing" "github.com/prometheus/procfs/nfs" ) func TestNewNFSdServerRPCStats(t testing.T) { tests := []struct { name string content string stats nfs.ServerRPCStats invalid bool }{ { name: "invalid file", content: "invalid", invalid: true, }, { name: "good file, proc4ops 72", content: `rc 0 6 18622 fh 0 0 0 0 0 io 157286400 0 th 8 0 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 ra 32 0 0 0 0 0 0 0 0 0 0 0 net 18628 0 18628 6 rpc 18628 0 0 0 0 proc2 18 2 69 0 0 4410 0 0 0 0 0 0 0 0 0 0 0 99 2 proc3 22 2 112 0 2719 111 0 0 0 0 0 0 0 0 0 0 0 27 216 0 2 1 0 proc4 2 2 10853 proc4ops 72 0 0 0 1098 2 0 0 0 0 8179 5896 0 0 0 0 5900 0 0 2 0 2 0 9609 0 2 150 1272 0 0 0 1236 0 0 0 0 3 3 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 wdeleg_getattr 16 `, stats: &nfs.ServerRPCStats{ ReplyCache: nfs.ReplyCache{ Hits: 0, Misses: 6, NoCache: 18622, }, FileHandles: nfs.FileHandles{ Stale: 0, TotalLookups: 0, AnonLookups: 0, DirNoCache: 0, NoDirNoCache: 0, }, InputOutput: nfs.InputOutput{ Read: 157286400, Write: 0, }, Threads: nfs.Threads{ Threads: 8, FullCnt: 0, }, ReadAheadCache: nfs.ReadAheadCache{ CacheSize: 32, CacheHistogram: []uint64{0, 0, 0, 0, 0, 0, 0, 0, 0, 0}, NotFound: 0, }, Network: nfs.Network{ NetCount: 18628, UDPCount: 0, TCPCount: 18628, TCPConnect: 6, }, ServerRPC: nfs.ServerRPC{ RPCCount: 18628, BadCnt: 0, BadFmt: 0, BadAuth: 0, BadcInt: 0, }, V2Stats: nfs.V2Stats{ Null: 2, GetAttr: 69, SetAttr: 0, Root: 0, Lookup: 4410, ReadLink: 0, Read: 0, WrCache: 0, Write: 0, Create: 0, Remove: 0, Rename: 0, Link: 0, SymLink: 0, MkDir: 0, RmDir: 0, ReadDir: 99, FsStat: 2, }, V3Stats: nfs.V3Stats{ Null: 2, GetAttr: 112, SetAttr: 0, Lookup: 2719, Access: 111, ReadLink: 0, Read: 0, Write: 0, Create: 0, MkDir: 0, SymLink: 0, MkNod: 0, Remove: 0, RmDir: 0, Rename: 0, Link: 0, ReadDir: 27, ReadDirPlus: 216, FsStat: 0, FsInfo: 2, PathConf: 1, Commit: 0, }, ServerV4Stats: nfs.ServerV4Stats{ Null: 2, Compound: 10853, }, V4Ops: nfs.V4Ops{ Op0Unused: 0, Op1Unused: 0, Op2Future: 0, Access: 1098, Close: 2, Commit: 0, Create: 0, DelegPurge: 0, DelegReturn: 0, GetAttr: 8179, GetFH: 5896, Link: 0, Lock: 0, Lockt: 0, Locku: 0, Lookup: 5900, LookupRoot: 0, Nverify: 0, Open: 2, OpenAttr: 0, OpenConfirm: 2, OpenDgrd: 0, PutFH: 9609, PutPubFH: 0, PutRootFH: 2, Read: 150, ReadDir: 1272, ReadLink: 0, Remove: 0, Rename: 0, Renew: 1236, RestoreFH: 0, SaveFH: 0, SecInfo: 0, SetAttr: 0, SetClientID: 3, SetClientIDConfirm: 3, Verify: 0, Write: 0, RelLockOwner: 0, }, WdelegGetattr: 16, }, }, { name: "good file, proc4ops 40", content: `rc 0 25020854 19157796 fh 276 0 0 0 0 io 899844043 2470085989 th 1024 0 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 ra 2048 4250593 118232 55926 31504 20253 13815 9875 7028 5546 3991 171551 net 44179842 1 44179026 3092 rpc 44177753 0 0 0 0 proc2 18 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 proc3 22 747 7259760 1383711 1570520 3464939 8436 4688207 21668847 1173194 6457 2127 172 213538 1253 556401 14950 1101 56245 90790 742 367 1989658 proc4 2 0 0 proc4ops 40 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 wdeleg_getattr 9`, stats: &nfs.ServerRPCStats{ ReplyCache: nfs.ReplyCache{ Hits: 0, Misses: 25020854, NoCache: 19157796, }, FileHandles: nfs.FileHandles{ Stale: 276, TotalLookups: 0, AnonLookups: 0, DirNoCache: 0, NoDirNoCache: 0, }, InputOutput: nfs.InputOutput{ Read: 899844043, Write: 2470085989, }, Threads: nfs.Threads{ Threads: 1024, FullCnt: 0, }, ReadAheadCache: nfs.ReadAheadCache{ CacheSize: 2048, CacheHistogram: []uint64{4250593, 118232, 55926, 31504, 20253, 13815, 9875, 7028, 5546, 3991}, NotFound: 171551, }, Network: nfs.Network{ NetCount: 44179842, UDPCount: 1, TCPCount: 44179026, TCPConnect: 3092, }, ServerRPC: nfs.ServerRPC{ RPCCount: 44177753, BadCnt: 0, BadFmt: 0, BadAuth: 0, BadcInt: 0, }, V2Stats: nfs.V2Stats{ Null: 0, GetAttr: 0, SetAttr: 0, Root: 0, Lookup: 0, ReadLink: 0, Read: 0, WrCache: 0, Write: 0, Create: 0, Remove: 0, Rename: 0, Link: 0, SymLink: 0, MkDir: 0, RmDir: 0, ReadDir: 0, FsStat: 0, }, V3Stats: nfs.V3Stats{ Null: 747, GetAttr: 7259760, SetAttr: 1383711, Lookup: 1570520, Access: 3464939, ReadLink: 8436, Read: 4688207, Write: 21668847, Create: 1173194, MkDir: 6457, SymLink: 2127, MkNod: 172, Remove: 213538, RmDir: 1253, Rename: 556401, Link: 14950, ReadDir: 1101, ReadDirPlus: 56245, FsStat: 90790, FsInfo: 742, PathConf: 367, Commit: 1989658, }, ServerV4Stats: nfs.ServerV4Stats{ Null: 0, Compound: 0, }, V4Ops: nfs.V4Ops{ Op0Unused: 0, Op1Unused: 0, Op2Future: 0, Access: 0, Close: 0, Commit: 0, Create: 0, DelegPurge: 0, DelegReturn: 0, GetAttr: 0, GetFH: 0, Link: 0, Lock: 0, Lockt: 0, Locku: 0, Lookup: 0, LookupRoot: 0, Nverify: 0, Open: 0, OpenAttr: 0, OpenConfirm: 0, OpenDgrd: 0, PutFH: 0, PutPubFH: 0, PutRootFH: 0, Read: 0, ReadDir: 0, ReadLink: 0, Remove: 0, Rename: 0, Renew: 0, RestoreFH: 0, SaveFH: 0, SecInfo: 0, SetAttr: 0, SetClientID: 0, SetClientIDConfirm: 0, Verify: 0, Write: 0, RelLockOwner: 0, }, WdelegGetattr: 9, }, }, { name: "good file, proc4ops 59", content: `rc 0 268 742119 fh 0 0 0 0 0 io 2476981939 0 th 8 0 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 ra 32 30104 0 0 0 0 0 0 0 0 0 71174 net 742701 314 742393 10103960 rpc 742406 310 310 0 0 proc2 18 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 proc3 22 105 71158 0 175642 184711 17103 101277 0 0 0 0 0 0 0 0 0 0 8916 102 202 0 0 proc4 2 101 182991 proc4ops 59 0 0 0 18112 8341 0 0 0 3239 71595 11834 0 0 0 0 107097 0 0 8344 0 5100 0 181968 0 235 5735 4406 0 0 0 652 8342 8344 0 0 134 134 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 wdeleg_getattr 10`, stats: &nfs.ServerRPCStats{ ReplyCache: nfs.ReplyCache{ Hits: 0, Misses: 268, NoCache: 742119, }, FileHandles: nfs.FileHandles{ Stale: 0, TotalLookups: 0, AnonLookups: 0, DirNoCache: 0, NoDirNoCache: 0, }, InputOutput: nfs.InputOutput{ Read: 2476981939, Write: 0, }, Threads: nfs.Threads{ Threads: 8, FullCnt: 0, }, ReadAheadCache: nfs.ReadAheadCache{ CacheSize: 32, CacheHistogram: []uint64{30104, 0, 0, 0, 0, 0, 0, 0, 0, 0}, NotFound: 71174, }, Network: nfs.Network{ NetCount: 742701, UDPCount: 314, TCPCount: 742393, TCPConnect: 10103960, }, ServerRPC: nfs.ServerRPC{ RPCCount: 742406, BadCnt: 310, BadFmt: 310, BadAuth: 0, BadcInt: 0, }, V2Stats: nfs.V2Stats{ Null: 0, GetAttr: 0, SetAttr: 0, Root: 0, Lookup: 0, ReadLink: 0, Read: 0, WrCache: 0, Write: 0, Create: 0, Remove: 0, Rename: 0, Link: 0, SymLink: 0, MkDir: 0, RmDir: 0, ReadDir: 0, FsStat: 0, }, V3Stats: nfs.V3Stats{ Null: 105, GetAttr: 71158, SetAttr: 0, Lookup: 175642, Access: 184711, ReadLink: 17103, Read: 101277, Write: 0, Create: 0, MkDir: 0, SymLink: 0, MkNod: 0, Remove: 0, RmDir: 0, Rename: 0, Link: 0, ReadDir: 0, ReadDirPlus: 8916, FsStat: 102, FsInfo: 202, PathConf: 0, Commit: 0, }, ServerV4Stats: nfs.ServerV4Stats{ Null: 101, Compound: 182991, }, V4Ops: nfs.V4Ops{ Op0Unused: 0, Op1Unused: 0, Op2Future: 0, Access: 18112, Close: 8341, Commit: 0, Create: 0, DelegPurge: 0, DelegReturn: 3239, GetAttr: 71595, GetFH: 11834, Link: 0, Lock: 0, Lockt: 0, Locku: 0, Lookup: 107097, LookupRoot: 0, Nverify: 0, Open: 8344, OpenAttr: 0, OpenConfirm: 5100, OpenDgrd: 0, PutFH: 181968, PutPubFH: 0, PutRootFH: 235, Read: 5735, ReadDir: 4406, ReadLink: 0, Remove: 0, Rename: 0, Renew: 652, RestoreFH: 8342, SaveFH: 8344, SecInfo: 0, SetAttr: 0, SetClientID: 134, SetClientIDConfirm: 134, Verify: 0, Write: 0, RelLockOwner: 0, }, WdelegGetattr: 10, }, }, { name: "good file, proc4ops 39", content: `rc 0 25020854 19157796 fh 276 0 0 0 0 io 899844043 2470085989 th 1024 0 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 0.000 ra 2048 4250593 118232 55926 31504 20253 13815 9875 7028 5546 3991 171551 net 44179842 1 44179026 3092 rpc 44177753 0 0 0 0 proc2 18 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 proc3 22 747 7259760 1383711 1570520 3464939 8436 4688207 21668847 1173194 6457 2127 172 213538 1253 556401 14950 1101 56245 90790 742 367 1989658 proc4 2 0 0 proc4ops 39 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 39 wdeleg_getattr 765432`, stats: &nfs.ServerRPCStats{ ReplyCache: nfs.ReplyCache{ Hits: 0, Misses: 25020854, NoCache: 19157796, }, FileHandles: nfs.FileHandles{ Stale: 276, TotalLookups: 0, AnonLookups: 0, DirNoCache: 0, NoDirNoCache: 0, }, InputOutput: nfs.InputOutput{ Read: 899844043, Write: 2470085989, }, Threads: nfs.Threads{ Threads: 1024, FullCnt: 0, }, ReadAheadCache: nfs.ReadAheadCache{ CacheSize: 2048, CacheHistogram: []uint64{4250593, 118232, 55926, 31504, 20253, 13815, 9875, 7028, 5546, 3991}, NotFound: 171551, }, Network: nfs.Network{ NetCount: 44179842, UDPCount: 1, TCPCount: 44179026, TCPConnect: 3092, }, ServerRPC: nfs.ServerRPC{ RPCCount: 44177753, BadCnt: 0, BadFmt: 0, BadAuth: 0, BadcInt: 0, }, V2Stats: nfs.V2Stats{ Null: 0, GetAttr: 0, SetAttr: 0, Root: 0, Lookup: 0, ReadLink: 0, Read: 0, WrCache: 0, Write: 0, Create: 0, Remove: 0, Rename: 0, Link: 0, SymLink: 0, MkDir: 0, RmDir: 0, ReadDir: 0, FsStat: 0, }, V3Stats: nfs.V3Stats{ Null: 747, GetAttr: 7259760, SetAttr: 1383711, Lookup: 1570520, Access: 3464939, ReadLink: 8436, Read: 4688207, Write: 21668847, Create: 1173194, MkDir: 6457, SymLink: 2127, MkNod: 172, Remove: 213538, RmDir: 1253, Rename: 556401, Link: 14950, ReadDir: 1101, ReadDirPlus: 56245, FsStat: 90790, FsInfo: 742, PathConf: 367, Commit: 1989658, }, ServerV4Stats: nfs.ServerV4Stats{ Null: 0, Compound: 0, }, V4Ops: nfs.V4Ops{ Op0Unused: 0, Op1Unused: 0, Op2Future: 0, Access: 0, Close: 0, Commit: 0, Create: 0, DelegPurge: 0, DelegReturn: 0, GetAttr: 0, GetFH: 0, Link: 0, Lock: 0, Lockt: 0, Locku: 0, Lookup: 0, LookupRoot: 0, Nverify: 0, Open: 0, OpenAttr: 0, OpenConfirm: 0, OpenDgrd: 0, PutFH: 0, PutPubFH: 0, PutRootFH: 0, Read: 0, ReadDir: 0, ReadLink: 0, Remove: 0, Rename: 0, Renew: 0, RestoreFH: 0, SaveFH: 0, SecInfo: 0, SetAttr: 0, SetClientID: 0, SetClientIDConfirm: 0, Verify: 0, Write: 39, RelLockOwner: 0, }, WdelegGetattr: 765432, }, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { stats, err := nfs.ParseServerRPCStats(strings.NewReader(tt.content)) if tt.invalid && err == nil { t.Fatal("expected an error, but none occurred") } if !tt.invalid && err != nil { t.Fatalf("unexpected error: %v", err) } if want, have := tt.stats, stats; !reflect.DeepEqual(want, have) { t.Fatalf("unexpected NFS stats:\nwant:\n%v\nhave:\n%v", want, have) } }) } }	15.73 KB	2025-05-25 12:27

Terminal