aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/datastore_api.c4
-rw-r--r--src/datastore/gnunet-service-datastore.c8
-rw-r--r--src/datastore/perf_datastore_api.c2
-rw-r--r--src/datastore/perf_plugin_datastore.c2
-rw-r--r--src/datastore/plugin_datastore.h9
-rw-r--r--src/datastore/plugin_datastore_sqlite.c18
-rw-r--r--src/datastore/plugin_datastore_template.c40
-rw-r--r--src/datastore/test_datastore_api.c38
-rw-r--r--src/datastore/test_datastore_api_management.c18
9 files changed, 70 insertions, 69 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 7e7bf02c8..1c50dabee 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -319,7 +319,7 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h,
319 const GNUNET_HashCode * key, 319 const GNUNET_HashCode * key,
320 uint32_t size, 320 uint32_t size,
321 const void *data, 321 const void *data,
322 uint32_t type, 322 enum GNUNET_BLOCK_Type type,
323 uint32_t priority, 323 uint32_t priority,
324 uint32_t anonymity, 324 uint32_t anonymity,
325 struct GNUNET_TIME_Absolute expiration, 325 struct GNUNET_TIME_Absolute expiration,
@@ -668,7 +668,7 @@ transmit_for_result (struct GNUNET_DATASTORE_Handle *h,
668void 668void
669GNUNET_DATASTORE_get (struct GNUNET_DATASTORE_Handle *h, 669GNUNET_DATASTORE_get (struct GNUNET_DATASTORE_Handle *h,
670 const GNUNET_HashCode * key, 670 const GNUNET_HashCode * key,
671 uint32_t type, 671 enum GNUNET_BLOCK_Type type,
672 GNUNET_DATASTORE_Iterator iter, void *iter_cls, 672 GNUNET_DATASTORE_Iterator iter, void *iter_cls,
673 struct GNUNET_TIME_Relative timeout) 673 struct GNUNET_TIME_Relative timeout)
674{ 674{
diff --git a/src/datastore/gnunet-service-datastore.c b/src/datastore/gnunet-service-datastore.c
index 79fcd70e9..6d0f29671 100644
--- a/src/datastore/gnunet-service-datastore.c
+++ b/src/datastore/gnunet-service-datastore.c
@@ -288,7 +288,7 @@ expired_processor (void *cls,
288 const GNUNET_HashCode * key, 288 const GNUNET_HashCode * key,
289 uint32_t size, 289 uint32_t size,
290 const void *data, 290 const void *data,
291 uint32_t type, 291 enum GNUNET_BLOCK_Type type,
292 uint32_t priority, 292 uint32_t priority,
293 uint32_t anonymity, 293 uint32_t anonymity,
294 struct GNUNET_TIME_Absolute 294 struct GNUNET_TIME_Absolute
@@ -375,7 +375,7 @@ manage (void *cls,
375 const GNUNET_HashCode * key, 375 const GNUNET_HashCode * key,
376 uint32_t size, 376 uint32_t size,
377 const void *data, 377 const void *data,
378 uint32_t type, 378 enum GNUNET_BLOCK_Type type,
379 uint32_t priority, 379 uint32_t priority,
380 uint32_t anonymity, 380 uint32_t anonymity,
381 struct GNUNET_TIME_Absolute 381 struct GNUNET_TIME_Absolute
@@ -644,7 +644,7 @@ transmit_item (void *cls,
644 const GNUNET_HashCode * key, 644 const GNUNET_HashCode * key,
645 uint32_t size, 645 uint32_t size,
646 const void *data, 646 const void *data,
647 uint32_t type, 647 enum GNUNET_BLOCK_Type type,
648 uint32_t priority, 648 uint32_t priority,
649 uint32_t anonymity, 649 uint32_t anonymity,
650 struct GNUNET_TIME_Absolute 650 struct GNUNET_TIME_Absolute
@@ -1094,7 +1094,7 @@ remove_callback (void *cls,
1094 const GNUNET_HashCode * key, 1094 const GNUNET_HashCode * key,
1095 uint32_t size, 1095 uint32_t size,
1096 const void *data, 1096 const void *data,
1097 uint32_t type, 1097 enum GNUNET_BLOCK_Type type,
1098 uint32_t priority, 1098 uint32_t priority,
1099 uint32_t anonymity, 1099 uint32_t anonymity,
1100 struct GNUNET_TIME_Absolute 1100 struct GNUNET_TIME_Absolute
diff --git a/src/datastore/perf_datastore_api.c b/src/datastore/perf_datastore_api.c
index 93e875c8c..b92fefe4d 100644
--- a/src/datastore/perf_datastore_api.c
+++ b/src/datastore/perf_datastore_api.c
@@ -198,7 +198,7 @@ delete_value (void *cls,
198 const GNUNET_HashCode * key, 198 const GNUNET_HashCode * key,
199 uint32_t size, 199 uint32_t size,
200 const void *data, 200 const void *data,
201 uint32_t type, 201 enum GNUNET_BLOCK_Type type,
202 uint32_t priority, 202 uint32_t priority,
203 uint32_t anonymity, 203 uint32_t anonymity,
204 struct GNUNET_TIME_Absolute 204 struct GNUNET_TIME_Absolute
diff --git a/src/datastore/perf_plugin_datastore.c b/src/datastore/perf_plugin_datastore.c
index a23569875..ea1df5efa 100644
--- a/src/datastore/perf_plugin_datastore.c
+++ b/src/datastore/perf_plugin_datastore.c
@@ -140,7 +140,7 @@ iterateDummy (void *cls,
140 const GNUNET_HashCode * key, 140 const GNUNET_HashCode * key,
141 uint32_t size, 141 uint32_t size,
142 const void *data, 142 const void *data,
143 uint32_t type, 143 enum GNUNET_BLOCK_Type type,
144 uint32_t priority, 144 uint32_t priority,
145 uint32_t anonymity, 145 uint32_t anonymity,
146 struct GNUNET_TIME_Absolute 146 struct GNUNET_TIME_Absolute
diff --git a/src/datastore/plugin_datastore.h b/src/datastore/plugin_datastore.h
index 775a6641a..e8f433671 100644
--- a/src/datastore/plugin_datastore.h
+++ b/src/datastore/plugin_datastore.h
@@ -30,6 +30,7 @@
30#ifndef PLUGIN_DATASTORE_H 30#ifndef PLUGIN_DATASTORE_H
31#define PLUGIN_DATASTORE_H 31#define PLUGIN_DATASTORE_H
32 32
33#include "gnunet_block_lib.h"
33#include "gnunet_configuration_lib.h" 34#include "gnunet_configuration_lib.h"
34#include "gnunet_datastore_service.h" 35#include "gnunet_datastore_service.h"
35#include "gnunet_statistics_service.h" 36#include "gnunet_statistics_service.h"
@@ -103,7 +104,7 @@ typedef int (*PluginIterator) (void *cls,
103 const GNUNET_HashCode * key, 104 const GNUNET_HashCode * key,
104 uint32_t size, 105 uint32_t size,
105 const void *data, 106 const void *data,
106 uint32_t type, 107 enum GNUNET_BLOCK_Type type,
107 uint32_t priority, 108 uint32_t priority,
108 uint32_t anonymity, 109 uint32_t anonymity,
109 struct GNUNET_TIME_Absolute 110 struct GNUNET_TIME_Absolute
@@ -142,7 +143,7 @@ typedef int (*PluginPut) (void *cls,
142 const GNUNET_HashCode * key, 143 const GNUNET_HashCode * key,
143 uint32_t size, 144 uint32_t size,
144 const void *data, 145 const void *data,
145 uint32_t type, 146 enum GNUNET_BLOCK_Type type,
146 uint32_t priority, 147 uint32_t priority,
147 uint32_t anonymity, 148 uint32_t anonymity,
148 struct GNUNET_TIME_Absolute expiration, 149 struct GNUNET_TIME_Absolute expiration,
@@ -173,7 +174,7 @@ typedef int (*PluginPut) (void *cls,
173typedef void (*PluginGet) (void *cls, 174typedef void (*PluginGet) (void *cls,
174 const GNUNET_HashCode * key, 175 const GNUNET_HashCode * key,
175 const GNUNET_HashCode * vhash, 176 const GNUNET_HashCode * vhash,
176 uint32_t type, 177 enum GNUNET_BLOCK_Type type,
177 PluginIterator iter, void *iter_cls); 178 PluginIterator iter, void *iter_cls);
178 179
179 180
@@ -222,7 +223,7 @@ typedef int (*PluginUpdate) (void *cls,
222 * @param iter_cls closure for iter 223 * @param iter_cls closure for iter
223 */ 224 */
224typedef void (*PluginSelector) (void *cls, 225typedef void (*PluginSelector) (void *cls,
225 uint32_t type, 226 enum GNUNET_BLOCK_Type type,
226 PluginIterator iter, 227 PluginIterator iter,
227 void *iter_cls); 228 void *iter_cls);
228 229
diff --git a/src/datastore/plugin_datastore_sqlite.c b/src/datastore/plugin_datastore_sqlite.c
index 0d4170e56..824b74ad2 100644
--- a/src/datastore/plugin_datastore_sqlite.c
+++ b/src/datastore/plugin_datastore_sqlite.c
@@ -719,7 +719,7 @@ sqlite_plugin_put (void *cls,
719 const GNUNET_HashCode * key, 719 const GNUNET_HashCode * key,
720 uint32_t size, 720 uint32_t size,
721 const void *data, 721 const void *data,
722 uint32_t type, 722 enum GNUNET_BLOCK_Type type,
723 uint32_t priority, 723 uint32_t priority,
724 uint32_t anonymity, 724 uint32_t anonymity,
725 struct GNUNET_TIME_Absolute expiration, 725 struct GNUNET_TIME_Absolute expiration,
@@ -892,7 +892,7 @@ struct IterContext
892 /** 892 /**
893 * Desired type for blocks returned by this iterator. 893 * Desired type for blocks returned by this iterator.
894 */ 894 */
895 uint32_t type; 895 enum GNUNET_BLOCK_Type type;
896}; 896};
897 897
898 898
@@ -1026,7 +1026,7 @@ iter_next_prepare (void *cls,
1026 */ 1026 */
1027static void 1027static void
1028basic_iter (struct Plugin *plugin, 1028basic_iter (struct Plugin *plugin,
1029 uint32_t type, 1029 enum GNUNET_BLOCK_Type type,
1030 int is_asc, 1030 int is_asc,
1031 int is_prio, 1031 int is_prio,
1032 int is_migr, 1032 int is_migr,
@@ -1110,7 +1110,7 @@ basic_iter (struct Plugin *plugin,
1110 */ 1110 */
1111static void 1111static void
1112sqlite_plugin_iter_low_priority (void *cls, 1112sqlite_plugin_iter_low_priority (void *cls,
1113 uint32_t type, 1113 enum GNUNET_BLOCK_Type type,
1114 PluginIterator iter, 1114 PluginIterator iter,
1115 void *iter_cls) 1115 void *iter_cls)
1116{ 1116{
@@ -1137,7 +1137,7 @@ sqlite_plugin_iter_low_priority (void *cls,
1137 */ 1137 */
1138static void 1138static void
1139sqlite_plugin_iter_zero_anonymity (void *cls, 1139sqlite_plugin_iter_zero_anonymity (void *cls,
1140 uint32_t type, 1140 enum GNUNET_BLOCK_Type type,
1141 PluginIterator iter, 1141 PluginIterator iter,
1142 void *iter_cls) 1142 void *iter_cls)
1143{ 1143{
@@ -1176,7 +1176,7 @@ sqlite_plugin_iter_zero_anonymity (void *cls,
1176 */ 1176 */
1177static void 1177static void
1178sqlite_plugin_iter_ascending_expiration (void *cls, 1178sqlite_plugin_iter_ascending_expiration (void *cls,
1179 uint32_t type, 1179 enum GNUNET_BLOCK_Type type,
1180 PluginIterator iter, 1180 PluginIterator iter,
1181 void *iter_cls) 1181 void *iter_cls)
1182{ 1182{
@@ -1213,7 +1213,7 @@ sqlite_plugin_iter_ascending_expiration (void *cls,
1213 */ 1213 */
1214static void 1214static void
1215sqlite_plugin_iter_migration_order (void *cls, 1215sqlite_plugin_iter_migration_order (void *cls,
1216 uint32_t type, 1216 enum GNUNET_BLOCK_Type type,
1217 PluginIterator iter, 1217 PluginIterator iter,
1218 void *iter_cls) 1218 void *iter_cls)
1219{ 1219{
@@ -1288,7 +1288,7 @@ all_next_prepare (void *cls,
1288 */ 1288 */
1289static void 1289static void
1290sqlite_plugin_iter_all_now (void *cls, 1290sqlite_plugin_iter_all_now (void *cls,
1291 uint32_t type, 1291 enum GNUNET_BLOCK_Type type,
1292 PluginIterator iter, 1292 PluginIterator iter,
1293 void *iter_cls) 1293 void *iter_cls)
1294{ 1294{
@@ -1439,7 +1439,7 @@ static void
1439sqlite_plugin_get (void *cls, 1439sqlite_plugin_get (void *cls,
1440 const GNUNET_HashCode * key, 1440 const GNUNET_HashCode * key,
1441 const GNUNET_HashCode * vhash, 1441 const GNUNET_HashCode * vhash,
1442 uint32_t type, 1442 enum GNUNET_BLOCK_Type type,
1443 PluginIterator iter, void *iter_cls) 1443 PluginIterator iter, void *iter_cls)
1444{ 1444{
1445 struct Plugin *plugin = cls; 1445 struct Plugin *plugin = cls;
diff --git a/src/datastore/plugin_datastore_template.c b/src/datastore/plugin_datastore_template.c
index 6439bc019..7656f6a7d 100644
--- a/src/datastore/plugin_datastore_template.c
+++ b/src/datastore/plugin_datastore_template.c
@@ -70,12 +70,12 @@ static unsigned long long template_plugin_get_size (void *cls)
70 */ 70 */
71static int 71static int
72template_plugin_put (void *cls, 72template_plugin_put (void *cls,
73 const GNUNET_HashCode * key, 73 const GNUNET_HashCode * key,
74 uint32_t size, 74 uint32_t size,
75 const void *data, 75 const void *data,
76 uint32_t type, 76 enum GNUNET_BLOCK_Type type,
77 uint32_t priority, 77 uint32_t priority,
78 uint32_t anonymity, 78 uint32_t anonymity,
79 struct GNUNET_TIME_Absolute expiration, 79 struct GNUNET_TIME_Absolute expiration,
80 char **msg) 80 char **msg)
81{ 81{
@@ -126,7 +126,7 @@ static void
126template_plugin_get (void *cls, 126template_plugin_get (void *cls,
127 const GNUNET_HashCode * key, 127 const GNUNET_HashCode * key,
128 const GNUNET_HashCode * vhash, 128 const GNUNET_HashCode * vhash,
129 uint32_t type, 129 enum GNUNET_BLOCK_Type type,
130 PluginIterator iter, void *iter_cls) 130 PluginIterator iter, void *iter_cls)
131{ 131{
132 GNUNET_break (0); 132 GNUNET_break (0);
@@ -181,7 +181,7 @@ template_plugin_update (void *cls,
181 */ 181 */
182static void 182static void
183template_plugin_iter_low_priority (void *cls, 183template_plugin_iter_low_priority (void *cls,
184 uint32_t type, 184 enum GNUNET_BLOCK_Type type,
185 PluginIterator iter, 185 PluginIterator iter,
186 void *iter_cls) 186 void *iter_cls)
187{ 187{
@@ -203,9 +203,9 @@ template_plugin_iter_low_priority (void *cls,
203 */ 203 */
204static void 204static void
205template_plugin_iter_zero_anonymity (void *cls, 205template_plugin_iter_zero_anonymity (void *cls,
206 uint32_t type, 206 enum GNUNET_BLOCK_Type type,
207 PluginIterator iter, 207 PluginIterator iter,
208 void *iter_cls) 208 void *iter_cls)
209{ 209{
210 GNUNET_break (0); 210 GNUNET_break (0);
211} 211}
@@ -225,9 +225,9 @@ template_plugin_iter_zero_anonymity (void *cls,
225 */ 225 */
226static void 226static void
227template_plugin_iter_ascending_expiration (void *cls, 227template_plugin_iter_ascending_expiration (void *cls,
228 uint32_t type, 228 enum GNUNET_BLOCK_Type type,
229 PluginIterator iter, 229 PluginIterator iter,
230 void *iter_cls) 230 void *iter_cls)
231{ 231{
232 GNUNET_break (0); 232 GNUNET_break (0);
233} 233}
@@ -247,9 +247,9 @@ template_plugin_iter_ascending_expiration (void *cls,
247 */ 247 */
248static void 248static void
249template_plugin_iter_migration_order (void *cls, 249template_plugin_iter_migration_order (void *cls,
250 uint32_t type, 250 enum GNUNET_BLOCK_Type type,
251 PluginIterator iter, 251 PluginIterator iter,
252 void *iter_cls) 252 void *iter_cls)
253{ 253{
254 GNUNET_break (0); 254 GNUNET_break (0);
255} 255}
@@ -269,9 +269,9 @@ template_plugin_iter_migration_order (void *cls,
269 */ 269 */
270static void 270static void
271template_plugin_iter_all_now (void *cls, 271template_plugin_iter_all_now (void *cls,
272 uint32_t type, 272 enum GNUNET_BLOCK_Type type,
273 PluginIterator iter, 273 PluginIterator iter,
274 void *iter_cls) 274 void *iter_cls)
275{ 275{
276 GNUNET_break (0); 276 GNUNET_break (0);
277} 277}
diff --git a/src/datastore/test_datastore_api.c b/src/datastore/test_datastore_api.c
index 74c2ae206..07f1dc426 100644
--- a/src/datastore/test_datastore_api.c
+++ b/src/datastore/test_datastore_api.c
@@ -174,7 +174,7 @@ check_value (void *cls,
174 const GNUNET_HashCode * key, 174 const GNUNET_HashCode * key,
175 uint32_t size, 175 uint32_t size,
176 const void *data, 176 const void *data,
177 uint32_t type, 177 enum GNUNET_BLOCK_Type type,
178 uint32_t priority, 178 uint32_t priority,
179 uint32_t anonymity, 179 uint32_t anonymity,
180 struct GNUNET_TIME_Absolute 180 struct GNUNET_TIME_Absolute
@@ -209,14 +209,14 @@ check_value (void *cls,
209 209
210static void 210static void
211delete_value (void *cls, 211delete_value (void *cls,
212 const GNUNET_HashCode * key, 212 const GNUNET_HashCode * key,
213 uint32_t size, 213 uint32_t size,
214 const void *data, 214 const void *data,
215 uint32_t type, 215 enum GNUNET_BLOCK_Type type,
216 uint32_t priority, 216 uint32_t priority,
217 uint32_t anonymity, 217 uint32_t anonymity,
218 struct GNUNET_TIME_Absolute 218 struct GNUNET_TIME_Absolute
219 expiration, uint64_t uid) 219 expiration, uint64_t uid)
220{ 220{
221 struct CpsRunContext *crc = cls; 221 struct CpsRunContext *crc = cls;
222 if (key == NULL) 222 if (key == NULL)
@@ -239,14 +239,14 @@ delete_value (void *cls,
239 239
240static void 240static void
241check_nothing (void *cls, 241check_nothing (void *cls,
242 const GNUNET_HashCode * key, 242 const GNUNET_HashCode * key,
243 uint32_t size, 243 uint32_t size,
244 const void *data, 244 const void *data,
245 uint32_t type, 245 enum GNUNET_BLOCK_Type type,
246 uint32_t priority, 246 uint32_t priority,
247 uint32_t anonymity, 247 uint32_t anonymity,
248 struct GNUNET_TIME_Absolute 248 struct GNUNET_TIME_Absolute
249 expiration, uint64_t uid) 249 expiration, uint64_t uid)
250{ 250{
251 struct CpsRunContext *crc = cls; 251 struct CpsRunContext *crc = cls;
252 GNUNET_assert (key == NULL); 252 GNUNET_assert (key == NULL);
@@ -266,7 +266,7 @@ check_multiple (void *cls,
266 const GNUNET_HashCode * key, 266 const GNUNET_HashCode * key,
267 uint32_t size, 267 uint32_t size,
268 const void *data, 268 const void *data,
269 uint32_t type, 269 enum GNUNET_BLOCK_Type type,
270 uint32_t priority, 270 uint32_t priority,
271 uint32_t anonymity, 271 uint32_t anonymity,
272 struct GNUNET_TIME_Absolute 272 struct GNUNET_TIME_Absolute
@@ -296,7 +296,7 @@ check_update (void *cls,
296 const GNUNET_HashCode * key, 296 const GNUNET_HashCode * key,
297 uint32_t size, 297 uint32_t size,
298 const void *data, 298 const void *data,
299 uint32_t type, 299 enum GNUNET_BLOCK_Type type,
300 uint32_t priority, 300 uint32_t priority,
301 uint32_t anonymity, 301 uint32_t anonymity,
302 struct GNUNET_TIME_Absolute 302 struct GNUNET_TIME_Absolute
diff --git a/src/datastore/test_datastore_api_management.c b/src/datastore/test_datastore_api_management.c
index 62d1e5d26..169cef554 100644
--- a/src/datastore/test_datastore_api_management.c
+++ b/src/datastore/test_datastore_api_management.c
@@ -144,7 +144,7 @@ check_value (void *cls,
144 const GNUNET_HashCode * key, 144 const GNUNET_HashCode * key,
145 uint32_t size, 145 uint32_t size,
146 const void *data, 146 const void *data,
147 uint32_t type, 147 enum GNUNET_BLOCK_Type type,
148 uint32_t priority, 148 uint32_t priority,
149 uint32_t anonymity, 149 uint32_t anonymity,
150 struct GNUNET_TIME_Absolute 150 struct GNUNET_TIME_Absolute
@@ -189,14 +189,14 @@ check_value (void *cls,
189 189
190static void 190static void
191check_nothing (void *cls, 191check_nothing (void *cls,
192 const GNUNET_HashCode * key, 192 const GNUNET_HashCode * key,
193 uint32_t size, 193 uint32_t size,
194 const void *data, 194 const void *data,
195 uint32_t type, 195 enum GNUNET_BLOCK_Type type,
196 uint32_t priority, 196 uint32_t priority,
197 uint32_t anonymity, 197 uint32_t anonymity,
198 struct GNUNET_TIME_Absolute 198 struct GNUNET_TIME_Absolute
199 expiration, uint64_t uid) 199 expiration, uint64_t uid)
200{ 200{
201 struct CpsRunContext *crc = cls; 201 struct CpsRunContext *crc = cls;
202 202