aboutsummaryrefslogtreecommitdiff
path: root/src/rps/test_rps_multipeer.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/rps/test_rps_multipeer.c')
-rw-r--r--src/rps/test_rps_multipeer.c9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/rps/test_rps_multipeer.c b/src/rps/test_rps_multipeer.c
index 2a55eb49b..76e2fb2a9 100644
--- a/src/rps/test_rps_multipeer.c
+++ b/src/rps/test_rps_multipeer.c
@@ -121,8 +121,10 @@ request_peers (void *cls,
121 const struct GNUNET_SCHEDULER_TaskContext *tc) 121 const struct GNUNET_SCHEDULER_TaskContext *tc)
122{ 122{
123 struct RPSPeer *peer = (struct RPSPeer *) cls; 123 struct RPSPeer *peer = (struct RPSPeer *) cls;
124 struct GNUNET_RPS_Request_Handle *req_handle;
124 125
125 GNUNET_RPS_request_peers (peer->rps_handle, 1, handle_reply, NULL); 126 req_handle = GNUNET_RPS_request_peers (peer->rps_handle, 1, handle_reply, NULL);
127 GNUNET_free (req_handle);
126} 128}
127 129
128 130
@@ -187,6 +189,8 @@ rps_connect_complete_cb (void *cls,
187{ 189{
188 struct RPSPeer *peer = cls; 190 struct RPSPeer *peer = cls;
189 struct GNUNET_RPS_Handle *rps = ca_result; 191 struct GNUNET_RPS_Handle *rps = ca_result;
192 struct GNUNET_RPS_Request_Handle *req_handle;
193
190 peer->rps_handle = rps; 194 peer->rps_handle = rps;
191 195
192 GNUNET_assert (op == peer->op); 196 GNUNET_assert (op == peer->op);
@@ -201,7 +205,8 @@ rps_connect_complete_cb (void *cls,
201 } 205 }
202 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Started client successfully\n"); 206 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Started client successfully\n");
203 207
204 GNUNET_RPS_request_peers (rps, 1, handle_reply, NULL); 208 req_handle = GNUNET_RPS_request_peers (rps, 1, handle_reply, NULL);
209 GNUNET_free (req_handle);
205 210
206 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 10), 211 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 10),
207 request_peers, peer); 212 request_peers, peer);