summaryrefslogtreecommitdiff
path: root/fedora/.local/bin/htop-vim/NetworkIOMeter.c
diff options
context:
space:
mode:
authorTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-28 15:42:50 +0900
committerTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-28 15:42:50 +0900
commitae78dbbff81196f1d7bc8fabf84d05e6b9f3ca03 (patch)
treefdc69ee3e2772aa4db7e8efe4bd30d101c7f82ac /fedora/.local/bin/htop-vim/NetworkIOMeter.c
parent06ad645351572c0e7188c52028998384d718df2e (diff)
updatesHEADmaster
Diffstat (limited to 'fedora/.local/bin/htop-vim/NetworkIOMeter.c')
-rw-r--r--fedora/.local/bin/htop-vim/NetworkIOMeter.c167
1 files changed, 0 insertions, 167 deletions
diff --git a/fedora/.local/bin/htop-vim/NetworkIOMeter.c b/fedora/.local/bin/htop-vim/NetworkIOMeter.c
deleted file mode 100644
index d41eafa..0000000
--- a/fedora/.local/bin/htop-vim/NetworkIOMeter.c
+++ /dev/null
@@ -1,167 +0,0 @@
-#include "NetworkIOMeter.h"
-
-#include <stdbool.h>
-#include <stdint.h>
-
-#include "CRT.h"
-#include "Macros.h"
-#include "Meter.h"
-#include "Object.h"
-#include "Platform.h"
-#include "Process.h"
-#include "ProcessList.h"
-#include "RichString.h"
-#include "XUtils.h"
-
-
-static const int NetworkIOMeter_attributes[] = {
- METER_VALUE_IOREAD,
- METER_VALUE_IOWRITE,
-};
-
-static MeterRateStatus status = RATESTATUS_INIT;
-static uint32_t cached_rxb_diff;
-static uint32_t cached_rxp_diff;
-static uint32_t cached_txb_diff;
-static uint32_t cached_txp_diff;
-
-static void NetworkIOMeter_updateValues(Meter* this) {
- const ProcessList* pl = this->pl;
- static uint64_t cached_last_update = 0;
-
- uint64_t passedTimeInMs = pl->realtimeMs - cached_last_update;
-
- /* update only every 500ms to have a sane span for rate calculation */
- if (passedTimeInMs > 500) {
- static uint64_t cached_rxb_total;
- static uint64_t cached_rxp_total;
- static uint64_t cached_txb_total;
- static uint64_t cached_txp_total;
- uint64_t diff;
-
- NetworkIOData data;
- if (!Platform_getNetworkIO(&data)) {
- status = RATESTATUS_NODATA;
- } else if (cached_last_update == 0) {
- status = RATESTATUS_INIT;
- } else if (passedTimeInMs > 30000) {
- status = RATESTATUS_STALE;
- } else {
- status = RATESTATUS_DATA;
- }
-
- cached_last_update = pl->realtimeMs;
-
- if (status == RATESTATUS_NODATA) {
- xSnprintf(this->txtBuffer, sizeof(this->txtBuffer), "no data");
- return;
- }
-
- if (data.bytesReceived > cached_rxb_total) {
- diff = data.bytesReceived - cached_rxb_total;
- diff = (1000 * diff) / passedTimeInMs; /* convert to B/s */
- diff /= ONE_K; /* convert to KiB/s */
- cached_rxb_diff = (uint32_t)diff;
- } else {
- cached_rxb_diff = 0;
- }
- cached_rxb_total = data.bytesReceived;
-
- if (data.packetsReceived > cached_rxp_total) {
- diff = data.packetsReceived - cached_rxp_total;
- diff = (1000 * diff) / passedTimeInMs; /* convert to B/s */
- cached_rxp_diff = (uint32_t)diff;
- } else {
- cached_rxp_diff = 0;
- }
- cached_rxp_total = data.packetsReceived;
-
- if (data.bytesTransmitted > cached_txb_total) {
- diff = data.bytesTransmitted - cached_txb_total;
- diff = (1000 * diff) / passedTimeInMs; /* convert to B/s */
- diff /= ONE_K; /* convert to KiB/s */
- cached_txb_diff = (uint32_t)diff;
- } else {
- cached_txb_diff = 0;
- }
- cached_txb_total = data.bytesTransmitted;
-
- if (data.packetsTransmitted > cached_txp_total) {
- diff = data.packetsTransmitted - cached_txp_total;
- diff = (1000 * diff) / passedTimeInMs; /* convert to B/s */
- cached_txp_diff = (uint32_t)diff;
- } else {
- cached_txp_diff = 0;
- }
- cached_txp_total = data.packetsTransmitted;
- }
-
- if (status == RATESTATUS_INIT) {
- xSnprintf(this->txtBuffer, sizeof(this->txtBuffer), "init");
- return;
- }
- if (status == RATESTATUS_STALE) {
- xSnprintf(this->txtBuffer, sizeof(this->txtBuffer), "stale");
- return;
- }
-
- this->values[0] = cached_rxb_diff;
- this->values[1] = cached_txb_diff;
- if (cached_rxb_diff + cached_txb_diff > this->total) {
- this->total = cached_rxb_diff + cached_txb_diff;
- }
-
- char bufferBytesReceived[12], bufferBytesTransmitted[12];
- Meter_humanUnit(bufferBytesReceived, cached_rxb_diff, sizeof(bufferBytesReceived));
- Meter_humanUnit(bufferBytesTransmitted, cached_txb_diff, sizeof(bufferBytesTransmitted));
- xSnprintf(this->txtBuffer, sizeof(this->txtBuffer), "rx:%siB/s tx:%siB/s %d/%dpkts/s",
- bufferBytesReceived, bufferBytesTransmitted, cached_rxp_diff, cached_txp_diff);
-}
-
-static void NetworkIOMeter_display(ATTR_UNUSED const Object* cast, RichString* out) {
- switch (status) {
- case RATESTATUS_NODATA:
- RichString_writeAscii(out, CRT_colors[METER_VALUE_ERROR], "no data");
- return;
- case RATESTATUS_INIT:
- RichString_writeAscii(out, CRT_colors[METER_VALUE], "initializing...");
- return;
- case RATESTATUS_STALE:
- RichString_writeAscii(out, CRT_colors[METER_VALUE_WARN], "stale data");
- return;
- case RATESTATUS_DATA:
- break;
- }
-
- char buffer[64];
- int len;
-
- RichString_writeAscii(out, CRT_colors[METER_TEXT], "rx: ");
- Meter_humanUnit(buffer, cached_rxb_diff, sizeof(buffer));
- RichString_appendAscii(out, CRT_colors[METER_VALUE_IOREAD], buffer);
- RichString_appendAscii(out, CRT_colors[METER_VALUE_IOREAD], "iB/s");
-
- RichString_appendAscii(out, CRT_colors[METER_TEXT], " tx: ");
- Meter_humanUnit(buffer, cached_txb_diff, sizeof(buffer));
- RichString_appendAscii(out, CRT_colors[METER_VALUE_IOWRITE], buffer);
- RichString_appendAscii(out, CRT_colors[METER_VALUE_IOWRITE], "iB/s");
-
- len = xSnprintf(buffer, sizeof(buffer), " (%u/%u pkts/s) ", cached_rxp_diff, cached_txp_diff);
- RichString_appendnAscii(out, CRT_colors[METER_TEXT], buffer, len);
-}
-
-const MeterClass NetworkIOMeter_class = {
- .super = {
- .extends = Class(Meter),
- .delete = Meter_delete,
- .display = NetworkIOMeter_display
- },
- .updateValues = NetworkIOMeter_updateValues,
- .defaultMode = TEXT_METERMODE,
- .maxItems = 2,
- .total = 100.0,
- .attributes = NetworkIOMeter_attributes,
- .name = "NetworkIO",
- .uiName = "Network IO",
- .caption = "Network: "
-};