[GNUnet-SVN] r24198 - gnunet/src/regex

[gnunet]

Author: szengel
Date: 2012-10-05 18:41:54 +0200 (Fri, 05 Oct 2012)
New Revision: 24198

Modified:
   gnunet/src/regex/test_regex_big.c
   gnunet/src/regex/test_regex_big.conf
Log:
simple overlay connection working

Modified: gnunet/src/regex/test_regex_big.c
===================================================================
--- gnunet/src/regex/test_regex_big.c   2012-10-05 14:45:51 UTC (rev 24197)
+++ gnunet/src/regex/test_regex_big.c   2012-10-05 16:41:54 UTC (rev 24198)
@@ -113,6 +113,12 @@
    */
   LINKING,
 
+  LINKING_SLAVES,
+
+  LINKING_SLAVES_SUCCESS,
+
+  CONNECTING_PEERS,
+
   CREATING_PEER,
 
   STARTING_PEER
@@ -426,6 +432,7 @@
 static void
 peer_start_cb (void *cls, const char *emsg)
 {
+  unsigned int cnt;
   long i = (long) cls;
   GNUNET_TESTBED_operation_done(op[i]);
   peers_started++;
@@ -434,7 +441,16 @@
 
   if (TOTAL_PEERS == peers_started)
   {
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "ok\n");
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All peers started.\n");
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Linking slave controllers\n");
+
+    for (cnt = 0; cnt < NUM_HOSTS - 1; cnt++)
+    {
+      state[cnt] = LINKING_SLAVES;
+      op[cnt] = GNUNET_TESTBED_get_slave_config ((void*) (long)cnt, 
+                                                master_ctrl, 
+                                                slave_hosts[cnt+1]);
+    }
   }
 }
 
@@ -483,7 +499,11 @@
 
     break;
   case GNUNET_TESTBED_ET_PEER_STOP:
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer stopped\n");
+    break;
   case GNUNET_TESTBED_ET_CONNECT:
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Overlay Connected\n");
+    
     break;
   case GNUNET_TESTBED_ET_OPERATION_FINISHED:
     if (NULL != event->details.operation_finished.emsg)
@@ -492,17 +512,20 @@
                   event->details.operation_finished.emsg);
       GNUNET_assert (0);
     }
-    GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
-    //GNUNET_assert (NULL != event->details.operation_finished.op_cls);
+
     i = (long) event->details.operation_finished.op_cls;
-    op[i] = NULL;
-    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
     switch (state[i])
     {
       case INIT:
         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Init: %u\n", i);
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
         break;
       case LINKING:
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "   Linked host %i\n", i);
         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "   Creating peer...\n");
 
@@ -514,8 +537,48 @@
                                             (void *) i);
         break;
       case CREATING_PEER:
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Peer create\n");
         break;
+      case LINKING_SLAVES:
+       {
+       struct GNUNET_CONFIGURATION_Handle *slave_cfg;
+       GNUNET_assert (NULL != event->details.operation_finished.generic);
+       slave_cfg = GNUNET_CONFIGURATION_dup ((struct 
GNUNET_CONFIGURATION_Handle *)event->details.operation_finished.generic);
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
+       state[i] = LINKING_SLAVES_SUCCESS;
+       op[i] = GNUNET_TESTBED_controller_link ((void *) (long) i,
+                                               master_ctrl,
+                                               slave_hosts[i+1],
+                                               slave_hosts[i],
+                                               slave_cfg,
+                                               GNUNET_NO);
+       GNUNET_CONFIGURATION_destroy (slave_cfg);
+       break;
+       }
+      case LINKING_SLAVES_SUCCESS:
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, " Linking slave %i succeeded\n", 
i);
+       state[0] = CONNECTING_PEERS;
+       op[0] = GNUNET_TESTBED_overlay_configure_topology (NULL,
+                                                          TOTAL_PEERS,
+                                                          peers,
+                                                          
GNUNET_TESTBED_TOPOLOGY_LINE);
+       GNUNET_assert (NULL != op[0]);
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Connecting peers...\n");
+       break;
+      case CONNECTING_PEERS:
+       GNUNET_TESTBED_operation_done 
(event->details.operation_finished.operation);
+       op[i] = NULL;
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "  Operation %u finished\n", i);
+       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peers connected\n");
+       break;
       default:
         GNUNET_break (0);
     }

Modified: gnunet/src/regex/test_regex_big.conf
===================================================================
--- gnunet/src/regex/test_regex_big.conf        2012-10-05 14:45:51 UTC (rev 
24197)
+++ gnunet/src/regex/test_regex_big.conf        2012-10-05 16:41:54 UTC (rev 
24198)
@@ -1,6 +1,3 @@
-#[testbed]
-#ACCEPT_FROM =
-
 [lockmanager]
 AUTOSTART = NO
 ACCEPT_FROM = 127.0.0.1;