diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2012-03-30 15:04:43 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2012-03-30 15:04:43 +0000 |
commit | bcc838c867834e805e905dec88ea33d0ab437ce4 (patch) | |
tree | 76b2bbd6d8f1ecf21ea237ddc9c41c0ff32c8603 /src/ats | |
parent | bab2ead70660878c4e87fc6b420434fc8810d7d6 (diff) | |
download | gnunet-bcc838c867834e805e905dec88ea33d0ab437ce4.tar.gz gnunet-bcc838c867834e805e905dec88ea33d0ab437ce4.zip |
- log from ats
Diffstat (limited to 'src/ats')
-rw-r--r-- | src/ats/ats_api_scheduling.c | 42 |
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 * | |||
319 | find_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, | 319 | find_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 | |||
417 | remove_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, | 418 | remove_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 | |||
445 | release_session (struct GNUNET_ATS_SchedulingHandle *sh, uint32_t session_id, | 444 | release_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); |