pos = (const char *) cstate->msg;
len = ntohs (cstate->msg->size);
GNUNET_assert (cstate->msg_off < len);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ "client: message of type %u trying to send with socket %p\n", ntohs(cstate->msg->type), cstate->sock);
RETRY:
ret = GNUNET_NETWORK_socket_send (cstate->sock,
&pos[cstate->msg_off],
GNUNET_SCHEDULER_cancel (cstate->recv_task);
if (NULL != cstate->retry_task)
GNUNET_SCHEDULER_cancel (cstate->retry_task);
- if (NULL != cstate->sock)
+ if (NULL != cstate->sock){
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ "client: destroying socket: %p\n", cstate->sock);
GNUNET_NETWORK_socket_close (cstate->sock);
+ }
cancel_aps (cstate);
GNUNET_free (cstate->service_name);
GNUNET_free_non_null (cstate->hostname);
sock = GNUNET_NETWORK_socket_create (AF_UNIX,
SOCK_STREAM,
0);
+
+ GNUNET_log (GNUNET_ERROR_TYPE_MESSAGE,
+ "client: socket created: %p\n", sock);
+
if ( (NULL != sock) &&
( (GNUNET_OK ==
GNUNET_NETWORK_socket_connect (sock,
cstate->msg_off = 0;
if (NULL == cstate->sock){
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "client: waiting for socket\n");
+ "client: message of type %u waiting for socket\n",ntohs(msg->type));
return; /* still waiting for connection */
}
cstate->send_task