RPS test: Add another group for sub test

diff --git a/src/rps/test_rps.c b/src/rps/test_rps.c
index f26a9d4245397122bf4071cb229326b2837d4a86..1c98a1e5eafe81fb3c24146e2f8649d16a7c41c6 100644 (file)
--- a/src/rps/test_rps.c
+++ b/src/rps/test_rps.c
@@ -1578,6 +1578,14 @@ got_stream_peer_cb (void *cls,
       GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Received a peer id outside sub\n");
       ok = 1;
     }
+    else if (0 == rps_peer->index &&
+             0 != memcmp (&peers[i],
+                          &rps_peers[0].peer_id,
+                          sizeof (struct GNUNET_PeerIdentity)))
+    {
+      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Received a peer id outside sub (lonely)\n");
+      ok = 1;
+    }
   }
 }
 
@@ -1586,14 +1594,17 @@ static void
 sub_post (struct RPSPeer *rps_peer)
 {
   if (0 != rps_peer->index) GNUNET_RPS_sub_stop (rps_peer->rps_handle, "test");
+  else GNUNET_RPS_sub_stop (rps_peer->rps_handle, "lonely");
 }
 
+
 static void
 sub_pre (struct RPSPeer *rps_peer, struct GNUNET_RPS_Handle *h)
 {
   (void) rps_peer;
 
   if (0 != rps_peer->index) GNUNET_RPS_sub_start (h, "test");
+  else GNUNET_RPS_sub_start (h, "lonely"); /* have a group of one */
   rps_peer->rps_srh = GNUNET_RPS_stream_request (h,
                                                  0,
                                                  &got_stream_peer_cb,