gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r36190 - gnunet/src/rps


From: gnunet
Subject: [GNUnet-SVN] r36190 - gnunet/src/rps
Date: Mon, 3 Aug 2015 14:06:34 +0200

Author: ch3
Date: 2015-08-03 14:06:34 +0200 (Mon, 03 Aug 2015)
New Revision: 36190

Modified:
   gnunet/src/rps/gnunet-service-rps.c
   gnunet/src/rps/rps_api.c
Log:
-logging and fix

Modified: gnunet/src/rps/gnunet-service-rps.c
===================================================================
--- gnunet/src/rps/gnunet-service-rps.c 2015-08-03 11:34:36 UTC (rev 36189)
+++ gnunet/src/rps/gnunet-service-rps.c 2015-08-03 12:06:34 UTC (rev 36190)
@@ -937,6 +937,9 @@
 {
   if (GNUNET_YES == GNUNET_CONTAINER_multipeermap_contains (view, peer))
       return;
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+      "Going to put %s into view\n",
+      GNUNET_i2s (peer));
   if (GNUNET_YES != GNUNET_CONTAINER_multipeermap_put (view,
         peer,
         NULL,
@@ -2166,6 +2169,9 @@
       else
         check_peer_live (peer_ctx);
     }
+    else
+      peer_ctx = create_peer_ctx (&attacked_peer);
+    check_peer_live (peer_ctx);
 
     /* The maximum of pushes we're going to send this round */
     num_pushes = GNUNET_MIN (GNUNET_MIN (push_limit - 1,

Modified: gnunet/src/rps/rps_api.c
===================================================================
--- gnunet/src/rps/rps_api.c    2015-08-03 11:34:36 UTC (rev 36189)
+++ gnunet/src/rps/rps_api.c    2015-08-03 12:06:34 UTC (rev 36190)
@@ -165,7 +165,7 @@
 {
   struct GNUNET_RPS_Handle *h = cls;
   //TODO LOG
-  LOG (GNUNET_ERROR_TYPE_WARNING, "Some problem with the message queue. error: 
%i\n\
+  LOG (GNUNET_ERROR_TYPE_WARNING, "Problem with message queue. error: %i\n\
        1: READ,\n\
        2: WRITE,\n\
        4: TIMEOUT\n",
@@ -426,7 +426,6 @@
        "Cancelling request with id %" PRIu32 "\n",
        rh->id);
 
-  GNUNET_array_append (req_handlers, req_handlers_size, *rh);
   ev = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_RPS_CS_REQUEST_CANCEL);
   msg->id = htonl (rh->id);
   GNUNET_MQ_send (rh->rps_handle->mq, ev);




reply via email to

[Prev in Thread] Current Thread [Next in Thread]