Skip to content
This repository has been archived by the owner on May 4, 2021. It is now read-only.

Commit

Permalink
Include headers about progress in all the bw files
Browse files Browse the repository at this point in the history
Include the headers about eligible relays in all the bandwidth
files, not only in the ones that does not have enough eligible
relays (#28365).
  • Loading branch information
juga0 committed Nov 8, 2018
1 parent 574a47d commit a011c93
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 5 deletions.
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
### Changed

- Change default directories when sbws is run from a system service (#28268).
- Include the headers about eligible relays in all the bandwidth files,
not only in the ones that does not have enough eligible relays (#28365).

## [1.0.0] - 2018-10-29

Expand Down
5 changes: 2 additions & 3 deletions sbws/lib/v3bwfile.py
Original file line number Diff line number Diff line change
Expand Up @@ -896,10 +896,9 @@ def update_progress(self, bw_lines, header, number_consensus_relays,
if number_consensus_relays is not None:
statsd, success = self.measured_progress_stats(
bw_lines, number_consensus_relays, min_perc_reached_before)
# add statistics about progress only when there are not enough
# measured relays. Should some stats be added always?
# add statistics about progress always
header.add_stats(**statsd)
if not success:
header.add_stats(**statsd)
bw_lines = []
state['min_perc_reached'] = None
else:
Expand Down
11 changes: 9 additions & 2 deletions tests/unit/lib/test_v3bwfile.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,8 @@
import os.path

from sbws import __version__ as version
from sbws.globals import SPEC_VERSION, SBWS_SCALING, TORFLOW_SCALING
from sbws.globals import (SPEC_VERSION, SBWS_SCALING, TORFLOW_SCALING,
MIN_REPORT)
from sbws.lib.resultdump import Result, load_result_file, ResultSuccess
from sbws.lib.v3bwfile import (V3BWHeader, V3BWLine, TERMINATOR, LINE_SEP,
KEYVALUE_SEP_V110, num_results_of_type,
Expand Down Expand Up @@ -234,9 +235,15 @@ def test_update_progress(datadir, tmpdir):
state)
assert header.percent_eligible_relays == '50'
assert state.get('min_perc_reached') is None
# Test that the headers are also included when there are enough eligible
# relays
number_consensus_relays = 3
header = V3BWHeader(str(now_unixts()))
bwfile.update_progress(bw_lines_raw, header, number_consensus_relays,
state)
assert state.get('min_perc_reached') == now_isodt_str()
assert not hasattr(header, 'percent_eligible_relays')
assert header.minimum_number_eligible_relays == '2'
assert header.minimum_percent_eligible_relays == str(MIN_REPORT)
assert header.number_consensus_relays == '3'
assert header.number_eligible_relays == '3'
assert header.percent_eligible_relays == '100'

0 comments on commit a011c93

Please sign in to comment.