diff options
Diffstat (limited to 'vendor/github.com/prometheus/procfs/sysfs/class_fibrechannel.go')
-rw-r--r-- | vendor/github.com/prometheus/procfs/sysfs/class_fibrechannel.go | 249 |
1 files changed, 249 insertions, 0 deletions
diff --git a/vendor/github.com/prometheus/procfs/sysfs/class_fibrechannel.go b/vendor/github.com/prometheus/procfs/sysfs/class_fibrechannel.go new file mode 100644 index 0000000..d57ff9c --- /dev/null +++ b/vendor/github.com/prometheus/procfs/sysfs/class_fibrechannel.go | |||
@@ -0,0 +1,249 @@ | |||
1 | // Copyright 2020 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 | |||
14 | // +build !windows | ||
15 | |||
16 | package sysfs | ||
17 | |||
18 | import ( | ||
19 | "fmt" | ||
20 | "io/ioutil" | ||
21 | "os" | ||
22 | "path/filepath" | ||
23 | |||
24 | "github.com/prometheus/procfs/internal/util" | ||
25 | ) | ||
26 | |||
27 | const fibrechannelClassPath = "class/fc_host" | ||
28 | |||
29 | type FibreChannelCounters struct { | ||
30 | DumpedFrames uint64 // /sys/class/fc_host/<Name>/statistics/dumped_frames | ||
31 | ErrorFrames uint64 // /sys/class/fc_host/<Name>/statistics/error_frames | ||
32 | InvalidCRCCount uint64 // /sys/class/fc_host/<Name>/statistics/invalid_crc_count | ||
33 | RXFrames uint64 // /sys/class/fc_host/<Name>/statistics/rx_frames | ||
34 | RXWords uint64 // /sys/class/fc_host/<Name>/statistics/rx_words | ||
35 | TXFrames uint64 // /sys/class/fc_host/<Name>/statistics/tx_frames | ||
36 | TXWords uint64 // /sys/class/fc_host/<Name>/statistics/tx_words | ||
37 | SecondsSinceLastReset uint64 // /sys/class/fc_host/<Name>/statistics/seconds_since_last_reset | ||
38 | InvalidTXWordCount uint64 // /sys/class/fc_host/<Name>/statistics/invalid_tx_word_count | ||
39 | LinkFailureCount uint64 // /sys/class/fc_host/<Name>/statistics/link_failure_count | ||
40 | LossOfSyncCount uint64 // /sys/class/fc_host/<Name>/statistics/loss_of_sync_count | ||
41 | LossOfSignalCount uint64 // /sys/class/fc_host/<Name>/statistics/loss_of_signal_count | ||
42 | NosCount uint64 // /sys/class/fc_host/<Name>/statistics/nos_count | ||
43 | FCPPacketAborts uint64 // / sys/class/fc_host/<Name>/statistics/fcp_packet_aborts | ||
44 | } | ||
45 | |||
46 | type FibreChannelHost struct { | ||
47 | Name string // /sys/class/fc_host/<Name> | ||
48 | Speed string // /sys/class/fc_host/<Name>/speed | ||
49 | PortState string // /sys/class/fc_host/<Name>/port_state | ||
50 | PortType string // /sys/class/fc_host/<Name>/port_type | ||
51 | SymbolicName string // /sys/class/fc_host/<Name>/symbolic_name | ||
52 | NodeName string // /sys/class/fc_host/<Name>/node_name | ||
53 | PortID string // /sys/class/fc_host/<Name>/port_id | ||
54 | PortName string // /sys/class/fc_host/<Name>/port_name | ||
55 | FabricName string // /sys/class/fc_host/<Name>/fabric_name | ||
56 | DevLossTMO string // /sys/class/fc_host/<Name>/dev_loss_tmo | ||
57 | SupportedClasses string // /sys/class/fc_host/<Name>/supported_classes | ||
58 | SupportedSpeeds string // /sys/class/fc_host/<Name>/supported_speeds | ||
59 | Counters FibreChannelCounters // /sys/class/fc_host/<Name>/statistics/* | ||
60 | } | ||
61 | |||
62 | type FibreChannelClass map[string]FibreChannelHost | ||
63 | |||
64 | // FibreChannelClass parses everything in /sys/class/fc_host. | ||
65 | func (fs FS) FibreChannelClass() (FibreChannelClass, error) { | ||
66 | path := fs.sys.Path(fibrechannelClassPath) | ||
67 | |||
68 | dirs, err := ioutil.ReadDir(path) | ||
69 | if err != nil { | ||
70 | return nil, err | ||
71 | } | ||
72 | |||
73 | fcc := make(FibreChannelClass, len(dirs)) | ||
74 | for _, d := range dirs { | ||
75 | host, err := fs.parseFibreChannelHost(d.Name()) | ||
76 | if err != nil { | ||
77 | return nil, err | ||
78 | } | ||
79 | |||
80 | fcc[host.Name] = *host | ||
81 | } | ||
82 | |||
83 | return fcc, nil | ||
84 | } | ||
85 | |||
86 | // Parse a single FC host | ||
87 | func (fs FS) parseFibreChannelHost(name string) (*FibreChannelHost, error) { | ||
88 | path := fs.sys.Path(fibrechannelClassPath, name) | ||
89 | host := FibreChannelHost{Name: name} | ||
90 | |||
91 | for _, f := range [...]string{"speed", "port_state", "port_type", "node_name", "port_id", "port_name", "fabric_name", "dev_loss_tmo", "symbolic_name", "supported_classes", "supported_speeds"} { | ||
92 | name := filepath.Join(path, f) | ||
93 | value, err := util.SysReadFile(name) | ||
94 | if err != nil { | ||
95 | return nil, fmt.Errorf("failed to read file %q: %v", name, err) | ||
96 | } | ||
97 | |||
98 | switch f { | ||
99 | case "speed": | ||
100 | host.Speed = value | ||
101 | case "port_state": | ||
102 | host.PortState = value | ||
103 | case "port_type": | ||
104 | host.PortType = value | ||
105 | case "node_name": | ||
106 | if len(value) > 2 { | ||
107 | value = value[2:] | ||
108 | } | ||
109 | host.NodeName = value | ||
110 | case "port_id": | ||
111 | if len(value) > 2 { | ||
112 | value = value[2:] | ||
113 | } | ||
114 | host.PortID = value | ||
115 | case "port_name": | ||
116 | if len(value) > 2 { | ||
117 | value = value[2:] | ||
118 | } | ||
119 | host.PortName = value | ||
120 | case "fabric_name": | ||
121 | if len(value) > 2 { | ||
122 | value = value[2:] | ||
123 | } | ||
124 | host.FabricName = value | ||
125 | case "dev_loss_tmo": | ||
126 | host.DevLossTMO = value | ||
127 | case "supported_classes": | ||
128 | host.SupportedClasses = value | ||
129 | case "supported_speeds": | ||
130 | host.SupportedSpeeds = value | ||
131 | case "symbolic_name": | ||
132 | host.SymbolicName = value | ||
133 | } | ||
134 | } | ||
135 | |||
136 | counters, err := parseFibreChannelStatistics(path) | ||
137 | if err != nil { | ||
138 | return nil, err | ||
139 | } | ||
140 | host.Counters = *counters | ||
141 | |||
142 | return &host, nil | ||
143 | } | ||
144 | |||
145 | // parseFibreChannelStatistics parses metrics from a single FC host. | ||
146 | func parseFibreChannelStatistics(hostPath string) (*FibreChannelCounters, error) { | ||
147 | var counters FibreChannelCounters | ||
148 | |||
149 | path := filepath.Join(hostPath, "statistics") | ||
150 | files, err := ioutil.ReadDir(path) | ||
151 | if err != nil { | ||
152 | return nil, err | ||
153 | } | ||
154 | |||
155 | for _, f := range files { | ||
156 | if !f.Mode().IsRegular() || f.Name() == "reset_statistics" { | ||
157 | continue | ||
158 | } | ||
159 | |||
160 | name := filepath.Join(path, f.Name()) | ||
161 | value, err := util.SysReadFile(name) | ||
162 | if err != nil { | ||
163 | // there are some write-only files in this directory; we can safely skip over them | ||
164 | if os.IsNotExist(err) || err.Error() == "operation not supported" || err.Error() == "invalid argument" { | ||
165 | continue | ||
166 | } | ||
167 | return nil, fmt.Errorf("failed to read file %q: %v", name, err) | ||
168 | } | ||
169 | |||
170 | vp := util.NewValueParser(value) | ||
171 | |||
172 | // Below switch was automatically generated. Don't need everything in there yet, so the unwanted bits are commented out. | ||
173 | switch f.Name() { | ||
174 | case "dumped_frames": | ||
175 | counters.DumpedFrames = *vp.PUInt64() | ||
176 | case "error_frames": | ||
177 | counters.ErrorFrames = *vp.PUInt64() | ||
178 | /* | ||
179 | case "fc_no_free_exch": | ||
180 | counters.FcNoFreeExch = *vp.PUInt64() | ||
181 | case "fc_no_free_exch_xid": | ||
182 | counters.FcNoFreeExchXid = *vp.PUInt64() | ||
183 | case "fc_non_bls_resp": | ||
184 | counters.FcNonBlsResp = *vp.PUInt64() | ||
185 | case "fc_seq_not_found": | ||
186 | counters.FcSeqNotFound = *vp.PUInt64() | ||
187 | case "fc_xid_busy": | ||
188 | counters.FcXidBusy = *vp.PUInt64() | ||
189 | case "fc_xid_not_found": | ||
190 | counters.FcXidNotFound = *vp.PUInt64() | ||
191 | case "fcp_control_requests": | ||
192 | counters.FcpControlRequests = *vp.PUInt64() | ||
193 | case "fcp_frame_alloc_failures": | ||
194 | counters.FcpFrameAllocFailures = *vp.PUInt64() | ||
195 | case "fcp_input_megabytes": | ||
196 | counters.FcpInputMegabytes = *vp.PUInt64() | ||
197 | case "fcp_input_requests": | ||
198 | counters.FcpInputRequests = *vp.PUInt64() | ||
199 | case "fcp_output_megabytes": | ||
200 | counters.FcpOutputMegabytes = *vp.PUInt64() | ||
201 | case "fcp_output_requests": | ||
202 | counters.FcpOutputRequests = *vp.PUInt64() | ||
203 | */ | ||
204 | case "fcp_packet_aborts": | ||
205 | counters.FCPPacketAborts = *vp.PUInt64() | ||
206 | /* | ||
207 | case "fcp_packet_alloc_failures": | ||
208 | counters.FcpPacketAllocFailures = *vp.PUInt64() | ||
209 | */ | ||
210 | case "invalid_tx_word_count": | ||
211 | counters.InvalidTXWordCount = *vp.PUInt64() | ||
212 | case "invalid_crc_count": | ||
213 | counters.InvalidCRCCount = *vp.PUInt64() | ||
214 | case "link_failure_count": | ||
215 | counters.LinkFailureCount = *vp.PUInt64() | ||
216 | /* | ||
217 | case "lip_count": | ||
218 | counters.LipCount = *vp.PUInt64() | ||
219 | */ | ||
220 | case "loss_of_signal_count": | ||
221 | counters.LossOfSignalCount = *vp.PUInt64() | ||
222 | case "loss_of_sync_count": | ||
223 | counters.LossOfSyncCount = *vp.PUInt64() | ||
224 | case "nos_count": | ||
225 | counters.NosCount = *vp.PUInt64() | ||
226 | /* | ||
227 | case "prim_seq_protocol_err_count": | ||
228 | counters.PrimSeqProtocolErrCount = *vp.PUInt64() | ||
229 | */ | ||
230 | case "rx_frames": | ||
231 | counters.RXFrames = *vp.PUInt64() | ||
232 | case "rx_words": | ||
233 | counters.RXWords = *vp.PUInt64() | ||
234 | case "seconds_since_last_reset": | ||
235 | counters.SecondsSinceLastReset = *vp.PUInt64() | ||
236 | case "tx_frames": | ||
237 | counters.TXFrames = *vp.PUInt64() | ||
238 | case "tx_words": | ||
239 | counters.TXWords = *vp.PUInt64() | ||
240 | } | ||
241 | |||
242 | if err := vp.Err(); err != nil { | ||
243 | return nil, err | ||
244 | } | ||
245 | |||
246 | } | ||
247 | |||
248 | return &counters, nil | ||
249 | } | ||