()
| 240 | time.sleep(INTERVAL) |
| 241 | |
| 242 | def _net_speed(): |
| 243 | while True: |
| 244 | with open("/proc/net/dev", "r") as f: |
| 245 | net_dev = f.readlines() |
| 246 | avgrx = 0 |
| 247 | avgtx = 0 |
| 248 | for dev in net_dev[2:]: |
| 249 | dev = dev.split(':') |
| 250 | if "lo" in dev[0] or "tun" in dev[0] \ |
| 251 | or "docker" in dev[0] or "veth" in dev[0] \ |
| 252 | or "br-" in dev[0] or "vmbr" in dev[0] \ |
| 253 | or "vnet" in dev[0] or "kube" in dev[0]: |
| 254 | continue |
| 255 | dev = dev[1].split() |
| 256 | avgrx += int(dev[0]) |
| 257 | avgtx += int(dev[8]) |
| 258 | now_clock = time.time() |
| 259 | netSpeed["diff"] = now_clock - netSpeed["clock"] |
| 260 | netSpeed["clock"] = now_clock |
| 261 | netSpeed["netrx"] = int((avgrx - netSpeed["avgrx"]) / netSpeed["diff"]) |
| 262 | netSpeed["nettx"] = int((avgtx - netSpeed["avgtx"]) / netSpeed["diff"]) |
| 263 | netSpeed["avgrx"] = avgrx |
| 264 | netSpeed["avgtx"] = avgtx |
| 265 | time.sleep(INTERVAL) |
| 266 | |
| 267 | def _disk_io(): |
| 268 | ''' |
nothing calls this directly
no outgoing calls
no test coverage detected