diff options
Diffstat (limited to 'src/ats/gnunet-service-ats-new.c')
-rw-r--r-- | src/ats/gnunet-service-ats-new.c | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/src/ats/gnunet-service-ats-new.c b/src/ats/gnunet-service-ats-new.c index dd65d54a2..a1666d8d3 100644 --- a/src/ats/gnunet-service-ats-new.c +++ b/src/ats/gnunet-service-ats-new.c | |||
@@ -213,6 +213,10 @@ suggest_cb (void *cls, | |||
213 | // FIXME: stats! | 213 | // FIXME: stats! |
214 | return; | 214 | return; |
215 | } | 215 | } |
216 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
217 | "Suggesting address `%s' of peer `%s'\n", | ||
218 | address, | ||
219 | GNUNET_i2s (pid)); | ||
216 | env = GNUNET_MQ_msg_extra (as, | 220 | env = GNUNET_MQ_msg_extra (as, |
217 | slen, | 221 | slen, |
218 | GNUNET_MESSAGE_TYPE_ATS_ADDRESS_SUGGESTION); | 222 | GNUNET_MESSAGE_TYPE_ATS_ADDRESS_SUGGESTION); |
@@ -253,6 +257,12 @@ allocate_cb (void *cls, | |||
253 | losses of sessions (possibly of previous transport), ignore! */ | 257 | losses of sessions (possibly of previous transport), ignore! */ |
254 | return; | 258 | return; |
255 | } | 259 | } |
260 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
261 | "Allocating %u/%u bytes for %p of peer `%s'\n", | ||
262 | ntohl (bw_in.value__), | ||
263 | ntohl (bw_out.value__), | ||
264 | session, | ||
265 | GNUNET_i2s (peer)); | ||
256 | env = GNUNET_MQ_msg (sam, | 266 | env = GNUNET_MQ_msg (sam, |
257 | GNUNET_MESSAGE_TYPE_ATS_SESSION_ALLOCATION); | 267 | GNUNET_MESSAGE_TYPE_ATS_SESSION_ALLOCATION); |
258 | sam->session_id = session->session_id; | 268 | sam->session_id = session->session_id; |
@@ -307,6 +317,11 @@ handle_suggest (void *cls, | |||
307 | GNUNET_SERVICE_client_drop (c->client); | 317 | GNUNET_SERVICE_client_drop (c->client); |
308 | return; | 318 | return; |
309 | } | 319 | } |
320 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
321 | "Client suggested we talk to %s with preference %d at rate %u\n", | ||
322 | GNUNET_i2s (&msg->peer), | ||
323 | (int) ntohl (msg->pk), | ||
324 | (int) ntohl (msg->bw.value__)); | ||
310 | cp = GNUNET_new (struct ClientPreference); | 325 | cp = GNUNET_new (struct ClientPreference); |
311 | cp->client = c; | 326 | cp->client = c; |
312 | cp->pref.peer = msg->peer; | 327 | cp->pref.peer = msg->peer; |
@@ -464,6 +479,10 @@ handle_session_add (void *cls, | |||
464 | &session->data, | 479 | &session->data, |
465 | address); | 480 | address); |
466 | GNUNET_assert (NULL != session->sh); | 481 | GNUNET_assert (NULL != session->sh); |
482 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
483 | "Transport has new session %p to %s\n", | ||
484 | session, | ||
485 | GNUNET_i2s (&message->peer)); | ||
467 | GNUNET_SERVICE_client_continue (c->client); | 486 | GNUNET_SERVICE_client_continue (c->client); |
468 | } | 487 | } |
469 | 488 | ||
@@ -540,6 +559,10 @@ handle_session_del (void *cls, | |||
540 | GNUNET_CONTAINER_multihashmap32_remove (c->details.transport.sessions, | 559 | GNUNET_CONTAINER_multihashmap32_remove (c->details.transport.sessions, |
541 | session->session_id, | 560 | session->session_id, |
542 | session)); | 561 | session)); |
562 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
563 | "Transport lost session %p to %s\n", | ||
564 | session, | ||
565 | GNUNET_i2s (&session->data.peer)); | ||
543 | GNUNET_free (session); | 566 | GNUNET_free (session); |
544 | GNUNET_SERVICE_client_continue (c->client); | 567 | GNUNET_SERVICE_client_continue (c->client); |
545 | } | 568 | } |