src/testbed/test_testbed_api_peer_reconfiguration.c

   1 /*
   2       This file is part of GNUnet
   3       Copyright (C) 2008--2013 GNUnet e.V.
   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., 51 Franklin Street, Fifth Floor,
  18       Boston, MA 02110-1301, USA.
  19  */
  20
  21 /**
  22  * @file testbed/test_testbed_api_peer_reconfiguration.c
  23  * @brief testcase for testing GNUNET_TESTBED_peer_manage_service()
  24  *          implementation
  25  * @author Sree Harsha Totakura <sreeharsha@totakura.in>
  26  */
  27
  28 #include "platform.h"
  29 #include "gnunet_util_lib.h"
  30 #include "gnunet_testbed_service.h"
  31
  32 /**
  33  * Number of peers we want to start
  34  */
  35 #define NUM_PEERS 1
  36
  37 /**
  38  * The array of peers; we get them from the testbed
  39  */
  40 static struct GNUNET_TESTBED_Peer **peers;
  41
  42 /**
  43  * Operation handle
  44  */
  45 static struct GNUNET_TESTBED_Operation *op;
  46
  47 /**
  48  * Abort task identifier
  49  */
  50 static struct GNUNET_SCHEDULER_Task * abort_task;
  51
  52 /**
  53  * States in this test
  54  */
  55 enum {
  56
  57   /**
  58    * Test has just been initialized
  59    */
  60   STATE_INIT,
  61
  62   /**
  63    * Peers have been started
  64    */
  65   STATE_PEER_STARTED,
  66
  67   /**
  68    * Peer has been reconfigured.  Test completed successfully
  69    */
  70   STATE_PEER_RECONFIGURED
  71
  72 } state;
  73
  74 /**
  75  * Fail testcase
  76  */
  77 #define FAIL_TEST(cond, ret) do {                               \
  78     if (!(cond)) {                                              \
  79       GNUNET_break(0);                                          \
  80       if (NULL != abort_task)               \
  81         GNUNET_SCHEDULER_cancel (abort_task);                   \
  82       abort_task = GNUNET_SCHEDULER_add_now (&do_abort, NULL);  \
  83       ret;                                                      \
  84     }                                                           \
  85   } while (0)
  86
  87
  88 /**
  89  * Abort task
  90  *
  91  * @param cls NULL
  92  */
  93 static void
  94 do_abort (void *cls)
  95 {
  96   GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Aborting\n");
  97   abort_task = NULL;
  98   if (NULL != op)
  99   {
 100     GNUNET_TESTBED_operation_done (op);
 101     op = NULL;
 102   }
 103   GNUNET_SCHEDULER_shutdown();
 104 }
 105
 106
 107 /**
 108  * Signature of the event handler function called by the
 109  * respective event controller.
 110  *
 111  * @param cls closure
 112  * @param event information about the event
 113  */
 114 static void
 115 controller_cb (void *cls, const struct GNUNET_TESTBED_EventInformation *event)
 116 {
 117   if (STATE_PEER_STARTED != state)
 118     return;
 119   if (GNUNET_TESTBED_ET_OPERATION_FINISHED != event->type)
 120   {
 121     GNUNET_TESTBED_operation_done (op);
 122     op = NULL;
 123     FAIL_TEST (0, return);
 124   }
 125   if (NULL != event->details.operation_finished.emsg)
 126   {
 127     fprintf (stderr, "Operation failed: %s\n",
 128              event->details.operation_finished.emsg);
 129     GNUNET_TESTBED_operation_done (op);
 130     op = NULL;
 131     FAIL_TEST (0, return);
 132   }
 133   GNUNET_TESTBED_operation_done (op);
 134   state = STATE_PEER_RECONFIGURED;
 135   GNUNET_SCHEDULER_cancel (abort_task);
 136   abort_task = NULL;
 137   GNUNET_SCHEDULER_shutdown ();
 138 }
 139
 140
 141 /**
 142  * Signature of a main function for a testcase.
 143  *
 144  * @param cls closure
 145  * @param h the run handle
 146  * @param num_peers number of peers in 'peers'
 147  * @param peers_ handle to peers run in the testbed
 148  * @param links_succeeded the number of overlay link connection attempts that
 149  *          succeeded
 150  * @param links_failed the number of overlay link connection attempts that
 151  *          failed
 152  */
 153 static void
 154 test_master (void *cls,
 155              struct GNUNET_TESTBED_RunHandle *h,
 156              unsigned int num_peers,
 157              struct GNUNET_TESTBED_Peer **peers_,
 158              unsigned int links_succeeded,
 159              unsigned int links_failed)
 160 {
 161   struct GNUNET_CONFIGURATION_Handle *cfg;
 162
 163   FAIL_TEST (NUM_PEERS == num_peers, return);
 164   state = STATE_PEER_STARTED;
 165   peers = peers_;
 166   cfg = GNUNET_CONFIGURATION_create ();
 167   FAIL_TEST (GNUNET_OK == GNUNET_CONFIGURATION_load
 168              (cfg, "test_testbed_api_testbed_run_topologyrandom.conf"), return);
 169   op = GNUNET_TESTBED_peer_update_configuration (peers[0], cfg);
 170   GNUNET_CONFIGURATION_destroy (cfg);
 171   FAIL_TEST (NULL != op, return);
 172   abort_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply
 173                                              (GNUNET_TIME_UNIT_SECONDS, 30),
 174                                              &do_abort, NULL);
 175 }
 176
 177
 178 /**
 179  * Main function
 180  */
 181 int
 182 main (int argc, char **argv)
 183 {
 184   state = STATE_INIT;
 185   (void) GNUNET_TESTBED_test_run ("test_testbed_api_peer_reconfiguration",
 186                                   "test_testbed_api.conf",
 187                                   NUM_PEERS,
 188                                   1LL << GNUNET_TESTBED_ET_OPERATION_FINISHED,
 189                                   &controller_cb, NULL,
 190                                   &test_master, NULL);
 191   if (STATE_PEER_RECONFIGURED != state)
 192     return 1;
 193   return 0;
 194 }