aboutsummaryrefslogtreecommitdiff
path: root/src/ats
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2012-06-15 13:11:46 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2012-06-15 13:11:46 +0000
commit0bb2d2a34cbd8f1c0118f6203eaf9f41a1570fa7 (patch)
treeac8af3c2af3091c8945838a5f2403821efa10c27 /src/ats
parent1dfa405cdd6ad888dff6386d4abecf44ef3828ab (diff)
downloadgnunet-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.c18
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",