Skip to content

Commit

Permalink
ah_wireless bug fixes
Browse files Browse the repository at this point in the history
This change contains:
1. Missed else part for min/max/avg logic for
few data items.
2. Added required padding for structs.
  • Loading branch information
chayan-04 committed Sep 26, 2024
1 parent c5d33ed commit b7e4598
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 0 deletions.
12 changes: 12 additions & 0 deletions plugins/inputs/ah_wireless/ah_wireless.go
Original file line number Diff line number Diff line change
Expand Up @@ -1342,10 +1342,14 @@ func Gather_AirTime(t *Ah_wireless, acc telegraf.Accumulator) error {

if ((clt_last_stats.tx_airtime_min > clt_item[cn].ns_tx_airtime) || (clt_last_stats.tx_airtime_min == 0) ) {
clt_new_stats.tx_airtime_min = clt_item[cn].ns_tx_airtime - clt_last_stats.tx_airtime
} else {
clt_new_stats.tx_airtime_min = clt_last_stats.tx_airtime_min
}

if (clt_last_stats.tx_airtime_max < clt_item[cn].ns_tx_airtime ) {
clt_new_stats.tx_airtime_max = clt_item[cn].ns_tx_airtime - clt_last_stats.tx_airtime
} else {
clt_new_stats.tx_airtime_max = clt_last_stats.tx_airtime_max
}

clt_new_stats.tx_airtime_average = ((clt_last_stats.tx_airtime_average + clt_new_stats.tx_airtime_min + clt_new_stats.tx_airtime_max)/3)
Expand All @@ -1354,10 +1358,14 @@ func Gather_AirTime(t *Ah_wireless, acc telegraf.Accumulator) error {

if ((clt_last_stats.rx_airtime_min > clt_item[cn].ns_rx_airtime) || (clt_last_stats.rx_airtime_min == 0) ) {
clt_new_stats.rx_airtime_min = clt_item[cn].ns_rx_airtime - clt_last_stats.rx_airtime
} else {
clt_new_stats.rx_airtime_min = clt_last_stats.rx_airtime_min
}

if (clt_last_stats.rx_airtime_max < clt_item[cn].ns_rx_airtime ) {
clt_new_stats.rx_airtime_max = clt_item[cn].ns_rx_airtime - clt_last_stats.rx_airtime
} else {
clt_new_stats.rx_airtime_max = clt_last_stats.rx_airtime_max
}

clt_new_stats.rx_airtime_average = ((clt_last_stats.rx_airtime_average + clt_new_stats.rx_airtime_min + clt_new_stats.rx_airtime_max)/3)
Expand All @@ -1368,10 +1376,14 @@ func Gather_AirTime(t *Ah_wireless, acc telegraf.Accumulator) error {

if ((clt_last_stats.bw_usage_min > bw_usage) || (clt_last_stats.bw_usage_min == 0)) {
clt_new_stats.bw_usage_min = bw_usage
} else {
clt_new_stats.bw_usage_min = clt_last_stats.bw_usage_min
}

if (clt_last_stats.bw_usage_max < bw_usage) {
clt_new_stats.bw_usage_max = bw_usage
} else {
clt_new_stats.bw_usage_max = clt_last_stats.bw_usage_max
}

clt_new_stats.bw_usage_average = ((clt_last_stats.bw_usage_average + clt_new_stats.bw_usage_min + clt_new_stats.bw_usage_max)/3)
Expand Down
2 changes: 2 additions & 0 deletions plugins/inputs/ah_wireless/ah_wireless_defines.go
Original file line number Diff line number Diff line change
Expand Up @@ -716,11 +716,13 @@ type ah_ieee80211_sta_info struct {
rssi int32
tx_ratekbps int32
tx_pkts uint32
pad1 [4]byte
tx_bytes uint64
rx_ratekbps int32
rx_pkts uint32
rx_bytes uint64
bw uint32
pad2 [4]byte
}

type ieee80211req_cfg_one_sta struct{
Expand Down

0 comments on commit b7e4598

Please sign in to comment.