diff options
Diffstat (limited to 'src/transport/transport_api_monitoring.c')
-rw-r--r-- | src/transport/transport_api_monitoring.c | 8 |
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 | */ |
551 | static void | 554 | static void |
552 | peer_response_processor (void *cls, const struct GNUNET_MessageHeader *msg) | 555 | peer_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 | { |