diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-03-07 19:10:51 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-03-07 19:10:51 +0000 |
commit | cd0ad4c559f9338eec2a152ded51d16e021eca06 (patch) | |
tree | 151c7e7b1483f4b50411e1fd30be1091cc7480bd /src/datastore/datastore_api.c | |
parent | 71c9ff44f0b1b1f6c3dc72e945644e47ab5ab921 (diff) | |
download | gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.tar.gz gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.zip |
-indentation and comment fixes
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 5a46b2039..67ca9a8ad 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -1409,13 +1409,15 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | |||
1409 | * cancel | 1409 | * cancel |
1410 | */ | 1410 | */ |
1411 | struct GNUNET_DATASTORE_QueueEntry * | 1411 | struct GNUNET_DATASTORE_QueueEntry * |
1412 | GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, uint64_t offset, | 1412 | GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, |
1413 | uint64_t offset, | ||
1413 | const struct GNUNET_HashCode * key, | 1414 | const struct GNUNET_HashCode * key, |
1414 | enum GNUNET_BLOCK_Type type, | 1415 | enum GNUNET_BLOCK_Type type, |
1415 | unsigned int queue_priority, | 1416 | unsigned int queue_priority, |
1416 | unsigned int max_queue_size, | 1417 | unsigned int max_queue_size, |
1417 | struct GNUNET_TIME_Relative timeout, | 1418 | struct GNUNET_TIME_Relative timeout, |
1418 | GNUNET_DATASTORE_DatumProcessor proc, void *proc_cls) | 1419 | GNUNET_DATASTORE_DatumProcessor proc, |
1420 | void *proc_cls) | ||
1419 | { | 1421 | { |
1420 | struct GNUNET_DATASTORE_QueueEntry *qe; | 1422 | struct GNUNET_DATASTORE_QueueEntry *qe; |
1421 | struct GetMessage *gm; | 1423 | struct GetMessage *gm; |
@@ -1427,8 +1429,13 @@ GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, uint64_t offset, | |||
1427 | (unsigned int) type, GNUNET_h2s (key)); | 1429 | (unsigned int) type, GNUNET_h2s (key)); |
1428 | qc.rc.proc = proc; | 1430 | qc.rc.proc = proc; |
1429 | qc.rc.proc_cls = proc_cls; | 1431 | qc.rc.proc_cls = proc_cls; |
1430 | qe = make_queue_entry (h, sizeof (struct GetMessage), queue_priority, | 1432 | qe = make_queue_entry (h, |
1431 | max_queue_size, timeout, &process_result_message, &qc); | 1433 | sizeof (struct GetMessage), |
1434 | queue_priority, | ||
1435 | max_queue_size, | ||
1436 | timeout, | ||
1437 | &process_result_message, | ||
1438 | &qc); | ||
1432 | if (qe == NULL) | 1439 | if (qe == NULL) |
1433 | { | 1440 | { |
1434 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Could not queue request for `%s'\n", | 1441 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Could not queue request for `%s'\n", |
@@ -1436,8 +1443,10 @@ GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, uint64_t offset, | |||
1436 | return NULL; | 1443 | return NULL; |
1437 | } | 1444 | } |
1438 | #if INSANE_STATISTICS | 1445 | #if INSANE_STATISTICS |
1439 | GNUNET_STATISTICS_update (h->stats, gettext_noop ("# GET requests executed"), | 1446 | GNUNET_STATISTICS_update (h->stats, |
1440 | 1, GNUNET_NO); | 1447 | gettext_noop ("# GET requests executed"), |
1448 | 1, | ||
1449 | GNUNET_NO); | ||
1441 | #endif | 1450 | #endif |
1442 | gm = (struct GetMessage *) &qe[1]; | 1451 | gm = (struct GetMessage *) &qe[1]; |
1443 | gm->header.type = htons (GNUNET_MESSAGE_TYPE_DATASTORE_GET); | 1452 | gm->header.type = htons (GNUNET_MESSAGE_TYPE_DATASTORE_GET); |