resend:
/* Send the data */
- sent = 0;
sent = GNUNET_NETWORK_socket_sendto (send_handle, msgbuf, msgbuf_size, sb, sbs);
if (GNUNET_SYSERR == sent)
disconnect_session (s);
}
+
/**
* Function obtain the network type for a session
*
* @return the network type in HBO or GNUNET_SYSERR
*/
static enum GNUNET_ATS_Network_Type
-unix_get_network (void *cls, void *session)
+unix_get_network (void *cls,
+ struct Session *session)
{
- GNUNET_assert (NULL != session);
- return GNUNET_ATS_NET_LOOPBACK;
+ GNUNET_assert (NULL != session);
+ return GNUNET_ATS_NET_LOOPBACK;
}
s = lookup_session (plugin, sender, ua, ua_len);
if (NULL == s)
{
- GNUNET_break (0);
s = unix_plugin_get_session (plugin, addr);
s->inbound = GNUNET_YES;
/* Notify transport and ATS about new inbound session */
if ((csize < sizeof (struct UNIXMessage)) || (csize > ret))
{
GNUNET_break_op (0);
+ GNUNET_free (ua);
return;
}
msgbuf = (char *) &msg[1];
while (NULL != (msgw = plugin->msg_tail))
{
- if (GNUNET_TIME_absolute_get_remaining (msgw->timeout).rel_value > 0)
+ if (GNUNET_TIME_absolute_get_remaining (msgw->timeout).rel_value_us > 0)
break; /* Message is ready for sending */
/* Message has a timeout */
LOG (GNUNET_ERROR_TYPE_DEBUG,
if (0 == addrlen)
{
- GNUNET_snprintf(rbuf, sizeof (rbuf), "%s", "<inbound>");
+ GNUNET_snprintf(rbuf, sizeof (rbuf), "%s", TRANSPORT_SESSION_INBOUND_STRING);
}
if ((NULL == addr) || (sizeof (struct UnixAddress) > addrlen))
{
}
else if (0 == addrlen)
{
- asc (asc_cls, "<inbound>");
+ asc (asc_cls, TRANSPORT_SESSION_INBOUND_STRING);
}
else
{
address = NULL;
plugin = NULL;
optionstr = NULL;
- options = 0;
+
if ((NULL == addr) || (addrlen == 0))
{
GNUNET_break (0);