aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/perf_peerstore_store.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/peerstore/perf_peerstore_store.c')
-rw-r--r--src/peerstore/perf_peerstore_store.c64
1 files changed, 32 insertions, 32 deletions
diff --git a/src/peerstore/perf_peerstore_store.c b/src/peerstore/perf_peerstore_store.c
index 392dbbb03..bdff19cb5 100644
--- a/src/peerstore/perf_peerstore_store.c
+++ b/src/peerstore/perf_peerstore_store.c
@@ -40,68 +40,68 @@ static char *v = "test_peerstore_stress_val";
40static int count = 0; 40static int count = 0;
41 41
42static void 42static void
43disconnect() 43disconnect ()
44{ 44{
45 if (NULL != h) 45 if (NULL != h)
46 GNUNET_PEERSTORE_disconnect(h, GNUNET_YES); 46 GNUNET_PEERSTORE_disconnect (h, GNUNET_YES);
47 GNUNET_SCHEDULER_shutdown(); 47 GNUNET_SCHEDULER_shutdown ();
48} 48}
49 49
50 50
51static void 51static void
52store() 52store ()
53{ 53{
54 GNUNET_PEERSTORE_store(h, ss, &p, k, v, strlen(v) + 1, 54 GNUNET_PEERSTORE_store (h, ss, &p, k, v, strlen (v) + 1,
55 GNUNET_TIME_UNIT_FOREVER_ABS, 55 GNUNET_TIME_UNIT_FOREVER_ABS,
56 (count == 56 (count ==
57 0) ? GNUNET_PEERSTORE_STOREOPTION_REPLACE : 57 0) ? GNUNET_PEERSTORE_STOREOPTION_REPLACE :
58 GNUNET_PEERSTORE_STOREOPTION_MULTIPLE, NULL, NULL); 58 GNUNET_PEERSTORE_STOREOPTION_MULTIPLE, NULL, NULL);
59 count++; 59 count++;
60} 60}
61 61
62 62
63static void 63static void
64watch_cb(void *cls, const struct GNUNET_PEERSTORE_Record *record, 64watch_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
65 const char *emsg) 65 const char *emsg)
66{ 66{
67 GNUNET_assert(NULL == emsg); 67 GNUNET_assert (NULL == emsg);
68 if (STORES == count) 68 if (STORES == count)
69 { 69 {
70 ok = 0; 70 ok = 0;
71 disconnect(); 71 disconnect ();
72 } 72 }
73 else 73 else
74 store(); 74 store ();
75} 75}
76 76
77 77
78static void 78static void
79run(void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg, 79run (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg,
80 struct GNUNET_TESTING_Peer *peer) 80 struct GNUNET_TESTING_Peer *peer)
81{ 81{
82 memset(&p, 5, sizeof(p)); 82 memset (&p, 5, sizeof(p));
83 h = GNUNET_PEERSTORE_connect(cfg); 83 h = GNUNET_PEERSTORE_connect (cfg);
84 GNUNET_assert(NULL != h); 84 GNUNET_assert (NULL != h);
85 GNUNET_PEERSTORE_watch(h, ss, &p, k, &watch_cb, NULL); 85 GNUNET_PEERSTORE_watch (h, ss, &p, k, &watch_cb, NULL);
86 store(); 86 store ();
87} 87}
88 88
89 89
90int 90int
91main(int argc, char *argv[]) 91main (int argc, char *argv[])
92{ 92{
93 struct GNUNET_TIME_Absolute start; 93 struct GNUNET_TIME_Absolute start;
94 struct GNUNET_TIME_Relative diff; 94 struct GNUNET_TIME_Relative diff;
95 95
96 start = GNUNET_TIME_absolute_get(); 96 start = GNUNET_TIME_absolute_get ();
97 if (0 != 97 if (0 !=
98 GNUNET_TESTING_service_run("perf-peerstore-store", "peerstore", 98 GNUNET_TESTING_service_run ("perf-peerstore-store", "peerstore",
99 "test_peerstore_api_data.conf", &run, NULL)) 99 "test_peerstore_api_data.conf", &run, NULL))
100 return 1; 100 return 1;
101 diff = GNUNET_TIME_absolute_get_duration(start); 101 diff = GNUNET_TIME_absolute_get_duration (start);
102 fprintf(stderr, "Stored and retrieved %d records in %s (%s).\n", STORES, 102 fprintf (stderr, "Stored and retrieved %d records in %s (%s).\n", STORES,
103 GNUNET_STRINGS_relative_time_to_string(diff, GNUNET_YES), 103 GNUNET_STRINGS_relative_time_to_string (diff, GNUNET_YES),
104 GNUNET_STRINGS_relative_time_to_string(diff, GNUNET_NO)); 104 GNUNET_STRINGS_relative_time_to_string (diff, GNUNET_NO));
105 return ok; 105 return ok;
106} 106}
107 107