[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);
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r36190 - gnunet/src/rps,
gnunet <=