diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-06-16 12:58:43 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-06-16 12:58:43 +0000 |
commit | 93cb17b80c96217bfbbb912c26d7ac7f4edb9e3c (patch) | |
tree | 44ac3560154ad83e56d05a7e4b155fcdb4c71cc5 | |
parent | 33cbde487152c775a38628ae7b12e8f5e8040a52 (diff) | |
download | gnunet-93cb17b80c96217bfbbb912c26d7ac7f4edb9e3c.tar.gz gnunet-93cb17b80c96217bfbbb912c26d7ac7f4edb9e3c.zip |
dnc
-rw-r--r-- | src/datastore/datastore_api.c | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 2ce58e8fb..6eafbee8b 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -1295,7 +1295,18 @@ process_result_message (void *cls, | |||
1295 | } | 1295 | } |
1296 | qe = h->queue_head; | 1296 | qe = h->queue_head; |
1297 | rc = qe->qc.rc; | 1297 | rc = qe->qc.rc; |
1298 | GNUNET_assert (GNUNET_YES == qe->was_transmitted); | 1298 | if (GNUNET_YES != qe->was_transmitted) |
1299 | { | ||
1300 | GNUNET_break (0); | ||
1301 | free_queue_entry (qe); | ||
1302 | h->retry_time = GNUNET_TIME_UNIT_ZERO; | ||
1303 | do_disconnect (h); | ||
1304 | if (rc.proc != NULL) | ||
1305 | rc.proc (rc.proc_cls, | ||
1306 | NULL, 0, NULL, 0, 0, 0, | ||
1307 | GNUNET_TIME_UNIT_ZERO_ABS, 0); | ||
1308 | return; | ||
1309 | } | ||
1299 | if ( (ntohs(msg->size) < sizeof(struct DataMessage)) || | 1310 | if ( (ntohs(msg->size) < sizeof(struct DataMessage)) || |
1300 | (ntohs(msg->type) != GNUNET_MESSAGE_TYPE_DATASTORE_DATA) || | 1311 | (ntohs(msg->type) != GNUNET_MESSAGE_TYPE_DATASTORE_DATA) || |
1301 | (ntohs(msg->size) != sizeof(struct DataMessage) + ntohl (((const struct DataMessage*)msg)->size)) ) | 1312 | (ntohs(msg->size) != sizeof(struct DataMessage) + ntohl (((const struct DataMessage*)msg)->size)) ) |