diff options
author | Julius Bünger <buenger@mytum.de> | 2015-03-17 13:05:58 +0000 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2015-03-17 13:05:58 +0000 |
commit | c99b7b016fc341be3d90234aaa4d785376a9116d (patch) | |
tree | 5b3a80f5083cee5a1ee902ffc19e64df913aa496 /src | |
parent | b2525ab006d7df86c40f6e7bab87bb112d58f010 (diff) | |
download | gnunet-c99b7b016fc341be3d90234aaa4d785376a9116d.tar.gz gnunet-c99b7b016fc341be3d90234aaa4d785376a9116d.zip |
-fixed issue with ntfy_tmt_rdy ()
Diffstat (limited to 'src')
-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 61b090979..455da399c 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) | |||
629 | GNUNET_array_grow (peer_ctx->outstanding_ops, peer_ctx->num_outstanding_ops, 0); | 629 | GNUNET_array_grow (peer_ctx->outstanding_ops, peer_ctx->num_outstanding_ops, 0); |
630 | } | 630 | } |
631 | 631 | ||
632 | if (NULL != peer_ctx->is_live_task) | ||
633 | { | ||
634 | GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task); | ||
635 | peer_ctx->is_live_task = NULL; | ||
636 | } | ||
637 | |||
632 | return 0; | 638 | return 0; |
633 | } | 639 | } |
634 | 640 | ||
@@ -645,7 +651,10 @@ cadet_ntfy_tmt_rdy_cb (void *cls, size_t size, void *buf) | |||
645 | 651 | ||
646 | if (NULL != buf | 652 | if (NULL != buf |
647 | && 0 != size) | 653 | && 0 != size) |
654 | { | ||
655 | peer_ctx->is_live_task = NULL; | ||
648 | peer_is_live (peer_ctx); | 656 | peer_is_live (peer_ctx); |
657 | } | ||
649 | 658 | ||
650 | //if (NULL != peer_ctx->is_live_task) | 659 | //if (NULL != peer_ctx->is_live_task) |
651 | //{ | 660 | //{ |
@@ -655,7 +664,6 @@ cadet_ntfy_tmt_rdy_cb (void *cls, size_t size, void *buf) | |||
655 | // GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task); | 664 | // GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task); |
656 | // peer_ctx->is_live_task = NULL; | 665 | // peer_ctx->is_live_task = NULL; |
657 | //} | 666 | //} |
658 | peer_ctx->is_live_task = NULL; | ||
659 | 667 | ||
660 | return 0; | 668 | return 0; |
661 | } | 669 | } |
@@ -670,13 +678,13 @@ get_channel (struct GNUNET_CONTAINER_MultiPeerMap *peer_map, | |||
670 | { | 678 | { |
671 | struct PeerContext *peer_ctx; | 679 | struct PeerContext *peer_ctx; |
672 | 680 | ||
673 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
674 | "Trying to establish channel to peer %s\n", | ||
675 | GNUNET_i2s (peer)); | ||
676 | |||
677 | peer_ctx = get_peer_ctx (peer_map, peer); | 681 | peer_ctx = get_peer_ctx (peer_map, peer); |
678 | if (NULL == peer_ctx->send_channel) | 682 | if (NULL == peer_ctx->send_channel) |
679 | { | 683 | { |
684 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
685 | "Trying to establish channel to peer %s\n", | ||
686 | GNUNET_i2s (peer)); | ||
687 | |||
680 | peer_ctx->send_channel = | 688 | peer_ctx->send_channel = |
681 | GNUNET_CADET_channel_create (cadet_handle, | 689 | GNUNET_CADET_channel_create (cadet_handle, |
682 | NULL, | 690 | NULL, |
diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c index e848f9151..dad25f9be 100644 --- a/src/rps/rps_api.c +++ b/src/rps/rps_api.c | |||
@@ -155,6 +155,12 @@ handle_reply (void *cls, | |||
155 | mq_error_handler (void *cls, enum GNUNET_MQ_Error error) | 155 | mq_error_handler (void *cls, enum GNUNET_MQ_Error error) |
156 | { | 156 | { |
157 | //TODO LOG | 157 | //TODO LOG |
158 | LOG (GNUNET_ERROR_TYPE_WARNING, "Some problem with the message queue. error: %i\n\ | ||
159 | 1: READ,\n\ | ||
160 | 2: WRITE,\n\ | ||
161 | 4: TIMEOUT\n", | ||
162 | error); | ||
163 | |||
158 | } | 164 | } |
159 | 165 | ||
160 | /** | 166 | /** |