diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2012-06-15 13:11:46 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2012-06-15 13:11:46 +0000 |
commit | 0bb2d2a34cbd8f1c0118f6203eaf9f41a1570fa7 (patch) | |
tree | ac8af3c2af3091c8945838a5f2403821efa10c27 /src/ats | |
parent | 1dfa405cdd6ad888dff6386d4abecf44ef3828ab (diff) | |
download | gnunet-0bb2d2a34cbd8f1c0118f6203eaf9f41a1570fa7.tar.gz gnunet-0bb2d2a34cbd8f1c0118f6203eaf9f41a1570fa7.zip |
- changed behavior when receiving CONNECT messages ... inbound session and NAT tests work again
Diffstat (limited to 'src/ats')
-rw-r--r-- | src/ats/ats_api_scheduling.c | 18 |
1 files changed, 7 insertions, 11 deletions
diff --git a/src/ats/ats_api_scheduling.c b/src/ats/ats_api_scheduling.c index cdf948291..25296d95e 100644 --- a/src/ats/ats_api_scheduling.c +++ b/src/ats/ats_api_scheduling.c | |||
@@ -384,9 +384,6 @@ find_empty_session_slot (struct GNUNET_ATS_SchedulingHandle *sh, struct Session | |||
384 | sh->session_array_size * 2); | 384 | sh->session_array_size * 2); |
385 | } | 385 | } |
386 | GNUNET_assert (f > 0); | 386 | GNUNET_assert (f > 0); |
387 | GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api", | ||
388 | "Session %p for peer `%s' stored in slot %u \n", | ||
389 | session, GNUNET_i2s (peer), f); | ||
390 | sh->session_array[f].session = session; | 387 | sh->session_array[f].session = session; |
391 | sh->session_array[f].peer = *peer; | 388 | sh->session_array[f].peer = *peer; |
392 | sh->session_array[f].slot_used = GNUNET_YES; | 389 | sh->session_array[f].slot_used = GNUNET_YES; |
@@ -1117,8 +1114,11 @@ GNUNET_ATS_address_add (struct GNUNET_ATS_SchedulingHandle *sh, | |||
1117 | s = find_session_id (sh, session, &address->peer); | 1114 | s = find_session_id (sh, session, &address->peer); |
1118 | if (NOT_FOUND != s) | 1115 | if (NOT_FOUND != s) |
1119 | { | 1116 | { |
1120 | /* Already existing */ | 1117 | /* Already existing, nothing todo */ |
1121 | GNUNET_break (0); | 1118 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1119 | "Adding duplicate address for peer `%s', plugin `%s', session %p id %u\n", | ||
1120 | GNUNET_i2s (&address->peer), | ||
1121 | address->transport_name, session, s); | ||
1122 | return GNUNET_SYSERR; | 1122 | return GNUNET_SYSERR; |
1123 | } | 1123 | } |
1124 | s = find_empty_session_slot (sh, session, &address->peer); | 1124 | s = find_empty_session_slot (sh, session, &address->peer); |
@@ -1213,12 +1213,8 @@ GNUNET_ATS_address_update (struct GNUNET_ATS_SchedulingHandle *sh, | |||
1213 | { | 1213 | { |
1214 | s = find_session_id (sh, session, &address->peer); | 1214 | s = find_session_id (sh, session, &address->peer); |
1215 | if (NOT_FOUND == s) | 1215 | if (NOT_FOUND == s) |
1216 | { | 1216 | GNUNET_break (0); |
1217 | /* new session without slot, find one */ | ||
1218 | s = find_empty_session_slot (sh, session, &address->peer); | ||
1219 | GNUNET_break (NOT_FOUND != s); | ||
1220 | return; | 1217 | return; |
1221 | } | ||
1222 | } | 1218 | } |
1223 | m->session_id = htonl (s); | 1219 | m->session_id = htonl (s); |
1224 | 1220 | ||
@@ -1272,7 +1268,7 @@ GNUNET_ATS_address_in_use (struct GNUNET_ATS_SchedulingHandle *sh, | |||
1272 | return; | 1268 | return; |
1273 | } | 1269 | } |
1274 | 1270 | ||
1275 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 1271 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1276 | "Trying to set address to %s for peer `%s', plugin `%s', session %p\n", | 1272 | "Trying to set address to %s for peer `%s', plugin `%s', session %p\n", |
1277 | GNUNET_i2s (&address->peer), | 1273 | GNUNET_i2s (&address->peer), |
1278 | (GNUNET_NO == in_use) ? "NO" : "YES", | 1274 | (GNUNET_NO == in_use) ? "NO" : "YES", |