commit d56ec60c41e48381da7ee3b9d52f94cb6fe2f50e Author: juga0 juga@riseup.net Date: Tue Jun 19 19:48:33 2018 +0000
Change args' names for reseting bw on IP changes
to be more descriptive. Also default them to False. --- sbws/core/generate.py | 5 +++-- sbws/lib/resultdump.py | 21 +++++++++++++-------- 2 files changed, 16 insertions(+), 10 deletions(-)
diff --git a/sbws/core/generate.py b/sbws/core/generate.py index 69c224d..827058e 100644 --- a/sbws/core/generate.py +++ b/sbws/core/generate.py @@ -74,8 +74,9 @@ def main(args, conf): reset_bw_ipv4_changes = conf.getboolean('general', 'reset_bw_ipv4_changes') reset_bw_ipv6_changes = conf.getboolean('general', 'reset_bw_ipv6_changes') results = load_recent_results_in_datadir( - fresh_days, datadir, success_only=True, ipv4=reset_bw_ipv4_changes, - ipv6=reset_bw_ipv6_changes) + fresh_days, datadir, success_only=True, + on_changed_ipv4=reset_bw_ipv4_changes, + on_changed_ipv6=reset_bw_ipv6_changes) if len(results) < 1: log.warning('No recent results, so not generating anything. (Have you ' 'ran sbws scanner recently?)') diff --git a/sbws/lib/resultdump.py b/sbws/lib/resultdump.py index 2124cec..02945fa 100644 --- a/sbws/lib/resultdump.py +++ b/sbws/lib/resultdump.py @@ -82,20 +82,23 @@ def trim_results(fresh_days, result_dict): return out_results
-def trim_results_ip_changed(result_dict, ipv4=True, ipv6=False): +def trim_results_ip_changed(result_dict, on_changed_ipv4=False, + on_changed_ipv6=False): """When there are results for the same relay with different IPs, create a new results' dictionary without that relay's results using an older IP.
:param dict result_dict: a dictionary of results - :param bool ipv4: whether to trim the results when a relay's IPv4 changes - :param bool ipv6: whether to trim the results when a relay's IPv6 changes + :param bool on_changed_ipv4: whether to trim the results when a relay's + IPv4 changes + :param bool on_changed_ipv6: whether to trim the results when a relay's + IPv6 changes :returns: a new results dictionary """ assert isinstance(result_dict, dict) - assert ipv4 is True or ipv6 is True + assert on_changed_ipv4 is True or on_changed_ipv6 is True new_results_dict = {} - if ipv4 is True: + if on_changed_ipv4 is True: for fp in result_dict.keys(): results = result_dict[fp] # find if the results for a relay have more than one ipv4 @@ -112,14 +115,15 @@ def trim_results_ip_changed(result_dict, ipv4=True, ipv6=False): new_results_dict[fp] = last_ip_results else: new_results_dict[fp] = results - if ipv6 is True: + if on_changed_ipv6 is True: # Not implemented pass return new_results_dict
def load_recent_results_in_datadir(fresh_days, datadir, success_only=False, - ipv4=True, ipv6=False): + on_changed_ipv4=False, + on_changed_ipv6=False): ''' Given a data directory, read all results files in it that could have results in them that are still valid. Trim them, and return the valid Results as a list ''' @@ -146,7 +150,8 @@ def load_recent_results_in_datadir(fresh_days, datadir, success_only=False, results = trim_results(fresh_days, results) # in time fresh days is possible that a relay changed ip, # if that's the case, keep only the results for the last ip - results = trim_results_ip_changed(results, ipv4, ipv6) + results = trim_results_ip_changed(results, on_changed_ipv4, + on_changed_ipv6) num_res = sum([len(results[fp]) for fp in results]) if num_res == 0: log.warning('Results files that are valid not found. '