[GNUnet-SVN] r35416 - gnunet/src/revocation

[gnunet]

Author: grothoff
Date: 2015-03-21 00:29:14 +0100 (Sat, 21 Mar 2015)
New Revision: 35416

Modified:
   gnunet/src/revocation/gnunet-service-revocation.c
Log:
fix #3721

Modified: gnunet/src/revocation/gnunet-service-revocation.c
===================================================================
--- gnunet/src/revocation/gnunet-service-revocation.c   2015-03-20 23:25:05 UTC 
(rev 35415)
+++ gnunet/src/revocation/gnunet-service-revocation.c   2015-03-20 23:29:14 UTC 
(rev 35416)
@@ -512,14 +512,27 @@
   struct GNUNET_HashCode my_hash;
   struct GNUNET_HashCode peer_hash;
 
-  if (0 == memcmp(peer,
-                  &my_identity,
-                  sizeof (my_identity)))
-      return;
+  if (0 == memcmp (peer,
+                   &my_identity,
+                   sizeof (my_identity)))
+  {
+    GNUNET_break (0);
+    return;
+  }
 
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Peer `%s' connected to us\n",
               GNUNET_i2s (peer));
+  peer_entry = GNUNET_CONTAINER_multipeermap_get (peers,
+                                                  peer);
+  if (NULL != peer_entry)
+  {
+    /* This can happen if "core"'s notification is a tad late
+       and CADET+SET were faster and already produced a
+       #handle_revocation_union_request() for us to deal
+       with.  This should be rare, but isn't impossible. */
+    return;
+  }
   peer_entry = GNUNET_new (struct PeerEntry);
   peer_entry->id = *peer;
   GNUNET_assert (GNUNET_OK ==
@@ -568,7 +581,10 @@
   if (0 == memcmp (peer,
                    &my_identity,
                    sizeof (my_identity)))
+  {
+    GNUNET_break (0);
     return;
+  }
 
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Peer `%s' disconnected from us\n",
@@ -728,7 +744,8 @@
     peer_entry = GNUNET_new (struct PeerEntry);
     peer_entry->id = *other_peer;
     GNUNET_assert (GNUNET_OK ==
-                   GNUNET_CONTAINER_multipeermap_put (peers, other_peer,
+                   GNUNET_CONTAINER_multipeermap_put (peers,
+                                                      other_peer,
                                                       peer_entry,
                                                       
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
   }