-LRN: use correct character counting, instead of byte counting
[oweals/gnunet.git] / src / datastore / test_datastore_api_management.c
1 /*
2      This file is part of GNUnet.
3      (C) 2004, 2005, 2006, 2007, 2009, 2011 Christian Grothoff (and other contributing authors)
4
5      GNUnet is free software; you can redistribute it and/or modify
6      it under the terms of the GNU General Public License as published
7      by the Free Software Foundation; either version 3, or (at your
8      option) any later version.
9
10      GNUnet is distributed in the hope that it will be useful, but
11      WITHOUT ANY WARRANTY; without even the implied warranty of
12      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13      General Public License for more details.
14
15      You should have received a copy of the GNU General Public License
16      along with GNUnet; see the file COPYING.  If not, write to the
17      Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18      Boston, MA 02111-1307, USA.
19 */
20 /*
21  * @file datastore/test_datastore_api_management.c
22  * @brief Test for the space management functions of the datastore implementation.
23  * @author Christian Grothoff
24  */
25
26 #include "platform.h"
27 #include "gnunet_util_lib.h"
28 #include "gnunet_protocols.h"
29 #include "gnunet_datastore_service.h"
30
31 #define VERBOSE GNUNET_EXTRA_LOGGING
32
33 /**
34  * How long until we give up on transmitting the message?
35  */
36 #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60)
37
38 /**
39  * Number of iterations to run; must be large enough
40  * so that the quota will be exceeded!
41  */
42 #define ITERATIONS 5000
43
44 static struct GNUNET_DATASTORE_Handle *datastore;
45
46 static struct GNUNET_TIME_Absolute now;
47
48 static int ok;
49
50 static const char *plugin_name;
51
52 static size_t
53 get_size (int i)
54 {
55   return 8 + 8 * (i % 256);
56 }
57
58
59 static const void *
60 get_data (int i)
61 {
62   static char buf[60000];
63
64   memset (buf, i, 8 + 8 * (i % 256));
65   return buf;
66 }
67
68
69 static int
70 get_type (int i)
71 {
72   return 1;
73 }
74
75
76 static int
77 get_priority (int i)
78 {
79   return i + 1;
80 }
81
82
83 static int
84 get_anonymity (int i)
85 {
86   return i;
87 }
88
89
90 static struct GNUNET_TIME_Absolute
91 get_expiration (int i)
92 {
93   struct GNUNET_TIME_Absolute av;
94
95   av.abs_value = now.abs_value + i * 1000;
96   return av;
97 }
98
99 enum RunPhase
100 {
101   RP_PUT,
102   RP_GET,
103   RP_DONE,
104   RP_GET_FAIL
105 };
106
107
108 struct CpsRunContext
109 {
110   GNUNET_HashCode key;
111   int i;
112   int found;
113   const struct GNUNET_CONFIGURATION_Handle *cfg;
114   void *data;
115   enum RunPhase phase;
116   uint64_t offset;
117 };
118
119
120 static void
121 run_continuation (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc);
122
123
124 static void
125 check_success (void *cls, int success, struct GNUNET_TIME_Absolute min_expiration, const char *msg)
126 {
127   struct CpsRunContext *crc = cls;
128
129   if (GNUNET_OK != success)
130     GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "%s\n", msg);
131   GNUNET_assert (GNUNET_OK == success);
132   GNUNET_free_non_null (crc->data);
133   crc->data = NULL;
134   GNUNET_SCHEDULER_add_continuation (&run_continuation, crc,
135                                      GNUNET_SCHEDULER_REASON_PREREQ_DONE);
136 }
137
138
139 static void
140 check_value (void *cls, const GNUNET_HashCode * key, size_t size,
141              const void *data, enum GNUNET_BLOCK_Type type, uint32_t priority,
142              uint32_t anonymity, struct GNUNET_TIME_Absolute expiration,
143              uint64_t uid)
144 {
145   struct CpsRunContext *crc = cls;
146   int i;
147
148   if (NULL == key)
149   {
150     crc->phase = RP_GET_FAIL;
151     GNUNET_SCHEDULER_add_continuation (&run_continuation, crc,
152                                        GNUNET_SCHEDULER_REASON_PREREQ_DONE);
153     return;
154   }
155   i = crc->i;
156   GNUNET_assert (size == get_size (i));
157   GNUNET_assert (0 == memcmp (data, get_data (i), size));
158   GNUNET_assert (type == get_type (i));
159   GNUNET_assert (priority == get_priority (i));
160   GNUNET_assert (anonymity == get_anonymity (i));
161   GNUNET_assert (expiration.abs_value == get_expiration (i).abs_value);
162   crc->offset++;
163   crc->i--;
164   if (crc->i == 0)
165     crc->phase = RP_DONE;
166   GNUNET_SCHEDULER_add_continuation (&run_continuation, crc,
167                                      GNUNET_SCHEDULER_REASON_PREREQ_DONE);
168 }
169
170
171 static void
172 check_nothing (void *cls, const GNUNET_HashCode * key, size_t size,
173                const void *data, enum GNUNET_BLOCK_Type type, uint32_t priority,
174                uint32_t anonymity, struct GNUNET_TIME_Absolute expiration,
175                uint64_t uid)
176 {
177   struct CpsRunContext *crc = cls;
178
179   GNUNET_assert (key == NULL);
180   if (0 == --crc->i)
181     crc->phase = RP_DONE;
182   GNUNET_SCHEDULER_add_continuation (&run_continuation, crc,
183                                      GNUNET_SCHEDULER_REASON_PREREQ_DONE);
184 }
185
186
187 static void
188 run_continuation (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
189 {
190   struct CpsRunContext *crc = cls;
191
192   ok = (int) crc->phase;
193   switch (crc->phase)
194   {
195   case RP_PUT:
196 #if VERBOSE
197     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Executing `%s' number %u\n", "PUT",
198                 crc->i);
199 #endif
200     GNUNET_CRYPTO_hash (&crc->i, sizeof (int), &crc->key);
201     GNUNET_DATASTORE_put (datastore, 0, &crc->key, get_size (crc->i),
202                           get_data (crc->i), get_type (crc->i),
203                           get_priority (crc->i), get_anonymity (crc->i), 0,
204                           get_expiration (crc->i), 1, 1, TIMEOUT,
205                           &check_success, crc);
206     crc->i++;
207     if (crc->i == ITERATIONS)
208     {
209       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
210                   "Sleeping to give datastore time to clean up\n");
211       sleep (1);
212       crc->phase = RP_GET;
213       crc->i--;
214     }
215     break;
216   case RP_GET:
217 #if VERBOSE
218     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Executing `%s' number %u\n", "GET",
219                 crc->i);
220 #endif
221     GNUNET_CRYPTO_hash (&crc->i, sizeof (int), &crc->key);
222     GNUNET_DATASTORE_get_key (datastore, crc->offset++, &crc->key,
223                               get_type (crc->i), 1, 1, TIMEOUT, &check_value,
224                               crc);
225     break;
226   case RP_GET_FAIL:
227 #if VERBOSE
228     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Executing `%s' number %u\n", "GET(f)",
229                 crc->i);
230 #endif
231     GNUNET_CRYPTO_hash (&crc->i, sizeof (int), &crc->key);
232     GNUNET_DATASTORE_get_key (datastore, crc->offset++, &crc->key,
233                               get_type (crc->i), 1, 1, TIMEOUT, &check_nothing,
234                               crc);
235     break;
236   case RP_DONE:
237     GNUNET_assert (0 == crc->i);
238 #if VERBOSE
239     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Finished, disconnecting\n");
240 #endif
241     GNUNET_DATASTORE_disconnect (datastore, GNUNET_YES);
242     GNUNET_free (crc);
243     ok = 0;
244   }
245 }
246
247
248 static void
249 run_tests (void *cls, int success, struct GNUNET_TIME_Absolute min_expiration, const char *msg)
250 {
251   struct CpsRunContext *crc = cls;
252
253   if (success != GNUNET_YES)
254   {
255     FPRINTF (stderr,
256              "Test 'put' operation failed with error `%s' database likely not setup, skipping test.",
257              msg);
258     GNUNET_free (crc);
259     return;
260   }
261   GNUNET_SCHEDULER_add_continuation (&run_continuation, crc,
262                                      GNUNET_SCHEDULER_REASON_PREREQ_DONE);
263 }
264
265
266 static void
267 run (void *cls, char *const *args, const char *cfgfile,
268      const struct GNUNET_CONFIGURATION_Handle *cfg)
269 {
270   struct CpsRunContext *crc;
271   static GNUNET_HashCode zkey;
272
273   crc = GNUNET_malloc (sizeof (struct CpsRunContext));
274   crc->cfg = cfg;
275   crc->phase = RP_PUT;
276   now = GNUNET_TIME_absolute_get ();
277   datastore = GNUNET_DATASTORE_connect (cfg);
278   if (NULL ==
279       GNUNET_DATASTORE_put (datastore, 0, &zkey, 4, "TEST",
280                             GNUNET_BLOCK_TYPE_TEST, 0, 0, 0,
281                             GNUNET_TIME_relative_to_absolute
282                             (GNUNET_TIME_UNIT_SECONDS), 0, 1,
283                             GNUNET_TIME_UNIT_MINUTES, &run_tests, crc))
284   {
285     FPRINTF (stderr, "%s",  "Test 'put' operation failed.\n");
286     GNUNET_free (crc);
287     ok = 1;
288   }
289 }
290
291
292
293 static int
294 check ()
295 {
296   struct GNUNET_OS_Process *proc;
297   char cfg_name[128];
298
299   char *const argv[] = {
300     "test-datastore-api-management",
301     "-c",
302     cfg_name,
303 #if VERBOSE
304     "-L", "DEBUG",
305 #endif
306     NULL
307   };
308   struct GNUNET_GETOPT_CommandLineOption options[] = {
309     GNUNET_GETOPT_OPTION_END
310   };
311   GNUNET_snprintf (cfg_name, sizeof (cfg_name),
312                    "test_datastore_api_data_%s.conf", plugin_name);
313   proc =
314       GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm",
315                                "gnunet-service-arm",
316 #if VERBOSE
317                                "-L", "DEBUG",
318 #endif
319                                "-c", cfg_name, NULL);
320   GNUNET_assert (NULL != proc);
321   GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, argv,
322                       "test-datastore-api-management", "nohelp", options, &run,
323                       NULL);
324   sleep (1);                    /* give datastore chance to process 'DROP' request */
325   if (0 != GNUNET_OS_process_kill (proc, SIGTERM))
326   {
327     GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill");
328     ok = 1;
329   }
330   GNUNET_OS_process_wait (proc);
331   GNUNET_OS_process_close (proc);
332   proc = NULL;
333   if (ok != 0)
334     FPRINTF (stderr, "Missed some testcases: %u\n", ok);
335   return ok;
336 }
337
338 int
339 main (int argc, char *argv[])
340 {
341   int ret;
342
343   char *pos;
344   char dir_name[128];
345
346   sleep (1);
347   /* determine name of plugin to use */
348   plugin_name = argv[0];
349   while (NULL != (pos = strstr (plugin_name, "_")))
350     plugin_name = pos + 1;
351   if (NULL != (pos = strstr (plugin_name, ".")))
352     pos[0] = 0;
353   else
354     pos = (char *) plugin_name;
355
356   GNUNET_snprintf (dir_name, sizeof (dir_name), "/tmp/test-gnunet-datastore-%s",
357                    plugin_name);
358   GNUNET_DISK_directory_remove (dir_name);
359   GNUNET_log_setup ("test-datastore-api-management",
360 #if VERBOSE
361                     "DEBUG",
362 #else
363                     "WARNING",
364 #endif
365                     NULL);
366   ret = check ();
367   if (pos != plugin_name)
368     pos[0] = '.';
369   GNUNET_DISK_directory_remove (dir_name);
370   return ret;
371 }
372
373 /* end of test_datastore_api_management.c */