- setup_peer (&p1, "test_core_quota_peer1.conf");
- setup_peer (&p2, "test_core_quota_peer2.conf");
-
- GNUNET_assert (GNUNET_SYSERR != GNUNET_CONFIGURATION_get_value_number (p1.cfg,
- "CORE",
- "TOTAL_QUOTA_IN",
- ¤t_quota_p1_in));
- GNUNET_assert (GNUNET_SYSERR != GNUNET_CONFIGURATION_get_value_number (p2.cfg,
- "CORE",
- "TOTAL_QUOTA_IN",
- ¤t_quota_p2_in));
- GNUNET_assert (GNUNET_SYSERR != GNUNET_CONFIGURATION_get_value_number (p1.cfg,
- "CORE",
- "TOTAL_QUOTA_OUT",
- ¤t_quota_p1_out));
- GNUNET_assert (GNUNET_SYSERR != GNUNET_CONFIGURATION_get_value_number (p2.cfg,
- "CORE",
- "TOTAL_QUOTA_OUT",
- ¤t_quota_p2_out));
-
- GNUNET_CORE_connect (p1.cfg, 1,
- &p1,
- &init_notify,
- &connect_notify,
- &disconnect_notify,
- NULL,
- &inbound_notify,
- GNUNET_YES, &outbound_notify, GNUNET_YES, handlers);
+ err_task =
+ GNUNET_SCHEDULER_add_delayed (TIMEOUT,
+ &terminate_task_error,
+ NULL);
+ GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
+ NULL);
+ if (test == SYMMETRIC)
+ {
+ setup_peer (&p1,
+ "test_core_quota_peer1.conf");
+ setup_peer (&p2,
+ "test_core_quota_peer2.conf");
+ }
+ else if (test == ASYMMETRIC_SEND_LIMITED)
+ {
+ setup_peer (&p1,
+ "test_core_quota_asymmetric_send_limit_peer1.conf");
+ setup_peer (&p2,
+ "test_core_quota_asymmetric_send_limit_peer2.conf");
+ }
+ else if (test == ASYMMETRIC_RECV_LIMITED)
+ {
+ setup_peer (&p1,
+ "test_core_quota_asymmetric_recv_limited_peer1.conf");
+ setup_peer (&p2,
+ "test_core_quota_asymmetric_recv_limited_peer2.conf");
+ }
+
+ GNUNET_assert (test != -1);
+ GNUNET_assert (GNUNET_SYSERR !=
+ GNUNET_CONFIGURATION_get_value_size (p1.cfg,
+ "ATS",
+ "WAN_QUOTA_IN",
+ ¤t_quota_p1_in));
+ GNUNET_assert (GNUNET_SYSERR !=
+ GNUNET_CONFIGURATION_get_value_size (p2.cfg,
+ "ATS",
+ "WAN_QUOTA_IN",
+ ¤t_quota_p2_in));
+ GNUNET_assert (GNUNET_SYSERR !=
+ GNUNET_CONFIGURATION_get_value_size (p1.cfg,
+ "ATS",
+ "WAN_QUOTA_OUT",
+ ¤t_quota_p1_out));
+ GNUNET_assert (GNUNET_SYSERR !=
+ GNUNET_CONFIGURATION_get_value_size (p2.cfg,
+ "ATS",
+ "WAN_QUOTA_OUT",
+ ¤t_quota_p2_out));
+
+ p1.ch = GNUNET_CORE_connect (p1.cfg,
+ &p1,
+ &init_notify,
+ &connect_notify,
+ &disconnect_notify,
+ handlers);