aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2014-06-22 22:19:02 +0000
committerChristian Grothoff <christian@grothoff.org>2014-06-22 22:19:02 +0000
commitd28cb8e55ebe88deccac1a27cfcdbdd71516cc47 (patch)
treea85d1b2e72f747c1189a392c66f65b5881b4528f /src
parent6092b234351e35f0a64c1a1c874f28229b927cf8 (diff)
downloadgnunet-d28cb8e55ebe88deccac1a27cfcdbdd71516cc47.tar.gz
gnunet-d28cb8e55ebe88deccac1a27cfcdbdd71516cc47.zip
-fix doxygen
Diffstat (limited to 'src')
-rw-r--r--src/dht/gnunet_dht_profiler.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/dht/gnunet_dht_profiler.c b/src/dht/gnunet_dht_profiler.c
index 9921c0aed..724a75d8a 100644
--- a/src/dht/gnunet_dht_profiler.c
+++ b/src/dht/gnunet_dht_profiler.c
@@ -21,7 +21,7 @@
21/** 21/**
22 * @file dht/gnunet_dht_profiler.c 22 * @file dht/gnunet_dht_profiler.c
23 * @brief Profiler for GNUnet DHT 23 * @brief Profiler for GNUnet DHT
24 * @author Sree Harsha Totakura <sreeharsha@totakura.in> 24 * @author Sree Harsha Totakura <sreeharsha@totakura.in>
25 */ 25 */
26 26
27#include "platform.h" 27#include "platform.h"
@@ -114,7 +114,7 @@ struct ActiveContext
114 struct GNUNET_DHT_GetHandle *dht_get; 114 struct GNUNET_DHT_GetHandle *dht_get;
115 115
116 /** 116 /**
117 * The hash of the @put_data 117 * The hash of the @e put_data
118 */ 118 */
119 struct GNUNET_HashCode hash; 119 struct GNUNET_HashCode hash;
120 120
@@ -124,7 +124,7 @@ struct ActiveContext
124 GNUNET_SCHEDULER_TaskIdentifier delay_task; 124 GNUNET_SCHEDULER_TaskIdentifier delay_task;
125 125
126 /** 126 /**
127 * The size of the put_data 127 * The size of the @e put_data
128 */ 128 */
129 uint16_t put_data_size; 129 uint16_t put_data_size;
130 130
@@ -212,14 +212,14 @@ do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
212{ 212{
213 struct ActiveContext *ac; 213 struct ActiveContext *ac;
214 unsigned int cnt; 214 unsigned int cnt;
215 215
216 if (NULL != a_ctx) 216 if (NULL != a_ctx)
217 { 217 {
218 for (cnt=0; cnt < num_peers; cnt++) 218 for (cnt=0; cnt < num_peers; cnt++)
219 { 219 {
220 if (NULL != a_ctx[cnt].op) 220 if (NULL != a_ctx[cnt].op)
221 GNUNET_TESTBED_operation_done (a_ctx[cnt].op); 221 GNUNET_TESTBED_operation_done (a_ctx[cnt].op);
222 222
223 /* Cleanup active context if this peer is an active peer */ 223 /* Cleanup active context if this peer is an active peer */
224 ac = a_ctx[cnt].ac; 224 ac = a_ctx[cnt].ac;
225 if (NULL == ac) 225 if (NULL == ac)
@@ -293,7 +293,7 @@ cancel_get (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
293 * @param size number of bytes in @a data 293 * @param size number of bytes in @a data
294 * @param data pointer to the result data 294 * @param data pointer to the result data
295 */ 295 */
296static void 296static void
297get_iter (void *cls, 297get_iter (void *cls,
298 struct GNUNET_TIME_Absolute exp, 298 struct GNUNET_TIME_Absolute exp,
299 const struct GNUNET_HashCode *key, 299 const struct GNUNET_HashCode *key,
@@ -306,7 +306,7 @@ get_iter (void *cls,
306{ 306{
307 struct ActiveContext *ac = cls; 307 struct ActiveContext *ac = cls;
308 struct ActiveContext *get_ac = ac->get_ac; 308 struct ActiveContext *get_ac = ac->get_ac;
309 309
310 if (get_ac->put_data_size != size) 310 if (get_ac->put_data_size != size)
311 { 311 {
312 DEBUG ("Found a GET with incorrect data length (this may happen, but very unlikely)\n"); 312 DEBUG ("Found a GET with incorrect data length (this may happen, but very unlikely)\n");
@@ -413,7 +413,7 @@ delayed_put (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
413 ac->put_data_size += GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 413 ac->put_data_size += GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
414 (63*1024)); 414 (63*1024));
415 ac->put_data = GNUNET_malloc (ac->put_data_size); 415 ac->put_data = GNUNET_malloc (ac->put_data_size);
416 GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, 416 GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK,
417 ac->put_data, ac->put_data_size); 417 ac->put_data, ac->put_data_size);
418 GNUNET_CRYPTO_hash (ac->put_data, ac->put_data_size, &ac->hash); 418 GNUNET_CRYPTO_hash (ac->put_data, ac->put_data_size, &ac->hash);
419 DEBUG ("Doing a DHT PUT with data of size %u\n", ac->put_data_size); 419 DEBUG ("Doing a DHT PUT with data of size %u\n", ac->put_data_size);
@@ -487,7 +487,7 @@ dht_connect (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg)
487 * @param cls the active context 487 * @param cls the active context
488 * @param op_result service handle returned from the connect adapter 488 * @param op_result service handle returned from the connect adapter
489 */ 489 */
490static void 490static void
491dht_disconnect (void *cls, void *op_result) 491dht_disconnect (void *cls, void *op_result)
492{ 492{
493 struct ActiveContext *ac = cls; 493 struct ActiveContext *ac = cls;
@@ -560,7 +560,7 @@ test_run (void *cls,
560 } 560 }
561 INFO ("%u peers started\n", num_peers); 561 INFO ("%u peers started\n", num_peers);
562 a_ctx = GNUNET_malloc (sizeof (struct Context) * num_peers); 562 a_ctx = GNUNET_malloc (sizeof (struct Context) * num_peers);
563 563
564 /* select the peers which actively participate in profiling */ 564 /* select the peers which actively participate in profiling */
565 n_active = num_peers * PUT_PROBABILITY / 100; 565 n_active = num_peers * PUT_PROBABILITY / 100;
566 if (0 == n_active) 566 if (0 == n_active)
@@ -611,7 +611,7 @@ run (void *cls, char *const *args, const char *cfgfile,
611 const struct GNUNET_CONFIGURATION_Handle *config) 611 const struct GNUNET_CONFIGURATION_Handle *config)
612{ 612{
613 uint64_t event_mask; 613 uint64_t event_mask;
614 614
615 if (0 == num_peers) 615 if (0 == num_peers)
616 { 616 {
617 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, _("Exiting as the number of peers is %u\n"), 617 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, _("Exiting as the number of peers is %u\n"),