aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-03-07 19:10:51 +0000
committerChristian Grothoff <christian@grothoff.org>2015-03-07 19:10:51 +0000
commitcd0ad4c559f9338eec2a152ded51d16e021eca06 (patch)
tree151c7e7b1483f4b50411e1fd30be1091cc7480bd /src/datastore
parent71c9ff44f0b1b1f6c3dc72e945644e47ab5ab921 (diff)
downloadgnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.tar.gz
gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.zip
-indentation and comment fixes
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/datastore_api.c21
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 */
1411struct GNUNET_DATASTORE_QueueEntry * 1411struct GNUNET_DATASTORE_QueueEntry *
1412GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, uint64_t offset, 1412GNUNET_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);