vecna
/
lox
mirror of https://gitlab.torproject.org/vecna/lox.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add more sensible process for db write_context testing

This commit is contained in:
onyinyang 2023-11-02 11:01:55 -04:00
parent 66f560eb08
commit 1ed629e233
4 changed files with 23 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
crates/lox-distributor/db_test_file.json Normal file
View File

File diff suppressed because one or more lines are too long

19
crates/lox-distributor/src/db_handler.rs
View File

File diff suppressed because one or more lines are too long

4
crates/lox-distributor/src/lox_context.rs
View File

@ -66,7 +66,7 @@ impl LoxServerContext {
let (bridgelines, blocked_bridgelines) = let (bridgelines, blocked_bridgelines) =
parse_into_bridgelines(watched_blockages, working_resources); parse_into_bridgelines(watched_blockages, working_resources);
for bridge in blocked_bridgelines { for bridge in blocked_bridgelines {
let res = self.add_unreachable(bridge); let res = self.mark_blocked(bridge);
if res { if res {
println!("BridgeLine {:?} successfully marked unreachable", bridge); println!("BridgeLine {:?} successfully marked unreachable", bridge);
self.metrics.blocked_bridges.inc(); self.metrics.blocked_bridges.inc();
@ -109,7 +109,7 @@ impl LoxServerContext {
let (grace_period, failing, blocked) = let (grace_period, failing, blocked) =
sort_for_parsing(watched_blockages, not_working_resources); sort_for_parsing(watched_blockages, not_working_resources);
for bridge in blocked { for bridge in blocked {
let res = self.add_unreachable(bridge); let res = self.mark_blocked(bridge);
if res { if res {
println!("BridgeLine {:?} successfully marked unreachable", bridge); println!("BridgeLine {:?} successfully marked unreachable", bridge);
self.metrics.blocked_bridges.inc(); self.metrics.blocked_bridges.inc();

6
crates/lox-distributor/src/resource_parser.rs
View File

@ -23,10 +23,8 @@ pub fn parse_into_bridgelines(
.expect("Unable to get Fingerprint UID of resource"); .expect("Unable to get Fingerprint UID of resource");
let infostr: String = format!( let infostr: String = format!(
"type={} fingerprint={:?} params={:?}", "type={} fingerprint={:?} params={:?}",
resource.r#type, resource.r#type, resource.fingerprint, resource.params,
resource.fingerprint, );
resource.params,
);
let mut info_bytes: [u8; BRIDGE_BYTES - 26] = [0; BRIDGE_BYTES - 26]; let mut info_bytes: [u8; BRIDGE_BYTES - 26] = [0; BRIDGE_BYTES - 26];
info_bytes[..infostr.len()].copy_from_slice(infostr.as_bytes()); info_bytes[..infostr.len()].copy_from_slice(infostr.as_bytes());