// FIXME: stats!
return;
}
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Suggesting address `%s' of peer `%s'\n",
+ address,
+ GNUNET_i2s (pid));
env = GNUNET_MQ_msg_extra (as,
slen,
GNUNET_MESSAGE_TYPE_ATS_ADDRESS_SUGGESTION);
losses of sessions (possibly of previous transport), ignore! */
return;
}
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Allocating %u/%u bytes for %p of peer `%s'\n",
+ ntohl (bw_in.value__),
+ ntohl (bw_out.value__),
+ session,
+ GNUNET_i2s (peer));
env = GNUNET_MQ_msg (sam,
GNUNET_MESSAGE_TYPE_ATS_SESSION_ALLOCATION);
sam->session_id = session->session_id;
*/
static void
handle_suggest (void *cls,
- const struct ExpressPreferenceMessage *msg)
+ const struct ExpressPreferenceMessage *msg)
{
struct Client *c = cls;
struct ClientPreference *cp;
GNUNET_SERVICE_client_drop (c->client);
return;
}
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Client suggested we talk to %s with preference %d at rate %u\n",
+ GNUNET_i2s (&msg->peer),
+ (int) ntohl (msg->pk),
+ (int) ntohl (msg->bw.value__));
cp = GNUNET_new (struct ClientPreference);
cp->client = c;
cp->pref.peer = msg->peer;
*/
static void
handle_suggest_cancel (void *cls,
- const struct ExpressPreferenceMessage *msg)
+ const struct ExpressPreferenceMessage *msg)
{
struct Client *c = cls;
struct ClientPreference *cp;
cp = cp->next)
if ( (cp->pref.pk == (enum GNUNET_MQ_PreferenceKind) ntohl (msg->pk)) &&
(cp->pref.bw.value__ == msg->bw.value__) &&
- (0 == memcmp (&cp->pref.peer,
- &msg->peer,
- sizeof (struct GNUNET_PeerIdentity))) )
+ (0 == GNUNET_memcmp (&cp->pref.peer,
+ &msg->peer)) )
break;
if (NULL == cp)
{
session->sh = plugin->session_add (plugin->cls,
&session->data,
address);
+ GNUNET_assert (NULL != session->sh);
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transport has new session %p to %s\n",
+ session,
+ GNUNET_i2s (&message->peer));
GNUNET_SERVICE_client_continue (c->client);
}
GNUNET_SERVICE_client_drop (c->client);
return;
}
+ GNUNET_assert (NULL != session->sh);
plugin->session_del (plugin->cls,
session->sh,
&session->data);
+ session->sh = NULL;
GNUNET_assert (GNUNET_YES ==
GNUNET_CONTAINER_multihashmap32_remove (c->details.transport.sessions,
session->session_id,
session));
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transport lost session %p to %s\n",
+ session,
+ GNUNET_i2s (&session->data.peer));
GNUNET_free (session);
GNUNET_SERVICE_client_continue (c->client);
}
(void) key;
GNUNET_assert (c == session->client);
+ GNUNET_assert (NULL != session->sh);
plugin->session_del (plugin->cls,
session->sh,
&session->data);
+ session->sh = NULL;
GNUNET_free (session);
return GNUNET_OK;
}
&client_disconnect_cb,
NULL,
GNUNET_MQ_hd_fixed_size (suggest,
- GNUNET_MESSAGE_TYPE_ATS_SUGGEST,
- struct ExpressPreferenceMessage,
- NULL),
+ GNUNET_MESSAGE_TYPE_ATS_SUGGEST,
+ struct ExpressPreferenceMessage,
+ NULL),
GNUNET_MQ_hd_fixed_size (suggest_cancel,
- GNUNET_MESSAGE_TYPE_ATS_SUGGEST_CANCEL,
- struct ExpressPreferenceMessage,
- NULL),
+ GNUNET_MESSAGE_TYPE_ATS_SUGGEST_CANCEL,
+ struct ExpressPreferenceMessage,
+ NULL),
GNUNET_MQ_hd_fixed_size (start,
GNUNET_MESSAGE_TYPE_ATS_START,
struct GNUNET_MessageHeader,