diff options
Diffstat (limited to 'src/dht/gnunet-service-dht_clients.c')
-rw-r--r-- | src/dht/gnunet-service-dht_clients.c | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c index aa2fd9462..29096b030 100644 --- a/src/dht/gnunet-service-dht_clients.c +++ b/src/dht/gnunet-service-dht_clients.c | |||
@@ -622,6 +622,9 @@ send_reply_to_client (void *cls, size_t size, void *buf) | |||
622 | if (buf == NULL) | 622 | if (buf == NULL) |
623 | { | 623 | { |
624 | /* client disconnected */ | 624 | /* client disconnected */ |
625 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
626 | "Client %p disconnected, pending messages will be discarded\n", | ||
627 | client->client_handle); | ||
625 | return 0; | 628 | return 0; |
626 | } | 629 | } |
627 | off = 0; | 630 | off = 0; |
@@ -632,6 +635,10 @@ send_reply_to_client (void *cls, size_t size, void *buf) | |||
632 | reply); | 635 | reply); |
633 | memcpy (&cbuf[off], reply->msg, msize); | 636 | memcpy (&cbuf[off], reply->msg, msize); |
634 | GNUNET_free (reply); | 637 | GNUNET_free (reply); |
638 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
639 | "Transmitting %u bytes to client %p\n", | ||
640 | msize, | ||
641 | client->client_handle); | ||
635 | off += msize; | 642 | off += msize; |
636 | } | 643 | } |
637 | process_pending_messages (client); | 644 | process_pending_messages (client); |
@@ -824,7 +831,7 @@ forward_reply (void *cls, const GNUNET_HashCode * key, void *value) | |||
824 | reply = (struct GNUNET_DHT_ClientResultMessage*) &pm[1]; | 831 | reply = (struct GNUNET_DHT_ClientResultMessage*) &pm[1]; |
825 | reply->unique_id = record->unique_id; | 832 | reply->unique_id = record->unique_id; |
826 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 833 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
827 | "Queueing reply to query %s for peer %p\n", | 834 | "Queueing reply to query %s for client %p\n", |
828 | GNUNET_h2s (key), | 835 | GNUNET_h2s (key), |
829 | record->client->client_handle); | 836 | record->client->client_handle); |
830 | add_pending_message (record->client, pm); | 837 | add_pending_message (record->client, pm); |