aboutsummaryrefslogtreecommitdiff
path: root/src/dv/dv_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dv/dv_api.c')
-rw-r--r--src/dv/dv_api.c11
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;