max_bps was never used

1 files changed, 36 insertions, 9 deletions

diff --git a/src/transport/test_transport_api_unreliability.c b/src/transport/test_transport_api_unreliability.c
index aa84b8519..a1a4517f8 100644
--- a/src/transport/test_transport_api_unreliability.c
+++ b/src/transport/test_transport_api_unreliability.c
@@ -39,7 +39,7 @@
 #include "transport.h"
 #include "transport-testing.h"
 
-#define VERBOSE GNUNET_NO
+#define VERBOSE GNUNET_YES
 
 #define VERBOSE_ARM GNUNET_NO
 
@@ -75,6 +75,9 @@ char *cfg_file_p1;
 
 char *cfg_file_p2;
 
+uint32_t max_bps_p1;
+uint32_t max_bps_p2;
+
 /*
  * Testcase specific declarations
  */
@@ -393,19 +396,43 @@ notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer,
 
   if (cls == p1)
   {
+    char * sec;
+    long long unsigned int l_bps;
+
+    GNUNET_asprintf(&sec, "transport-%s", test_plugin);
+    if (GNUNET_CONFIGURATION_have_value (p1->cfg, sec, "MAX_BPS"))
+    {
+      GNUNET_CONFIGURATION_get_value_number (p1->cfg, sec, "MAX_BPS",
+                                             &l_bps);
+      max_bps_p1 = l_bps;
+    }
+    else
+      max_bps_p1 = 1024 * 1024 * 1024;
+    GNUNET_free (sec);
+
     GNUNET_TRANSPORT_set_quota (p1->th, &p2->id,
-                                GNUNET_BANDWIDTH_value_init (1024 * 1024 *
-                                                             1024),
-                                GNUNET_BANDWIDTH_value_init (1024 * 1024 *
-                                                             1024));
+                                GNUNET_BANDWIDTH_value_init (max_bps_p1),
+                                GNUNET_BANDWIDTH_value_init (max_bps_p1));
   }
   else if (cls == p2)
   {
+    char * sec;
+    long long unsigned int l_bps;
+
+    GNUNET_asprintf(&sec, "transport-%s", test_plugin);
+    if (GNUNET_CONFIGURATION_have_value (p2->cfg, sec, "MAX_BPS"))
+    {
+      GNUNET_CONFIGURATION_get_value_number (p2->cfg, sec, "MAX_BPS",
+                                             &l_bps);
+      max_bps_p2 = l_bps;
+    }
+    else
+      max_bps_p2 = 1024 * 1024 * 1024;
+    GNUNET_free (sec);
+
     GNUNET_TRANSPORT_set_quota (p2->th, &p1->id,
-                                GNUNET_BANDWIDTH_value_init (1024 * 1024 *
-                                                             1024),
-                                GNUNET_BANDWIDTH_value_init (1024 * 1024 *
-                                                             1024));
+                                GNUNET_BANDWIDTH_value_init (max_bps_p2),
+                                GNUNET_BANDWIDTH_value_init (max_bps_p2));
   }
 }