aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport_api_monitoring.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/transport_api_monitoring.c')
-rw-r--r--src/transport/transport_api_monitoring.c8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/transport/transport_api_monitoring.c b/src/transport/transport_api_monitoring.c
index 624ed4f74..371a5f568 100644
--- a/src/transport/transport_api_monitoring.c
+++ b/src/transport/transport_api_monitoring.c
@@ -339,6 +339,9 @@ reconnect_peer_ctx (struct GNUNET_TRANSPORT_PeerMonitoringContext *pal_ctx)
339 GNUNET_assert (GNUNET_NO == pal_ctx->one_shot); 339 GNUNET_assert (GNUNET_NO == pal_ctx->one_shot);
340 GNUNET_CLIENT_disconnect (pal_ctx->client); 340 GNUNET_CLIENT_disconnect (pal_ctx->client);
341 pal_ctx->client = NULL; 341 pal_ctx->client = NULL;
342 pal_ctx->cb (pal_ctx->cb_cls, NULL, NULL,
343 GNUNET_TRANSPORT_PS_NOT_CONNECTED,
344 GNUNET_TIME_UNIT_ZERO_ABS);
342 pal_ctx->backoff = GNUNET_TIME_STD_BACKOFF (pal_ctx->backoff); 345 pal_ctx->backoff = GNUNET_TIME_STD_BACKOFF (pal_ctx->backoff);
343 pal_ctx->reconnect_task = GNUNET_SCHEDULER_add_delayed (pal_ctx->backoff, 346 pal_ctx->reconnect_task = GNUNET_SCHEDULER_add_delayed (pal_ctx->backoff,
344 &do_peer_connect, 347 &do_peer_connect,
@@ -549,7 +552,8 @@ val_response_processor (void *cls, const struct GNUNET_MessageHeader *msg)
549 * message with the human-readable address 552 * message with the human-readable address
550 */ 553 */
551static void 554static void
552peer_response_processor (void *cls, const struct GNUNET_MessageHeader *msg) 555peer_response_processor (void *cls,
556 const struct GNUNET_MessageHeader *msg)
553{ 557{
554 struct GNUNET_TRANSPORT_PeerMonitoringContext *pal_ctx = cls; 558 struct GNUNET_TRANSPORT_PeerMonitoringContext *pal_ctx = cls;
555 struct PeerIterateResponseMessage *pir_msg; 559 struct PeerIterateResponseMessage *pir_msg;
@@ -560,7 +564,7 @@ peer_response_processor (void *cls, const struct GNUNET_MessageHeader *msg)
560 size_t alen; 564 size_t alen;
561 size_t tlen; 565 size_t tlen;
562 566
563 if (msg == NULL) 567 if (NULL == msg)
564 { 568 {
565 if (pal_ctx->one_shot) 569 if (pal_ctx->one_shot)
566 { 570 {