1 /* Copyright (C) 2021-2023 Free Software Foundation, Inc.
2 Contributed by Oracle.
3
4 This file is part of GNU Binutils.
5
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3, or (at your option)
9 any later version.
10
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
15
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, write to the Free Software
18 Foundation, 51 Franklin Street - Fifth Floor, Boston,
19 MA 02110-1301, USA. */
20
21 #ifndef _FILEDATA_H
22 #define _FILEDATA_H
23
24 #include "gp-defs.h"
25 #include "gp-time.h"
26
27 #include "vec.h"
28 #include "data_pckts.h"
29 #include "Histable.h"
30
31 #define FSTYPESZ 16
32
33 #define VIRTUAL_FD_TOTAL 0
34 #define VIRTUAL_FD_STDIN 1
35 #define VIRTUAL_FD_STDOUT 2
36 #define VIRTUAL_FD_STDERR 3
37 #define VIRTUAL_FD_OTHERIO 4
38 #define VIRTUAL_FD_NONE -1
39
40 #define STDIN_FD 0
41 #define STDOUT_FD 1
42 #define STDERR_FD 2
43 #define OTHERIO_FD -1
44
45 #define OTHERIO_FILENAME "<Other IO activity>"
46 #define STDIN_FILENAME "<stdin>"
47 #define STDOUT_FILENAME "<stdout>"
48 #define STDERR_FILENAME "<stderr>"
49 #define TOTAL_FILENAME NTXT("<Total>")
50 #define UNKNOWNFD_FILENAME "<pipe(), socket(), or other fds>"
51
52 #define _1KB 1024
53 #define _8KB 8192
54 #define _32KB 32768
55 #define _128KB 131072
56 #define _256KB 262144
57 #define _512KB 524288
58 #define _1000KB 1048576
59 #define _10MB 10485760
60 #define _100MB 104857600
61 #define _1GB 1073741824
62 #define _10GB 10737418240
63 #define _100GB 107374182400
64 #define _1TB 1099511627776
65 #define _10TB 10995116277760
66
67 class FileData : public Histable
68 {
69 friend class IOActivity;
70 public:
71 FileData (const char *fName);
72 FileData (FileData *fData);
73 ~FileData ();
74
75 virtual char *get_name (Histable::NameFormat nfmt);
76 virtual Histable *convertto (Histable_type, Histable* = NULL);
77
78 char *get_raw_name (Histable::NameFormat nfmt);
79 void setFsType (FileSystem_type fst);
80 void setFsType (const char* fst);
81
82 virtual Histable_type
83 get_type ()
84 {
85 return histType;
86 };
87
88 virtual uint64_t
89 get_addr ()
90 {
91 return virtualFd;
92 };
93
94 uint64_t
95 get_index ()
96 {
97 return virtualFd;
98 };
99
100 void init ();
101
102 char *
103 getFileName ()
104 {
105 return fileName;
106 }
107
108 void
109 addReadEvent (hrtime_t rt, int64_t nb)
110 {
111 readTime += rt;
112 readBytes += nb;
113 readCnt++;
114 }
115
116 hrtime_t
117 getReadTime ()
118 {
119 return readTime;
120 }
121
122 int64_t
123 getReadBytes ()
124 {
125 return readBytes;
126 }
127
128 int32_t
129 getReadCnt ()
130 {
131 return readCnt;
132 }
133
134 void
135 addWriteEvent (hrtime_t wt, int64_t nb)
136 {
137 writeTime += wt;
138 writeBytes += nb;
139 writeCnt++;
140 }
141
142 hrtime_t
143 getWriteTime ()
144 {
145 return writeTime;
146 }
147
148 int64_t
149 getWriteBytes ()
150 {
151 return writeBytes;
152 }
153
154 int32_t
155 getWriteCnt ()
156 {
157 return writeCnt;
158 }
159
160 void
161 addOtherEvent (hrtime_t ot)
162 {
163 otherTime += ot;
164 otherCnt++;
165 }
166
167 hrtime_t
168 getOtherTime ()
169 {
170 return otherTime;
171 }
172
173 int32_t
174 getOtherCnt ()
175 {
176 return otherCnt;
177 }
178
179 void
180 addErrorEvent (hrtime_t er)
181 {
182 errorTime += er;
183 errorCnt++;
184 }
185
186 hrtime_t
187 getErrorTime ()
188 {
189 return errorTime;
190 }
191
192 int32_t
193 getErrorCnt ()
194 {
195 return errorCnt;
196 }
197
198 void setFileDesList (int fd);
199
200 Vector<int> *
201 getFileDesList ()
202 {
203 return fileDesList;
204 }
205
206 void
207 setFileDes (int fd)
208 {
209 fileDes = fd;
210 }
211
212 int32_t
213 getFileDes ()
214 {
215 return fileDes;
216 }
217
218 void setVirtualFds (int64_t vfd);
219
220 Vector<int64_t> *
221 getVirtualFds ()
222 {
223 return virtualFds;
224 }
225
226 char *
227 getFsType ()
228 {
229 return fsType;
230 }
231
232 void
233 setVirtualFd (int64_t vFd)
234 {
235 virtualFd = vFd;
236 }
237
238 int64_t
239 getVirtualFd ()
240 {
241 return virtualFd;
242 }
243
244 void
245 setHistType (Histable::Type hType)
246 {
247 histType = hType;
248 }
249
250 Histable::Type
251 getHistType ()
252 {
253 return histType;
254 }
255
256 void setWriteStat (hrtime_t wt, int64_t nb);
257
258 hrtime_t
259 getWSlowestBytes ()
260 {
261 return wSlowestBytes;
262 }
263
264 int64_t
265 getWSmallestBytes ()
266 {
267 return wSmallestBytes;
268 }
269
270 int64_t
271 getWLargestBytes ()
272 {
273 return wLargestBytes;
274 }
275
276 int32_t
277 getW0KB1KBCnt ()
278 {
279 return w0KB1KBCnt;
280 }
281
282 int32_t
283 getW1KB8KBCnt ()
284 {
285 return w1KB8KBCnt;
286 }
287
288 int32_t
289 getW8KB32KBCnt ()
290 {
291 return w8KB32KBCnt;
292 }
293
294 int32_t
295 getW32KB128KBCnt ()
296 {
297 return w32KB128KBCnt;
298 }
299
300 int32_t
301 getW128KB256KBCnt ()
302 {
303 return w128KB256KBCnt;
304 }
305
306 int32_t
307 getW256KB512KBCnt ()
308 {
309 return w256KB512KBCnt;
310 }
311
312 int32_t
313 getW512KB1000KBCnt ()
314 {
315 return w512KB1000KBCnt;
316 }
317
318 int32_t
319 getW1000KB10MBCnt ()
320 {
321 return w1000KB10MBCnt;
322 }
323
324 int32_t
325 getW10MB100MBCnt ()
326 {
327 return w10MB100MBCnt;
328 }
329
330 int32_t
331 getW100MB1GBCnt ()
332 {
333 return w100MB1GBCnt;
334 }
335
336 int32_t
337 getW1GB10GBCnt ()
338 {
339 return w1GB10GBCnt;
340 }
341
342 int32_t
343 getW10GB100GBCnt ()
344 {
345 return w10GB100GBCnt;
346 }
347
348 int32_t
349 getW100GB1TBCnt ()
350 {
351 return w100GB1TBCnt;
352 }
353
354 int32_t
355 getW1TB10TBCnt ()
356 {
357 return w1TB10TBCnt;
358 }
359
360 void setReadStat (hrtime_t rt, int64_t nb);
361
362 hrtime_t
363 getRSlowestBytes ()
364 {
365 return rSlowestBytes;
366 }
367
368 int64_t
369 getRSmallestBytes ()
370 {
371 return rSmallestBytes;
372 }
373
374 int64_t
375 getRLargestBytes ()
376 {
377 return rLargestBytes;
378 }
379
380 int32_t
381 getR0KB1KBCnt ()
382 {
383 return r0KB1KBCnt;
384 }
385
386 int32_t
387 getR1KB8KBCnt ()
388 {
389 return r1KB8KBCnt;
390 }
391
392 int32_t
393 getR8KB32KBCnt ()
394 {
395 return r8KB32KBCnt;
396 }
397
398 int32_t
399 getR32KB128KBCnt ()
400 {
401 return r32KB128KBCnt;
402 }
403
404 int32_t
405 getR128KB256KBCnt ()
406 {
407 return r128KB256KBCnt;
408 }
409
410 int32_t
411 getR256KB512KBCnt ()
412 {
413 return r256KB512KBCnt;
414 }
415
416 int32_t
417 getR512KB1000KBCnt ()
418 {
419 return r512KB1000KBCnt;
420 }
421
422 int32_t
423 getR1000KB10MBCnt ()
424 {
425 return r1000KB10MBCnt;
426 }
427
428 int32_t
429 getR10MB100MBCnt ()
430 {
431 return r10MB100MBCnt;
432 }
433
434 int32_t
435 getR100MB1GBCnt ()
436 {
437 return r100MB1GBCnt;
438 }
439
440 int32_t
441 getR1GB10GBCnt ()
442 {
443 return r1GB10GBCnt;
444 }
445
446 int32_t
447 getR10GB100GBCnt ()
448 {
449 return r10GB100GBCnt;
450 }
451
452 int32_t
453 getR100GB1TBCnt ()
454 {
455 return r100GB1TBCnt;
456 }
457
458 int32_t
459 getR1TB10TBCnt ()
460 {
461 return r1TB10TBCnt;
462 }
463
464 private:
465 char *fileName; // File name
466 hrtime_t readTime; // The Total time for read operations;
467 hrtime_t writeTime; // The Total time for write operations;
468 hrtime_t otherTime; // The Total time for other IO operations;
469 hrtime_t errorTime; // The Total time for failed IO operations;
470 int64_t readBytes; //The total bytes read
471 int64_t writeBytes; //The total bytes written
472 int32_t readCnt; // The read count
473 int32_t writeCnt; // The write count
474 int32_t otherCnt; // The other IO count
475 int32_t errorCnt; // The failed IO count
476 Vector<int> *fileDesList; // The list of file descriptors
477 Vector<int64_t> *virtualFds; // The list of file virtual descriptors
478 char fsType[FSTYPESZ]; // The file system type
479 int64_t virtualFd; // The virtual file descriptor
480 int32_t fileDes; // The file descriptor
481 Histable::Type histType; // The Histable type: IOACTFILE, IOACTVFD, ...
482
483 // Write statistics
484 hrtime_t wSlowestBytes;
485 int64_t wSmallestBytes;
486 int64_t wLargestBytes;
487 int32_t w0KB1KBCnt;
488 int32_t w1KB8KBCnt;
489 int32_t w8KB32KBCnt;
490 int32_t w32KB128KBCnt;
491 int32_t w128KB256KBCnt;
492 int32_t w256KB512KBCnt;
493 int32_t w512KB1000KBCnt;
494 int32_t w1000KB10MBCnt;
495 int32_t w10MB100MBCnt;
496 int32_t w100MB1GBCnt;
497 int32_t w1GB10GBCnt;
498 int32_t w10GB100GBCnt;
499 int32_t w100GB1TBCnt;
500 int32_t w1TB10TBCnt;
501
502 // Read statistics
503 hrtime_t rSlowestBytes;
504 int64_t rSmallestBytes;
505 int64_t rLargestBytes;
506 int32_t r0KB1KBCnt;
507 int32_t r1KB8KBCnt;
508 int32_t r8KB32KBCnt;
509 int32_t r32KB128KBCnt;
510 int32_t r128KB256KBCnt;
511 int32_t r256KB512KBCnt;
512 int32_t r512KB1000KBCnt;
513 int32_t r1000KB10MBCnt;
514 int32_t r10MB100MBCnt;
515 int32_t r100MB1GBCnt;
516 int32_t r1GB10GBCnt;
517 int32_t r10GB100GBCnt;
518 int32_t r100GB1TBCnt;
519 int32_t r1TB10TBCnt;
520 };
521
522 #endif