From ea51d048c44b83c679ba22978a3a4b0ff1bf12b5 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Julius=20B=C3=BCnger?= Date: Wed, 4 Apr 2018 08:45:17 +0200 Subject: [PATCH] rps tests: connect to all services --- src/rps/test_rps.c | 24 +++++++++--------------- 1 file changed, 9 insertions(+), 15 deletions(-) diff --git a/src/rps/test_rps.c b/src/rps/test_rps.c index 05902f037..660ac541a 100644 --- a/src/rps/test_rps.c +++ b/src/rps/test_rps.c @@ -2311,7 +2311,6 @@ run (void *cls, { unsigned int i; struct OpListEntry *entry; - uint32_t num_mal_peers; GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "RUN was called\n"); @@ -2352,24 +2351,19 @@ run (void *cls, } /* Bring peers up */ - num_mal_peers = round (portion * num_peers); GNUNET_assert (num_peers == n_peers); for (i = 0; i < n_peers; i++) { rps_peers[i].index = i; - if ( (rps_peers[i].num_recv_ids < rps_peers[i].num_ids_to_request) || - (i < num_mal_peers) ) - { - rps_peers[i].op = - GNUNET_TESTBED_service_connect (&rps_peers[i], - peers[i], - "rps", - &rps_connect_complete_cb, - &rps_peers[i], - &rps_connect_adapter, - &rps_disconnect_adapter, - &rps_peers[i]); - } + rps_peers[i].op = + GNUNET_TESTBED_service_connect (&rps_peers[i], + peers[i], + "rps", + &rps_connect_complete_cb, + &rps_peers[i], + &rps_connect_adapter, + &rps_disconnect_adapter, + &rps_peers[i]); /* Connect all peers to statistics service */ if (COLLECT_STATISTICS == cur_test_run.have_collect_statistics) { -- 2.25.1