diff options
-rw-r--r-- | src/dht/gnunet-service-dht.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c index 745392456..299d90d81 100644 --- a/src/dht/gnunet-service-dht.c +++ b/src/dht/gnunet-service-dht.c | |||
@@ -1049,9 +1049,11 @@ try_core_send (void *cls, | |||
1049 | reply_counter++; | 1049 | reply_counter++; |
1050 | if (reply_counter >= MAX_REPLY_TIMES) | 1050 | if (reply_counter >= MAX_REPLY_TIMES) |
1051 | reply_counter = 0; | 1051 | reply_counter = 0; |
1052 | peer->th = GNUNET_CORE_notify_transmit_ready(coreAPI, pending->importance, | 1052 | peer->th = GNUNET_CORE_notify_transmit_ready (coreAPI, pending->importance, |
1053 | pending->timeout, &peer->id, | 1053 | pending->timeout, &peer->id, |
1054 | ssize, &core_transmit_notify, peer); | 1054 | ssize, &core_transmit_notify, peer); |
1055 | if (peer->th == NULL) | ||
1056 | increment_stats("# notify transmit ready failed"); | ||
1055 | } | 1057 | } |
1056 | } | 1058 | } |
1057 | 1059 | ||
@@ -3600,7 +3602,7 @@ route_message(const struct GNUNET_MessageHeader *msg, | |||
3600 | &selected->id); | 3602 | &selected->id); |
3601 | } | 3603 | } |
3602 | #endif | 3604 | #endif |
3603 | forward_message(msg, selected, msg_ctx); | 3605 | forward_message (msg, selected, msg_ctx); |
3604 | } | 3606 | } |
3605 | } | 3607 | } |
3606 | 3608 | ||