aboutsummaryrefslogtreecommitdiff
path: root/src/datastore/datastore_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-08-29 10:19:43 +0000
committerChristian Grothoff <christian@grothoff.org>2011-08-29 10:19:43 +0000
commitcddbdf5b928c68ab71b40c950b9f01ea68a9fbdb (patch)
treeb704e00a3af618b2cd174a7f89514eaebd82a1cf /src/datastore/datastore_api.c
parentbb4fc4f4007988874f910d4de5492f9629301641 (diff)
downloadgnunet-cddbdf5b928c68ab71b40c950b9f01ea68a9fbdb.tar.gz
gnunet-cddbdf5b928c68ab71b40c950b9f01ea68a9fbdb.zip
run indent twice, it alternates between two 'canonical' forms, also run whitespace remover
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r--src/datastore/datastore_api.c20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 8a8f64eb3..f8826ce66 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -34,7 +34,7 @@
34/** 34/**
35 * If a client stopped asking for more results, how many more do 35 * If a client stopped asking for more results, how many more do
36 * we receive from the DB before killing the connection? Trade-off 36 * we receive from the DB before killing the connection? Trade-off
37 * between re-doing TCP handshakes and (needlessly) receiving 37 * between re-doing TCP handshakes and (needlessly) receiving
38 * useless results. 38 * useless results.
39 */ 39 */
40#define MAX_EXCESS_RESULTS 8 40#define MAX_EXCESS_RESULTS 8
@@ -163,7 +163,7 @@ struct GNUNET_DATASTORE_QueueEntry
163 /** 163 /**
164 * Has this message been transmitted to the service? 164 * Has this message been transmitted to the service?
165 * Only ever GNUNET_YES for the head of the queue. 165 * Only ever GNUNET_YES for the head of the queue.
166 * Note that the overall struct should end at a 166 * Note that the overall struct should end at a
167 * multiple of 64 bits. 167 * multiple of 64 bits.
168 */ 168 */
169 int was_transmitted; 169 int was_transmitted;
@@ -171,7 +171,7 @@ struct GNUNET_DATASTORE_QueueEntry
171}; 171};
172 172
173/** 173/**
174 * Handle to the datastore service. 174 * Handle to the datastore service.
175 */ 175 */
176struct GNUNET_DATASTORE_Handle 176struct GNUNET_DATASTORE_Handle
177{ 177{
@@ -391,7 +391,7 @@ timeout_queue_entry (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
391 * @param timeout timeout for the operation 391 * @param timeout timeout for the operation
392 * @param response_proc function to call with replies (can be NULL) 392 * @param response_proc function to call with replies (can be NULL)
393 * @param qc client context (NOT a closure for response_proc) 393 * @param qc client context (NOT a closure for response_proc)
394 * @return NULL if the queue is full 394 * @return NULL if the queue is full
395 */ 395 */
396static struct GNUNET_DATASTORE_QueueEntry * 396static struct GNUNET_DATASTORE_QueueEntry *
397make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize, 397make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
@@ -452,7 +452,7 @@ make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
452 if ((pos->max_queue < h->queue_size) && (pos->was_transmitted == GNUNET_NO)) 452 if ((pos->max_queue < h->queue_size) && (pos->was_transmitted == GNUNET_NO))
453 { 453 {
454 GNUNET_assert (pos->response_proc != NULL); 454 GNUNET_assert (pos->response_proc != NULL);
455 /* move 'pos' element to head so that it will be 455 /* move 'pos' element to head so that it will be
456 * killed on 'NULL' call below */ 456 * killed on 'NULL' call below */
457#if DEBUG_DATASTORE 457#if DEBUG_DATASTORE
458 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 458 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -477,7 +477,7 @@ make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
477/** 477/**
478 * Process entries in the queue (or do nothing if we are already 478 * Process entries in the queue (or do nothing if we are already
479 * doing so). 479 * doing so).
480 * 480 *
481 * @param h handle to the datastore 481 * @param h handle to the datastore
482 */ 482 */
483static void 483static void
@@ -637,7 +637,7 @@ transmit_request (void *cls, size_t size, void *buf)
637/** 637/**
638 * Process entries in the queue (or do nothing if we are already 638 * Process entries in the queue (or do nothing if we are already
639 * doing so). 639 * doing so).
640 * 640 *
641 * @param h handle to the datastore 641 * @param h handle to the datastore
642 */ 642 */
643static void 643static void
@@ -696,7 +696,7 @@ process_queue (struct GNUNET_DATASTORE_Handle *h)
696 * Dummy continuation used to do nothing (but be non-zero). 696 * Dummy continuation used to do nothing (but be non-zero).
697 * 697 *
698 * @param cls closure 698 * @param cls closure
699 * @param result result 699 * @param result result
700 * @param emsg error message 700 * @param emsg error message
701 */ 701 */
702static void 702static void
@@ -710,7 +710,7 @@ drop_status_cont (void *cls, int32_t result, const char *emsg)
710 * Free a queue entry. Removes the given entry from the 710 * Free a queue entry. Removes the given entry from the
711 * queue and releases associated resources. Does NOT 711 * queue and releases associated resources. Does NOT
712 * call the callback. 712 * call the callback.
713 * 713 *
714 * @param qe entry to free. 714 * @param qe entry to free.
715 */ 715 */
716static void 716static void
@@ -1478,7 +1478,7 @@ GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, uint64_t offset,
1478/** 1478/**
1479 * Cancel a datastore operation. The final callback from the 1479 * Cancel a datastore operation. The final callback from the
1480 * operation must not have been done yet. 1480 * operation must not have been done yet.
1481 * 1481 *
1482 * @param qe operation to cancel 1482 * @param qe operation to cancel
1483 */ 1483 */
1484void 1484void