logos-co/nomos-node
1
0
Fork 0
mirror of synced 2025-02-19 11:17:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: have executors and validators in the same subnet_id = 0

Browse Source
This commit is contained in:
Roman 2024-10-23 18:26:28 +08:00
parent 3eeafc819c
commit 54e6939141
No known key found for this signature in database
GPG Key ID: B8FE070B54E11B75
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
nomos-da/network/core/src/protocols/dispersal/validator/behaviour.rs
View File

@ -363,8 +363,8 @@ mod tests {
.map(|(_, peer_id, addr)| (peer_id.clone(), addr.clone().with_p2p(peer_id.clone()).unwrap())), .map(|(_, peer_id, addr)| (peer_id.clone(), addr.clone().with_p2p(peer_id.clone()).unwrap())),
); );
let subnet_0_membership = create_membership(num_instances / 2, 1, &subnet_0_ids); let subnet_0_membership = create_membership(num_instances / 2, 0, &subnet_0_ids);
let subnet_1_membership = create_membership(num_instances / 2, 1, &subnet_1_ids); let subnet_1_membership = create_membership(num_instances / 2, 0, &subnet_1_ids);
let mut all_neighbours = subnet_0_membership; let mut all_neighbours = subnet_0_membership;
all_neighbours all_neighbours
@ -410,10 +410,7 @@ mod tests {
}; };
let join_validator = tokio::spawn(validator_task); let join_validator = tokio::spawn(validator_task);
//executor_swarms[0].dial(validator_addr_p2p).unwrap();
let executor_disperse_blob_sender = executor_swarms[0].behaviour().blobs_sender(); let executor_disperse_blob_sender = executor_swarms[0].behaviour().blobs_sender();
let executor_open_stream_sender = executor_swarms[0].behaviour().open_stream_sender();
let executor_poll = async move { let executor_poll = async move {
let mut res = vec![]; let mut res = vec![];
@ -426,7 +423,7 @@ mod tests {
} }
} }
_ = time::sleep(Duration::from_secs(20)) => { _ = time::sleep(Duration::from_secs(1)) => {
if res.len() < msg_count {error!("Executor timeout reached");} if res.len() < msg_count {error!("Executor timeout reached");}
break; break;
} }
@ -437,8 +434,6 @@ mod tests {
let executor_task = tokio::spawn(executor_poll); let executor_task = tokio::spawn(executor_poll);
//executor_open_stream_sender.send(validator_id).unwrap();
for i in 0..msg_count { for i in 0..msg_count {
info!("Sending blob {i}..."); info!("Sending blob {i}...");
executor_disperse_blob_sender executor_disperse_blob_sender