- tmp commit

2 files changed, 56 insertions, 9 deletions

diff --git a/src/ats/gnunet-service-ats_addresses_mlp.c b/src/ats/gnunet-service-ats_addresses_mlp.c
index 57692440b..e111dae95 100644
--- a/src/ats/gnunet-service-ats_addresses_mlp.c
+++ b/src/ats/gnunet-service-ats_addresses_mlp.c
@@ -1341,13 +1341,12 @@ update_quality (struct GAS_MLP_Handle *mlp, struct ATS_Address * address)
 {
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Updating quality metrics for peer `%s'\n",
       GNUNET_i2s (&address->peer));
-
+  GNUNET_assert (NULL != address->ats);
   struct MLP_information *mlpi = address->mlp_information;
   struct GNUNET_ATS_Information *ats = address->ats;
   GNUNET_assert (mlpi != NULL);
 
   int c;
-
   for (c = 0; c < GNUNET_ATS_QualityPropertiesCount; c++)
   {
     int index = mlp_lookup_ats(address, mlp->q[c]);
@@ -1573,7 +1572,6 @@ GAS_mlp_address_update (struct GAS_MLP_Handle *mlp, struct GNUNET_CONTAINER_Mult
 
       GNUNET_CONTAINER_DLL_insert (peer->head, peer->tail, address);
     }
-
     update_quality (mlp, address);
   }
   else
diff --git a/src/ats/perf_ats_mlp.c b/src/ats/perf_ats_mlp.c
index 2daac4769..0d261374b 100644
--- a/src/ats/perf_ats_mlp.c
+++ b/src/ats/perf_ats_mlp.c
@@ -45,10 +45,31 @@ static int ret;
 
 struct GNUNET_STATISTICS_Handle * stats;
 
-//struct GNUNET_CONTAINER_MultiHashMap * addresses;
+struct GNUNET_CONTAINER_MultiHashMap * amap;
 
 struct GAS_MLP_Handle *mlp;
 
+struct PeerContext
+{
+  struct GNUNET_PeerIdentity id;
+
+  struct Address *addr;
+};
+
+struct Address
+{
+  char *plugin;
+  size_t plugin_len;
+
+  void *addr;
+  size_t addr_len;
+
+  struct GNUNET_ATS_Information *ats;
+  int ats_count;
+
+  void *session;
+};
+
 static void
 check (void *cls, char *const *args, const char *cfgfile,
        const struct GNUNET_CONFIGURATION_Handle *cfg)
@@ -58,6 +79,10 @@ check (void *cls, char *const *args, const char *cfgfile,
   ret = 1;
   return;
 #endif
+  unsigned int c = 0;
+  unsigned int c2 = 0;
+  unsigned int ca = 0;
+  //char * pid;
 
   if (peers == 0)
     peers = DEF_PEERS;
@@ -66,18 +91,42 @@ check (void *cls, char *const *args, const char *cfgfile,
 
   GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Setting up %u peers with %u addresses per peer\n", peers, addresses);
 
-  GNUNET_HashCode hash;
-  //memset (&hash, '\0', sizeof (GNUNET_HashCode));
-  //hash.bits[0] = 1;
-  //GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "peer %s\n", GNUNET_h2s_full (&hash));
+  struct PeerContext p[peers];
+  struct ATS_Address a[addresses * peers];
+
+  amap = GNUNET_CONTAINER_multihashmap_create(addresses * peers);
 
   mlp = GAS_mlp_init (cfg, NULL, MLP_MAX_EXEC_DURATION, MLP_MAX_ITERATIONS);
   mlp->auto_solve = GNUNET_NO;
-
+  for (c=0; c < peers; c++)
+  {
+    GNUNET_CRYPTO_hash_create_random(GNUNET_CRYPTO_QUALITY_WEAK, &p[c].id.hashPubKey);
+    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "peer %s\n", GNUNET_h2s_full(&p[c].id.hashPubKey));
+
+    for (c2=0; c2 < addresses; c2++)
+    {
+      a[ca].peer = p[c].id;
+      a[ca].plugin = strdup("test");
+      a[ca].addr = GNUNET_HELLO_address_allocate(&a[ca].peer, a[ca].plugin, NULL, 0);
+      a[ca].addr_len = GNUNET_HELLO_address_get_size(a[ca].addr);
+      a[ca].ats = NULL;
+      ca++;
+      GAS_mlp_address_update(mlp, amap, &a[c2]);
+    }
+  }
+
+  GAS_mlp_solve_problem(mlp);
 
 
   GAS_mlp_done (mlp);
 
+  for (c2=0; c2 < (peers * addresses); c2++)
+  {
+    GNUNET_free (a[c2].plugin);
+    GNUNET_free (a[c2].addr);
+//      GAS_mlp_address_update(mlp, amap, &a[c2]);
+  }
+
   ret = 0;
   return;
 }