diff options
Diffstat (limited to 'src/dv/dv_api.c')
-rw-r--r-- | src/dv/dv_api.c | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/dv/dv_api.c b/src/dv/dv_api.c index fff0896b3..dab7c7ad3 100644 --- a/src/dv/dv_api.c +++ b/src/dv/dv_api.c | |||
@@ -266,9 +266,10 @@ process_ack (void *cls, | |||
266 | GNUNET_CONTAINER_multihashmap_remove (ctx->sh->send_callbacks, | 266 | GNUNET_CONTAINER_multihashmap_remove (ctx->sh->send_callbacks, |
267 | key, | 267 | key, |
268 | th)); | 268 | th)); |
269 | /* FIXME: should distinguish between success and failure here... */ | ||
270 | th->cb (th->cb_cls, | 269 | th->cb (th->cb_cls, |
271 | GNUNET_OK); | 270 | (ntohs (ctx->ack->header.type) == GNUNET_MESSAGE_TYPE_DV_SEND_ACK) |
271 | ? GNUNET_OK | ||
272 | : GNUNET_SYSERR); | ||
272 | GNUNET_free (th); | 273 | GNUNET_free (th); |
273 | return GNUNET_NO; | 274 | return GNUNET_NO; |
274 | } | 275 | } |
@@ -345,6 +346,7 @@ handle_message_receipt (void *cls, | |||
345 | payload); | 346 | payload); |
346 | break; | 347 | break; |
347 | case GNUNET_MESSAGE_TYPE_DV_SEND_ACK: | 348 | case GNUNET_MESSAGE_TYPE_DV_SEND_ACK: |
349 | case GNUNET_MESSAGE_TYPE_DV_SEND_NACK: | ||
348 | if (ntohs (msg->size) != sizeof (struct GNUNET_DV_AckMessage)) | 350 | if (ntohs (msg->size) != sizeof (struct GNUNET_DV_AckMessage)) |
349 | { | 351 | { |
350 | GNUNET_break (0); | 352 | GNUNET_break (0); |
@@ -358,7 +360,10 @@ handle_message_receipt (void *cls, | |||
358 | &ack->target.hashPubKey, | 360 | &ack->target.hashPubKey, |
359 | &process_ack, | 361 | &process_ack, |
360 | &ctx); | 362 | &ctx); |
361 | return; | 363 | break; |
364 | case GNUNET_MESSAGE_TYPE_DV_DISTANCE_CHANGED: | ||
365 | GNUNET_break (0); | ||
366 | break; | ||
362 | default: | 367 | default: |
363 | reconnect (sh); | 368 | reconnect (sh); |
364 | break; | 369 | break; |