diff options
| -rw-r--r-- | src/rps/gnunet-service-rps.c | 18 | ||||
| -rw-r--r-- | src/rps/rps_api.c | 6 |
2 files changed, 19 insertions, 5 deletions
diff --git a/src/rps/gnunet-service-rps.c b/src/rps/gnunet-service-rps.c index 61b0909791..455da399cd 100644 --- a/src/rps/gnunet-service-rps.c +++ b/src/rps/gnunet-service-rps.c @@ -629,6 +629,12 @@ peer_is_live (struct PeerContext *peer_ctx) 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 @@ cadet_ntfy_tmt_rdy_cb (void *cls, size_t size, void *buf) 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 @@ cadet_ntfy_tmt_rdy_cb (void *cls, size_t size, void *buf) // 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 @@ get_channel (struct GNUNET_CONTAINER_MultiPeerMap *peer_map, { 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, diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c index e848f91515..dad25f9be6 100644 --- a/src/rps/rps_api.c +++ b/src/rps/rps_api.c @@ -155,6 +155,12 @@ handle_reply (void *cls, 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); + } /** |