projects
/
dnsseed-rust
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
88eda27
)
Fix some printing for new rules
author
Matt Corallo
<git@bluematt.me>
Mon, 10 Jun 2019 10:21:07 +0000
(06:21 -0400)
committer
Matt Corallo
<git@bluematt.me>
Mon, 10 Jun 2019 10:21:59 +0000
(06:21 -0400)
src/main.rs
patch
|
blob
|
history
diff --git
a/src/main.rs
b/src/main.rs
index 11bce61bf5968589a145381f074aa5b522e4c6a1..a1d03d2b978533266f94c80f03d25e4196387c5b 100644
(file)
--- a/
src/main.rs
+++ b/
src/main.rs
@@
-202,7
+202,7
@@
pub fn scan_node(scan_time: Instant, node: SocketAddr, manual: bool) {
}
} else {
assert!(state_lock.fail_reason != AddressState::Good);
}
} else {
assert!(state_lock.fail_reason != AddressState::Good);
- if state_lock.fail_reason == AddressState::TimeoutDuringRequest && state_lock.recvd_version && state_lock.recvd_verack {
+ if state_lock.fail_reason == AddressState::TimeoutDuringRequest && state_lock.recvd_version && state_lock.recvd_verack
&& state_lock.recvd_pong
{
if !state_lock.recvd_addrs {
state_lock.fail_reason = AddressState::TimeoutAwaitingAddr;
} else if !state_lock.recvd_block {
if !state_lock.recvd_addrs {
state_lock.fail_reason = AddressState::TimeoutAwaitingAddr;
} else if !state_lock.recvd_block {
@@
-211,8
+211,8
@@
pub fn scan_node(scan_time: Instant, node: SocketAddr, manual: bool) {
}
let old_state = store.set_node_state(node, state_lock.fail_reason, 0);
if (manual || old_state != state_lock.fail_reason) && state_lock.fail_reason == AddressState::TimeoutDuringRequest {
}
let old_state = store.set_node_state(node, state_lock.fail_reason, 0);
if (manual || old_state != state_lock.fail_reason) && state_lock.fail_reason == AddressState::TimeoutDuringRequest {
- printer.add_line(format!("Updating {} from {} to Timeout During Request (ver: {}, vack: {})",
- node, old_state.to_str(), state_lock.recvd_version, state_lock.recvd_verack), true);
+ printer.add_line(format!("Updating {} from {} to Timeout During Request (ver: {}, vack: {}
, pong: {}
)",
+ node, old_state.to_str(), state_lock.recvd_version, state_lock.recvd_verack
, state_lock.recvd_pong
), true);
} else if manual || (old_state != state_lock.fail_reason && state_lock.msg.0 != "" && state_lock.msg.1) {
printer.add_line(format!("Updating {} from {} to {} {}", node, old_state.to_str(), state_lock.fail_reason.to_str(), &state_lock.msg.0), state_lock.msg.1);
}
} else if manual || (old_state != state_lock.fail_reason && state_lock.msg.0 != "" && state_lock.msg.1) {
printer.add_line(format!("Updating {} from {} to {} {}", node, old_state.to_str(), state_lock.fail_reason.to_str(), &state_lock.msg.0), state_lock.msg.1);
}