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

[gnunet]

Author: ch3
Date: 2015-03-17 14:05:58 +0100 (Tue, 17 Mar 2015)
New Revision: 35400

Modified:
   gnunet/src/rps/gnunet-service-rps.c
   gnunet/src/rps/rps_api.c
Log:
 -fixed issue with ntfy_tmt_rdy ()

Modified: gnunet/src/rps/gnunet-service-rps.c
===================================================================
--- gnunet/src/rps/gnunet-service-rps.c 2015-03-17 09:12:45 UTC (rev 35399)
+++ gnunet/src/rps/gnunet-service-rps.c 2015-03-17 13:05:58 UTC (rev 35400)
@@ -629,6 +629,12 @@
     GNUNET_array_grow (peer_ctx->outstanding_ops, 
peer_ctx->num_outstanding_ops, 0);
   }
 
+  if (NULL != peer_ctx->is_live_task)
+  {
+    GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task);
+    peer_ctx->is_live_task = NULL;
+  }
+
   return 0;
 }
 
@@ -645,7 +651,10 @@
 
   if (NULL != buf
       && 0 != size)
+  {
+    peer_ctx->is_live_task = NULL;
     peer_is_live (peer_ctx);
+  }
 
   //if (NULL != peer_ctx->is_live_task)
   //{
@@ -655,7 +664,6 @@
   //  GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task);
   //  peer_ctx->is_live_task = NULL;
   //}
-  peer_ctx->is_live_task = NULL;
 
   return 0;
 }
@@ -670,13 +678,13 @@
 {
   struct PeerContext *peer_ctx;
 
-  LOG (GNUNET_ERROR_TYPE_DEBUG,
-       "Trying to establish channel to peer %s\n",
-       GNUNET_i2s (peer));
-
   peer_ctx = get_peer_ctx (peer_map, peer);
   if (NULL == peer_ctx->send_channel)
   {
+    LOG (GNUNET_ERROR_TYPE_DEBUG,
+         "Trying to establish channel to peer %s\n",
+         GNUNET_i2s (peer));
+
     peer_ctx->send_channel =
       GNUNET_CADET_channel_create (cadet_handle,
                                    NULL,

Modified: gnunet/src/rps/rps_api.c
===================================================================
--- gnunet/src/rps/rps_api.c    2015-03-17 09:12:45 UTC (rev 35399)
+++ gnunet/src/rps/rps_api.c    2015-03-17 13:05:58 UTC (rev 35400)
@@ -155,6 +155,12 @@
 mq_error_handler (void *cls, enum GNUNET_MQ_Error error)
 {
   //TODO LOG
+  LOG (GNUNET_ERROR_TYPE_WARNING, "Some problem with the message queue. error: 
%i\n\
+       1: READ,\n\
+       2: WRITE,\n\
+       4: TIMEOUT\n",
+       error);
+
 }
 
 /**