1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
crate::ix!();
impl PeerManager {
pub fn process_wtxidrelay_message(
self: Arc<Self>,
peer: &Option<Peer>,
pfrom: &mut AmoWriteGuard<Box<dyn NodeInterface>>,
msg_type: &str,
recv: &mut DataStream,
time_received: &OffsetDateTime ,
interrupt_msg_proc: &AtomicBool) {
if pfrom.is_successfully_connected() {
log_print!(
LogFlags::NET,
"wtxidrelay received after verack from peer=%d; disconnecting\n",
pfrom.get_id()
);
pfrom.mark_for_disconnect();
return;
}
if pfrom.get_common_version() >= WTXID_RELAY_VERSION {
let mut main_guard = CS_MAIN.lock();
let cstate = create_state(pfrom.get_id());
let state = cstate.get();
if !state.wtxid_relay.load(atomic::Ordering::Relaxed)
{
let cstate = create_state(pfrom.get_id());
let state = cstate.get();
state.wtxid_relay.store(true, atomic::Ordering::Relaxed);
self.inner.lock().wtxid_relay_peers.fetch_add(1, atomic::Ordering::Relaxed);
} else {
log_print!(
LogFlags::NET,
"ignoring duplicate wtxidrelay from peer=%d\n",
pfrom.get_id()
);
}
} else {
log_print!(
LogFlags::NET,
"ignoring wtxidrelay due to old common version=%d from peer=%d\n",
pfrom.get_common_version(),
pfrom.get_id()
);
}
}
}