mirror/bbfdm
1
0
Fork 0
mirror of https://dev.iopsys.eu/bbf/bbfdm.git synced 2025-12-10 07:44:39 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Blacklist ubus object only in timed out

Browse source
This commit is contained in:
Suvendhu Hansa 2025-06-13 12:20:46 +05:30
parent 25e2d0bab6
commit ad2602f114
1 changed files with 6 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
libbbfdm-api/legacy/dmubus.c
View file

@ -236,13 +236,6 @@ static int __dm_ubus_call_sync_entry(struct dm_ubus_cache_entry *entry, const ch
if (ubus_lookup_id(ubus_ctx, obj, &id)) {
BBF_WARNING("Failed to lookup UBUS object ID for '%s' using method '%s'", obj, method);
entry->consecutive_timeouts++;
if (entry->consecutive_timeouts >= UBUS_MAX_CONSECUTIVE_TIMEOUTS) {
entry->is_blacklisted = true;
BBF_ERR("UBUS [object: %s, method: %s] has been blacklisted due to repeated timeouts", obj, method);
}
return -1;
}
@ -253,10 +246,12 @@ static int __dm_ubus_call_sync_entry(struct dm_ubus_cache_entry *entry, const ch
BBF_ERR("UBUS invoke failed [object: %s, method: %s, timeout: %d ms] with error (%s:%d)",
obj, method, timeout, err_msg, err);
entry->consecutive_timeouts++;
if (entry->consecutive_timeouts >= UBUS_MAX_CONSECUTIVE_TIMEOUTS) {
entry->is_blacklisted = true;
BBF_ERR("UBUS [object: %s, method: %s] has been blacklisted due to repeated timeouts", obj, method);
if (err == UBUS_STATUS_TIMEOUT) {
entry->consecutive_timeouts++;
if (entry->consecutive_timeouts >= UBUS_MAX_CONSECUTIVE_TIMEOUTS) {
entry->is_blacklisted = true;
BBF_ERR("UBUS [object: %s, method: %s] has been blacklisted due to repeated timeouts", obj, method);
}
}
} else {
entry->consecutive_timeouts = 0;