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 /src/datastore | |
| parent | 33cbde487152c775a38628ae7b12e8f5e8040a52 (diff) | |
| download | gnunet-93cb17b80c96217bfbbb912c26d7ac7f4edb9e3c.tar.gz gnunet-93cb17b80c96217bfbbb912c26d7ac7f4edb9e3c.zip | |
dnc
Diffstat (limited to 'src/datastore')
| -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)) ) |