aboutsummaryrefslogtreecommitdiff
path: root/src/ats
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2012-03-30 15:04:43 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2012-03-30 15:04:43 +0000
commitbcc838c867834e805e905dec88ea33d0ab437ce4 (patch)
tree76b2bbd6d8f1ecf21ea237ddc9c41c0ff32c8603 /src/ats
parentbab2ead70660878c4e87fc6b420434fc8810d7d6 (diff)
downloadgnunet-bcc838c867834e805e905dec88ea33d0ab437ce4.tar.gz
gnunet-bcc838c867834e805e905dec88ea33d0ab437ce4.zip
- log from ats
Diffstat (limited to 'src/ats')
-rw-r--r--src/ats/ats_api_scheduling.c42
1 files changed, 19 insertions, 23 deletions
diff --git a/src/ats/ats_api_scheduling.c b/src/ats/ats_api_scheduling.c
index 78e8d61cc..123398992 100644
--- a/src/ats/ats_api_scheduling.c
+++ b/src/ats/ats_api_scheduling.c
@@ -319,10 +319,11 @@ static struct Session *
319find_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, 319find_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id,
320 const struct GNUNET_PeerIdentity *peer) 320 const struct GNUNET_PeerIdentity *peer)
321{ 321{
322#if DEBUG_ATS 322
323 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Find session %u from peer %s in %p\n", 323 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
324 "Find session %u from peer %s in %p\n",
324 (unsigned int) session_id, GNUNET_i2s (peer), sh); 325 (unsigned int) session_id, GNUNET_i2s (peer), sh);
325#endif 326
326 if (session_id >= sh->session_array_size) 327 if (session_id >= sh->session_array_size)
327 { 328 {
328 GNUNET_break (0); 329 GNUNET_break (0);
@@ -366,11 +367,11 @@ get_session_id (struct GNUNET_ATS_SchedulingHandle *sh, struct Session *session,
366 unsigned int i; 367 unsigned int i;
367 unsigned int f; 368 unsigned int f;
368 369
369#if DEBUG_ATS 370
370 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 371 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
371 "Get session ID for session %p from peer %s in %p\n", session, 372 "Get session ID for session %p from peer %s in %p\n", session,
372 GNUNET_i2s (peer), sh); 373 GNUNET_i2s (peer), sh);
373#endif 374
374 if (NULL == session) 375 if (NULL == session)
375 return 0; 376 return 0;
376 f = 0; 377 f = 0;
@@ -396,11 +397,11 @@ get_session_id (struct GNUNET_ATS_SchedulingHandle *sh, struct Session *session,
396 sh->session_array[f].session = session; 397 sh->session_array[f].session = session;
397 sh->session_array[f].peer = *peer; 398 sh->session_array[f].peer = *peer;
398 sh->session_array[f].slot_used = GNUNET_YES; 399 sh->session_array[f].slot_used = GNUNET_YES;
399#if DEBUG_ATS 400
400 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 401 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
401 "Assigning session ID %u for session %p of peer %s in %p\n", f, 402 "Assigning session ID %u for session %p of peer %s in %p\n", f,
402 session, GNUNET_i2s (peer), sh); 403 session, GNUNET_i2s (peer), sh);
403#endif 404
404 return f; 405 return f;
405} 406}
406 407
@@ -417,11 +418,9 @@ static void
417remove_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, 418remove_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id,
418 const struct GNUNET_PeerIdentity *peer) 419 const struct GNUNET_PeerIdentity *peer)
419{ 420{
420#if DEBUG_ATS 421 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
421 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 422 "Remove sessionID %u from peer %s in %p\n", "ats-scheduling-api",
422 "Remove sessionID %u from peer %s in %p\n",
423 (unsigned int) session_id, GNUNET_i2s (peer), sh); 423 (unsigned int) session_id, GNUNET_i2s (peer), sh);
424#endif
425 if (0 == session_id) 424 if (0 == session_id)
426 return; 425 return;
427 GNUNET_assert (session_id < sh->session_array_size); 426 GNUNET_assert (session_id < sh->session_array_size);
@@ -445,11 +444,11 @@ static void
445release_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, 444release_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id,
446 const struct GNUNET_PeerIdentity *peer) 445 const struct GNUNET_PeerIdentity *peer)
447{ 446{
448#if DEBUG_ATS 447
449 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 448 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
450 "Release sessionID %u from peer %s in %p\n", 449 "Release sessionID %u from peer %s in %p\n",
451 (unsigned int) session_id, GNUNET_i2s (peer), sh); 450 (unsigned int) session_id, GNUNET_i2s (peer), sh);
452#endif 451
453 if (session_id >= sh->session_array_size) 452 if (session_id >= sh->session_array_size)
454 { 453 {
455 GNUNET_break (0); 454 GNUNET_break (0);
@@ -552,11 +551,10 @@ process_ats_message (void *cls, const struct GNUNET_MessageHeader *msg)
552 s = find_session (sh, session_id, &m->peer); 551 s = find_session (sh, session_id, &m->peer);
553 if (s == NULL) 552 if (s == NULL)
554 { 553 {
555#if DEBUG_ATS 554
556 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 555 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
557 "ATS tries to use outdated session `%s'\n", 556 "ATS tries to use outdated session `%s'\n",
558 GNUNET_i2s (&m->peer)); 557 GNUNET_i2s (&m->peer));
559#endif
560 GNUNET_CLIENT_receive (sh->client, &process_ats_message, sh, 558 GNUNET_CLIENT_receive (sh->client, &process_ats_message, sh,
561 GNUNET_TIME_UNIT_FOREVER_REL); 559 GNUNET_TIME_UNIT_FOREVER_REL);
562 return; 560 return;
@@ -807,7 +805,8 @@ GNUNET_ATS_address_get_type (struct GNUNET_ATS_SchedulingHandle * sh, const stru
807 if (((a4->sin_addr.s_addr & mask4->sin_addr.s_addr)) == net4->sin_addr.s_addr) 805 if (((a4->sin_addr.s_addr & mask4->sin_addr.s_addr)) == net4->sin_addr.s_addr)
808 { 806 {
809 char * net = GNUNET_strdup (GNUNET_a2s ((const struct sockaddr *) net4, addrlen)); 807 char * net = GNUNET_strdup (GNUNET_a2s ((const struct sockaddr *) net4, addrlen));
810 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "`%s' is in network `%s'\n", 808 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "ats-scheduling-api",
809 "`%s' is in network `%s'\n",
811 GNUNET_a2s ((const struct sockaddr *)a4, addrlen), 810 GNUNET_a2s ((const struct sockaddr *)a4, addrlen),
812 net); 811 net);
813 GNUNET_free (net); 812 GNUNET_free (net);
@@ -862,9 +861,6 @@ GNUNET_ATS_address_get_type (struct GNUNET_ATS_SchedulingHandle * sh, const stru
862 861
863 break; 862 break;
864 } 863 }
865 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "`%s' is in network `%s'\n",
866 GNUNET_a2s ((const struct sockaddr *) addr, addrlen),
867 range);
868#endif 864#endif
869 865
870 ats.type = htonl (GNUNET_ATS_NETWORK_TYPE); 866 ats.type = htonl (GNUNET_ATS_NETWORK_TYPE);