diff options
-rw-r--r-- | src/transport/plugin_transport_udp.c | 15 | ||||
-rw-r--r-- | src/transport/test_transport_api_reliability.c | 12 | ||||
-rw-r--r-- | src/transport/transport.conf.in | 2 |
3 files changed, 17 insertions, 12 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c index 4eb4b7f36..4fef8e0c6 100644 --- a/src/transport/plugin_transport_udp.c +++ b/src/transport/plugin_transport_udp.c | |||
@@ -2986,13 +2986,12 @@ remove_timeout_messages_and_select (struct Plugin *plugin, | |||
2986 | if (GNUNET_TIME_UNIT_ZERO.rel_value_us == remaining.rel_value_us) | 2986 | if (GNUNET_TIME_UNIT_ZERO.rel_value_us == remaining.rel_value_us) |
2987 | { | 2987 | { |
2988 | /* Message timed out */ | 2988 | /* Message timed out */ |
2989 | udpw->qc (udpw->qc_cls, | ||
2990 | udpw, | ||
2991 | GNUNET_SYSERR); | ||
2992 | /* Remove message */ | ||
2993 | removed = GNUNET_YES; | 2989 | removed = GNUNET_YES; |
2994 | dequeue (plugin, | 2990 | dequeue (plugin, |
2995 | udpw); | 2991 | udpw); |
2992 | udpw->qc (udpw->qc_cls, | ||
2993 | udpw, | ||
2994 | GNUNET_SYSERR); | ||
2996 | GNUNET_free (udpw); | 2995 | GNUNET_free (udpw); |
2997 | 2996 | ||
2998 | if (sock == plugin->sockv4) | 2997 | if (sock == plugin->sockv4) |
@@ -3166,11 +3165,11 @@ udp_select_send (struct Plugin *plugin, | |||
3166 | else | 3165 | else |
3167 | { | 3166 | { |
3168 | GNUNET_break (0); | 3167 | GNUNET_break (0); |
3168 | dequeue (plugin, | ||
3169 | udpw); | ||
3169 | udpw->qc (udpw->qc_cls, | 3170 | udpw->qc (udpw->qc_cls, |
3170 | udpw, | 3171 | udpw, |
3171 | GNUNET_SYSERR); | 3172 | GNUNET_SYSERR); |
3172 | dequeue (plugin, | ||
3173 | udpw); | ||
3174 | notify_session_monitor (plugin, | 3173 | notify_session_monitor (plugin, |
3175 | udpw->session, | 3174 | udpw->session, |
3176 | GNUNET_TRANSPORT_SS_UPDATE); | 3175 | GNUNET_TRANSPORT_SS_UPDATE); |
@@ -3182,6 +3181,8 @@ udp_select_send (struct Plugin *plugin, | |||
3182 | udpw->msg_size, | 3181 | udpw->msg_size, |
3183 | a, | 3182 | a, |
3184 | slen); | 3183 | slen); |
3184 | dequeue (plugin, | ||
3185 | udpw); | ||
3185 | if (GNUNET_SYSERR == sent) | 3186 | if (GNUNET_SYSERR == sent) |
3186 | { | 3187 | { |
3187 | /* Failure */ | 3188 | /* Failure */ |
@@ -3226,8 +3227,6 @@ udp_select_send (struct Plugin *plugin, | |||
3226 | udpw, | 3227 | udpw, |
3227 | GNUNET_OK); | 3228 | GNUNET_OK); |
3228 | } | 3229 | } |
3229 | dequeue (plugin, | ||
3230 | udpw); | ||
3231 | notify_session_monitor (plugin, | 3230 | notify_session_monitor (plugin, |
3232 | udpw->session, | 3231 | udpw->session, |
3233 | GNUNET_TRANSPORT_SS_UPDATE); | 3232 | GNUNET_TRANSPORT_SS_UPDATE); |
diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c index fcada3e88..e24530008 100644 --- a/src/transport/test_transport_api_reliability.c +++ b/src/transport/test_transport_api_reliability.c | |||
@@ -31,6 +31,12 @@ | |||
31 | #include "gauger.h" | 31 | #include "gauger.h" |
32 | #include "transport-testing.h" | 32 | #include "transport-testing.h" |
33 | 33 | ||
34 | |||
35 | /** | ||
36 | * Allow making the problem "bigger". | ||
37 | */ | ||
38 | #define FACTOR 10 | ||
39 | |||
34 | /** | 40 | /** |
35 | * Total number of messages to send | 41 | * Total number of messages to send |
36 | * | 42 | * |
@@ -38,7 +44,7 @@ | |||
38 | * 'MAX_PENDING' in 'gnunet-service-transport_clients.c', otherwise | 44 | * 'MAX_PENDING' in 'gnunet-service-transport_clients.c', otherwise |
39 | * messages may be dropped even for a reliable transport. | 45 | * messages may be dropped even for a reliable transport. |
40 | */ | 46 | */ |
41 | #define TOTAL_MSGS (1024 * 3) | 47 | #define TOTAL_MSGS (1024 * 3 * FACTOR) |
42 | 48 | ||
43 | /** | 49 | /** |
44 | * Message type of test messages | 50 | * Message type of test messages |
@@ -48,12 +54,12 @@ | |||
48 | /** | 54 | /** |
49 | * Testcase timeout | 55 | * Testcase timeout |
50 | */ | 56 | */ |
51 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 90) | 57 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 90 * FACTOR) |
52 | 58 | ||
53 | /** | 59 | /** |
54 | * How long until we give up on transmitting the message? | 60 | * How long until we give up on transmitting the message? |
55 | */ | 61 | */ |
56 | #define TIMEOUT_TRANSMIT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60) | 62 | #define TIMEOUT_TRANSMIT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60 * FACTOR) |
57 | 63 | ||
58 | 64 | ||
59 | /** | 65 | /** |
diff --git a/src/transport/transport.conf.in b/src/transport/transport.conf.in index 82effb235..3718f3224 100644 --- a/src/transport/transport.conf.in +++ b/src/transport/transport.conf.in | |||
@@ -3,7 +3,7 @@ AUTOSTART = @AUTOSTART@ | |||
3 | @JAVAPORT@PORT = 2091 | 3 | @JAVAPORT@PORT = 2091 |
4 | HOSTNAME = localhost | 4 | HOSTNAME = localhost |
5 | BINARY = gnunet-service-transport | 5 | BINARY = gnunet-service-transport |
6 | # PREFIX = valgrind | 6 | PREFIX = valgrind |
7 | NEIGHBOUR_LIMIT = 50 | 7 | NEIGHBOUR_LIMIT = 50 |
8 | ACCEPT_FROM = 127.0.0.1; | 8 | ACCEPT_FROM = 127.0.0.1; |
9 | ACCEPT_FROM6 = ::1; | 9 | ACCEPT_FROM6 = ::1; |