From 54e693914141fbde186203bc0c39124d06dbda14 Mon Sep 17 00:00:00 2001 From: Roman Date: Wed, 23 Oct 2024 18:26:28 +0800 Subject: [PATCH] fix: have executors and validators in the same subnet_id = 0 --- .../src/protocols/dispersal/validator/behaviour.rs | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/nomos-da/network/core/src/protocols/dispersal/validator/behaviour.rs b/nomos-da/network/core/src/protocols/dispersal/validator/behaviour.rs index 87589913..d2ef4554 100644 --- a/nomos-da/network/core/src/protocols/dispersal/validator/behaviour.rs +++ b/nomos-da/network/core/src/protocols/dispersal/validator/behaviour.rs @@ -363,8 +363,8 @@ mod tests { .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_1_membership = create_membership(num_instances / 2, 1, &subnet_1_ids); + let subnet_0_membership = create_membership(num_instances / 2, 0, &subnet_0_ids); + let subnet_1_membership = create_membership(num_instances / 2, 0, &subnet_1_ids); let mut all_neighbours = subnet_0_membership; all_neighbours @@ -410,10 +410,7 @@ mod tests { }; 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_open_stream_sender = executor_swarms[0].behaviour().open_stream_sender(); let executor_poll = async move { 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");} break; } @@ -437,8 +434,6 @@ mod tests { let executor_task = tokio::spawn(executor_poll); - //executor_open_stream_sender.send(validator_id).unwrap(); - for i in 0..msg_count { info!("Sending blob {i}..."); executor_disperse_blob_sender