From ba8ca593c236036cfeaa0b1bafd6a79c851017d8 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 5 Sep 2010 15:58:48 +0000 Subject: [PATCH] skeleton for list_updateable testcase --- src/fs/Makefile.am | 8 + src/fs/test_fs_namespace_list_updateable.c | 226 +++++++++++++++++++++ 2 files changed, 234 insertions(+) create mode 100644 src/fs/test_fs_namespace_list_updateable.c diff --git a/src/fs/Makefile.am b/src/fs/Makefile.am index 4a7e4621a..bcf5f460c 100644 --- a/src/fs/Makefile.am +++ b/src/fs/Makefile.am @@ -122,6 +122,7 @@ check_PROGRAMS = \ test_fs_getopt \ test_fs_list_indexed \ test_fs_namespace \ + test_fs_namespace_list_updateable \ test_fs_publish \ test_fs_publish_persistence \ test_fs_search \ @@ -152,6 +153,7 @@ TESTS = \ test_fs_file_information \ test_fs_list_indexed \ test_fs_namespace \ + test_fs_namespace_list_updateable \ test_fs_publish \ test_fs_publish_persistence \ test_fs_search \ @@ -215,6 +217,12 @@ test_fs_namespace_LDADD = \ $(top_builddir)/src/fs/libgnunetfs.la \ $(top_builddir)/src/util/libgnunetutil.la +test_fs_namespace_list_updateable_SOURCES = \ + test_fs_namespace_list_updateable.c +test_fs_namespace_list_updateable_LDADD = \ + $(top_builddir)/src/fs/libgnunetfs.la \ + $(top_builddir)/src/util/libgnunetutil.la + test_fs_publish_SOURCES = \ test_fs_publish.c test_fs_publish_LDADD = \ diff --git a/src/fs/test_fs_namespace_list_updateable.c b/src/fs/test_fs_namespace_list_updateable.c new file mode 100644 index 000000000..c2351471e --- /dev/null +++ b/src/fs/test_fs_namespace_list_updateable.c @@ -0,0 +1,226 @@ +/* + This file is part of GNUnet. + (C) 2005, 2006, 2008, 2009 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ + +/** + * @file fs/test_fs_namespace.c + * @brief Test for fs_namespace.c + * @author Christian Grothoff + * + * TODO: + * - add timeout task + */ +#include "platform.h" +#include "gnunet_util_lib.h" +#include "gnunet_arm_service.h" +#include "gnunet_fs_service.h" + +#define VERBOSE GNUNET_NO + +#define START_ARM GNUNET_YES + +static struct GNUNET_SCHEDULER_Handle *sched; + +static struct PeerContext p1; + +static struct GNUNET_FS_Handle *fs; + +static int err; + +static struct GNUNET_FS_Namespace *ns; + +static struct GNUNET_TIME_Absolute expiration; + +static struct GNUNET_CONTAINER_MetaData *meta; + +static struct GNUNET_FS_Uri *uri_this; + +static struct GNUNET_FS_Uri *uri_next; + + +struct PeerContext +{ + struct GNUNET_CONFIGURATION_Handle *cfg; +#if START_ARM + pid_t arm_pid; +#endif +}; + + +static void * +progress_cb (void *cls, + const struct GNUNET_FS_ProgressInfo *event) +{ + return NULL; +} + + +static void +setup_peer (struct PeerContext *p, const char *cfgname) +{ + p->cfg = GNUNET_CONFIGURATION_create (); +#if START_ARM + p->arm_pid = GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", + "gnunet-service-arm", +#if VERBOSE + "-L", "DEBUG", +#endif + "-c", cfgname, NULL); +#endif + GNUNET_assert (GNUNET_OK == GNUNET_CONFIGURATION_load (p->cfg, cfgname)); +} + + +static void +stop_arm (struct PeerContext *p) +{ +#if START_ARM + if (0 != PLIBC_KILL (p->arm_pid, SIGTERM)) + GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); + if (GNUNET_OS_process_wait(p->arm_pid) != GNUNET_OK) + GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "ARM process %u stopped\n", p->arm_pid); +#endif + if (uri_this != NULL) + GNUNET_FS_uri_destroy (uri_this); + if (uri_next != NULL) + GNUNET_FS_uri_destroy (uri_next); + if (ns != NULL) + GNUNET_FS_namespace_delete (ns, GNUNET_NO); + if (meta != NULL) + GNUNET_CONTAINER_meta_data_destroy (meta); + GNUNET_CONFIGURATION_destroy (p->cfg); +} + + + +static void +sks_cont_next (void *cls, + const struct GNUNET_FS_Uri *uri, + const char *emsg) +{ + GNUNET_assert (NULL == emsg); +} + + +static void +sks_cont_this (void *cls, + const struct GNUNET_FS_Uri *uri, + const char *emsg) +{ + GNUNET_assert (NULL == emsg); + + GNUNET_FS_publish_sks (fs, + ns, + "next", + "future", + meta, + uri_next, + expiration, + 1, 1, + GNUNET_FS_PUBLISH_OPTION_NONE, + &sks_cont_next, + NULL); + +} + + + +static void +testNamespace () +{ + + ns = GNUNET_FS_namespace_create (fs, + "testNamespace"); + GNUNET_assert (NULL != ns); + expiration = GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_MINUTES); + meta = GNUNET_CONTAINER_meta_data_create (); + + uri_this = + GNUNET_FS_uri_parse ("gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.42", NULL); + uri_next = + GNUNET_FS_uri_parse ("gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.43", NULL); + GNUNET_FS_publish_sks (fs, + ns, + "this", + "next", + meta, + uri_this, + expiration, + 1, 1, + GNUNET_FS_PUBLISH_OPTION_NONE, + &sks_cont_this, + NULL); +} + + +static void +run (void *cls, + struct GNUNET_SCHEDULER_Handle *s, + char *const *args, + const char *cfgfile, + const struct GNUNET_CONFIGURATION_Handle *cfg) +{ + sched = s; + setup_peer (&p1, "test_fs_namespace_data.conf"); + fs = GNUNET_FS_start (sched, + cfg, + "test-fs-namespace", + &progress_cb, + NULL, + GNUNET_FS_FLAGS_NONE, + GNUNET_FS_OPTIONS_END); + testNamespace (); +} + + +int +main (int argc, char *argv[]) +{ + char *const argvx[] = { + "test-fs-namespace", + "-c", + "test_fs_namespace_data.conf", +#if VERBOSE + "-L", "DEBUG", +#endif + NULL + }; + struct GNUNET_GETOPT_CommandLineOption options[] = { + GNUNET_GETOPT_OPTION_END + }; + + GNUNET_log_setup ("test_fs_namespace_list_updateable", +#if VERBOSE + "DEBUG", +#else + "WARNING", +#endif + NULL); + GNUNET_PROGRAM_run ((sizeof (argvx) / sizeof (char *)) - 1, + argvx, "test-fs-namespace", + "nohelp", options, &run, NULL); + stop_arm (&p1); + GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-namespace/"); + return err; +} + + +/* end of test_fs_namespace_list_updateable.c */ -- 2.25.1