{
sock = GNUNET_CONNECTION_create_from_connect_to_unixpath (sched,
cfg,
- unixpath,
- GNUNET_SERVER_MAX_MESSAGE_SIZE);
+ unixpath);
GNUNET_free (unixpath);
if (sock != NULL)
return sock;
sock = GNUNET_CONNECTION_create_from_connect (sched,
cfg,
hostname,
- port,
- GNUNET_SERVER_MAX_MESSAGE_SIZE);
+ port);
GNUNET_free (hostname);
return sock;
}
#if DEBUG_CLIENT
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Received message of size %u\n",
+ "Received message of type %u and size %u\n",
+ ntohs (cmsg->type),
msize);
#endif
sock->receive_task = GNUNET_SCHEDULER_NO_TASK;
GNUNET_assert (sock->in_receive == GNUNET_NO);
sock->in_receive = GNUNET_YES;
GNUNET_CONNECTION_receive (sock->sock,
- GNUNET_SERVER_MAX_MESSAGE_SIZE,
+ GNUNET_SERVER_MAX_MESSAGE_SIZE - 1,
timeout, &receive_helper, sock);
}
}
}
else
{
- GNUNET_break (NULL != th->th);
+ GNUNET_assert (NULL != th->th);
GNUNET_CONNECTION_notify_transmit_ready_cancel (th->th);
}
th->sock->th = NULL;