github/darkfi
1
1
Fork 0
mirror of https://github.com/darkrenaissance/darkfi.git synced 2026-01-09 14:48:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

event_graph: fix broadcasted_ids issue when batch downloading events

Browse Source
This commit is contained in:
dasman
2025-09-10 01:59:31 +03:00
parent 7abdd3b0f7
commit 4a6bb97878
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/event_graph/proto.rs
View File

@@ -522,7 +522,7 @@ impl ProtocolEventGraph {
// reading our db and steal our bandwidth.
let mut events = vec![];
for event_id in event_ids.iter() {
/*if !self.event_graph.broadcasted_ids.read().await.contains(event_id) {
if !self.event_graph.header_dag.contains_key(event_id.as_bytes())? {
let malicious_count = self.malicious_count.fetch_add(1, SeqCst);
if malicious_count + 1 == MALICIOUS_THRESHOLD {
error!(
@@ -540,7 +540,7 @@ impl ProtocolEventGraph {
self.channel.address(), event_id,
);
continue
}*/
}
// At this point we should have it in our DAG.
// This code panics if this is not the case.
@@ -549,7 +549,12 @@ impl ProtocolEventGraph {
"Fetching event {:?} from DAG", event_id,
);
events.push(self.event_graph.dag_get(event_id).await?.ok_or(Error::EventNotFound("Event Not Found in DAG".to_owned()))?);
events.push(
self.event_graph
.dag_get(event_id)
.await?
.ok_or(Error::EventNotFound("Event Not Found in DAG".to_owned()))?,
);
}
// Check if the incoming event is older than the genesis event. If so, something