diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-01-25 13:05:23 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-01-25 13:05:23 +0000 |
commit | d5613dec791f437441a351973b283196b278763d (patch) | |
tree | e8aa3fe409ef5d055109607ef3e5479434bbcb07 /src/datastore/datastore_api.c | |
parent | 8ab3f5bf4b9335429a06752b18de80698883321d (diff) | |
download | gnunet-d5613dec791f437441a351973b283196b278763d.tar.gz gnunet-d5613dec791f437441a351973b283196b278763d.zip |
-style
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 8ff96d639..fab3bf0ca 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -393,7 +393,7 @@ timeout_queue_entry (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
393 | gettext_noop ("# queue entry timeouts"), 1, | 393 | gettext_noop ("# queue entry timeouts"), 1, |
394 | GNUNET_NO); | 394 | GNUNET_NO); |
395 | qe->task = GNUNET_SCHEDULER_NO_TASK; | 395 | qe->task = GNUNET_SCHEDULER_NO_TASK; |
396 | GNUNET_assert (qe->was_transmitted == GNUNET_NO); | 396 | GNUNET_assert (GNUNET_NO == qe->was_transmitted); |
397 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Timeout of request in datastore queue\n"); | 397 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Timeout of request in datastore queue\n"); |
398 | qe->response_proc (qe->h, NULL); | 398 | qe->response_proc (qe->h, NULL); |
399 | } | 399 | } |
@@ -475,7 +475,7 @@ make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize, | |||
475 | GNUNET_assert (pos->response_proc != NULL); | 475 | GNUNET_assert (pos->response_proc != NULL); |
476 | /* move 'pos' element to head so that it will be | 476 | /* move 'pos' element to head so that it will be |
477 | * killed on 'NULL' call below */ | 477 | * killed on 'NULL' call below */ |
478 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Dropping request from datastore queue\n"); | 478 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Dropping request from datastore queue\n"); |
479 | GNUNET_CONTAINER_DLL_remove (h->queue_head, h->queue_tail, pos); | 479 | GNUNET_CONTAINER_DLL_remove (h->queue_head, h->queue_tail, pos); |
480 | GNUNET_CONTAINER_DLL_insert (h->queue_head, h->queue_tail, pos); | 480 | GNUNET_CONTAINER_DLL_insert (h->queue_head, h->queue_tail, pos); |
481 | GNUNET_STATISTICS_update (h->stats, | 481 | GNUNET_STATISTICS_update (h->stats, |
@@ -1148,14 +1148,14 @@ process_result_message (void *cls, const struct GNUNET_MessageHeader *msg) | |||
1148 | const struct DataMessage *dm; | 1148 | const struct DataMessage *dm; |
1149 | int was_transmitted; | 1149 | int was_transmitted; |
1150 | 1150 | ||
1151 | if (msg == NULL) | 1151 | if (NULL == msg) |
1152 | { | 1152 | { |
1153 | qe = h->queue_head; | 1153 | qe = h->queue_head; |
1154 | GNUNET_assert (NULL != qe); | 1154 | GNUNET_assert (NULL != qe); |
1155 | rc = qe->qc.rc; | 1155 | rc = qe->qc.rc; |
1156 | was_transmitted = qe->was_transmitted; | 1156 | was_transmitted = qe->was_transmitted; |
1157 | free_queue_entry (qe); | 1157 | free_queue_entry (qe); |
1158 | if (was_transmitted == GNUNET_YES) | 1158 | if (GNUNET_YES == was_transmitted) |
1159 | { | 1159 | { |
1160 | LOG (GNUNET_ERROR_TYPE_WARNING, | 1160 | LOG (GNUNET_ERROR_TYPE_WARNING, |
1161 | _("Failed to receive response from database.\n")); | 1161 | _("Failed to receive response from database.\n")); |
@@ -1165,7 +1165,7 @@ process_result_message (void *cls, const struct GNUNET_MessageHeader *msg) | |||
1165 | { | 1165 | { |
1166 | process_queue (h); | 1166 | process_queue (h); |
1167 | } | 1167 | } |
1168 | if (rc.proc != NULL) | 1168 | if (NULL != rc.proc) |
1169 | rc.proc (rc.proc_cls, NULL, 0, NULL, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, | 1169 | rc.proc (rc.proc_cls, NULL, 0, NULL, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, |
1170 | 0); | 1170 | 0); |
1171 | return; | 1171 | return; |