[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r33790 - gnunet/src/transport
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r33790 - gnunet/src/transport |
|
Date: |
Mon, 23 Jun 2014 18:57:10 +0200 |
Author: grothoff
Date: 2014-06-23 18:57:10 +0200 (Mon, 23 Jun 2014)
New Revision: 33790
Modified:
gnunet/src/transport/plugin_transport_http_client.c
gnunet/src/transport/transport-testing.c
Log:
-use LOG macro instead of GNUNET_log_from
Modified: gnunet/src/transport/plugin_transport_http_client.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_client.c 2014-06-23 16:30:41 UTC
(rev 33789)
+++ gnunet/src/transport/plugin_transport_http_client.c 2014-06-23 16:57:10 UTC
(rev 33790)
@@ -51,6 +51,7 @@
#include <curl/curl.h>
+#define LOG(kind,...) GNUNET_log_from(kind, PLUGIN_NAME, __VA_ARGS__)
/**
* Encapsulation of all of the state of the plugin.
@@ -450,13 +451,11 @@
text[size] = '\n';
text[size + 1] = '\0';
}
-#if BUILD_HTTPS
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-https_client",
- "Connection %p %s: %s", ch->easyhandle, ttype, text);
-#else
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-http_client",
- "Connection %p %s: %s", ch->easyhandle, ttype, text);
-#endif
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Connection %p %s: %s",
+ ch->easyhandle,
+ ttype,
+ text);
}
return 0;
}
@@ -509,10 +508,10 @@
return GNUNET_SYSERR;
}
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %p: Sending message with %u to peer
`%s' \n",
- s, s->client_put,
- msgbuf_size, GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: Sending message with %u to peer `%s' \n",
+ s, s->client_put,
+ msgbuf_size, GNUNET_i2s (&s->target));
/* create new message and schedule */
msg = GNUNET_malloc (sizeof (struct HTTP_Message) + msgbuf_size);
@@ -536,20 +535,21 @@
{
/* PUT connection is currently getting disconnected */
s->put_reconnect_required = GNUNET_YES;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %jp: currently disconnecting,
reconnecting immediately\n",
- s, s->client_put);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %jp: currently disconnecting, reconnecting
immediately\n",
+ s,
+ s->client_put);
return msgbuf_size;
}
- else if (GNUNET_YES == s->put_paused)
+ if (GNUNET_YES == s->put_paused)
{
/* PUT connection was paused, unpause */
GNUNET_assert (s->put_disconnect_task != GNUNET_SCHEDULER_NO_TASK);
GNUNET_SCHEDULER_cancel (s->put_disconnect_task);
s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %p: unpausing connection\n",
- s, s->client_put);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: unpausing connection\n",
+ s, s->client_put);
s->put_paused = GNUNET_NO;
if (NULL != s->client_put)
curl_easy_pause (s->client_put, CURLPAUSE_CONT);
@@ -557,9 +557,9 @@
else if (GNUNET_YES == s->put_tmp_disconnected)
{
/* PUT connection was disconnected, reconnect */
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p: Reconnecting PUT connection\n",
- s);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p: Reconnecting PUT connection\n",
+ s);
s->put_tmp_disconnected = GNUNET_NO;
GNUNET_break (s->client_put == NULL);
if (GNUNET_SYSERR == client_connect_put (s))
@@ -646,9 +646,9 @@
if (NULL != s->client_put)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: disconnecting PUT connection
to peer `%s'\n",
- s, s->client_put, GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: disconnecting PUT connection to peer
`%s'\n",
+ s, s->client_put, GNUNET_i2s (&s->target));
/* remove curl handle from multi handle */
mret = curl_multi_remove_handle (plugin->curl_multi_handle, s->client_put);
@@ -671,10 +671,10 @@
if (NULL != s->client_get)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: disconnecting GET connection
to peer `%s'\n",
- s, s->client_get,
- GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: disconnecting GET connection to peer
`%s'\n",
+ s, s->client_get,
+ GNUNET_i2s (&s->target));
/* remove curl handle from multi handle */
mret = curl_multi_remove_handle (plugin->curl_multi_handle, s->client_get);
if (mret != CURLM_OK)
@@ -706,8 +706,8 @@
HTTP_STAT_STR_CONNECTIONS,
plugin->cur_connections,
GNUNET_NO);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p: notifying transport about ending session\n",s);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p: notifying transport about ending session\n",s);
plugin->env->session_end (plugin->env->cls, s->address, s);
client_delete_session (s);
@@ -755,9 +755,9 @@
struct Session *next = NULL;
struct Session *pos = NULL;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Transport tells me to disconnect `%s'\n",
- GNUNET_i2s (target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Transport tells me to disconnect `%s'\n",
+ GNUNET_i2s (target));
next = plugin->head;
while (NULL != (pos = next))
@@ -765,9 +765,9 @@
next = pos->next;
if (0 == memcmp (target, &pos->target, sizeof (struct
GNUNET_PeerIdentity)))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Disconnecting session %p to `%pos'\n",
- pos, GNUNET_i2s (target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Disconnecting session %p to `%pos'\n",
+ pos, GNUNET_i2s (target));
GNUNET_assert (GNUNET_OK == http_client_session_disconnect (plugin,
pos));
}
@@ -805,9 +805,9 @@
struct Session *s = cls;
s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %p: will be disconnected due to no
activity\n",
- s, s->client_put);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: will be disconnected due to no activity\n",
+ s, s->client_put);
s->put_paused = GNUNET_NO;
s->put_tmp_disconnecting = GNUNET_YES;
if (NULL != s->client_put)
@@ -842,18 +842,17 @@
}
if (GNUNET_YES == s->put_tmp_disconnecting)
{
-
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %p: disconnect due to
inactivity\n",
- s, s->client_put);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: disconnect due to inactivity\n",
+ s, s->client_put);
return 0;
}
if (NULL == msg)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: nothing to send, suspending\n",
- s, s->client_put);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: nothing to send, suspending\n",
+ s, s->client_put);
s->put_disconnect_task = GNUNET_SCHEDULER_add_delayed
(PUT_DISCONNECT_TIMEOUT, &client_put_disconnect, s);
s->put_paused = GNUNET_YES;
return CURL_READFUNC_PAUSE;
@@ -867,9 +866,9 @@
msg->pos += len;
if (msg->pos == msg->size)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: sent message with %u bytes
sent, removing message from queue\n",
- s, s->client_put, msg->size, msg->pos);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: sent message with %u bytes sent, removing
message from queue\n",
+ s, s->client_put, msg->size, msg->pos);
/* Calling transmit continuation */
GNUNET_CONTAINER_DLL_remove (s->msg_head, s->msg_tail, msg);
if (NULL != msg->transmit_cont)
@@ -913,10 +912,10 @@
s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK;
if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
return;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p/connection %p: Waking up GET handle\n",
- s,
- s->client_get);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: Waking up GET handle\n",
+ s,
+ s->client_get);
s->put_paused = GNUNET_NO;
if (NULL != s->client_get)
curl_easy_pause (s->client_get, CURLPAUSE_CONT);
@@ -970,14 +969,14 @@
if (GNUNET_TIME_absolute_get ().abs_value_us < s->next_receive.abs_value_us)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Client: peer `%s' address `%s' next read delayed for
%s\n",
- GNUNET_i2s (&s->target),
- http_common_plugin_address_to_string (NULL,
- s->plugin->protocol, s->address->address,
- s->address->address_length),
- GNUNET_STRINGS_relative_time_to_string (delay,
- GNUNET_YES));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Client: peer `%s' address `%s' next read delayed for %s\n",
+ GNUNET_i2s (&s->target),
+ http_common_plugin_address_to_string (NULL,
+ s->plugin->protocol,
s->address->address,
+ s->address->address_length),
+ GNUNET_STRINGS_relative_time_to_string (delay,
+ GNUNET_YES));
}
client_reschedule_session_timeout (s);
return GNUNET_OK;
@@ -1018,21 +1017,21 @@
struct GNUNET_TIME_Absolute now;
size_t len = size * nmemb;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p / connection %p: Received %u bytes from peer
`%s'\n",
- s, s->client_get,
- len, GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p / connection %p: Received %u bytes from peer `%s'\n",
+ s, s->client_get,
+ len, GNUNET_i2s (&s->target));
now = GNUNET_TIME_absolute_get ();
if (now.abs_value_us < s->next_receive.abs_value_us)
{
struct GNUNET_TIME_Absolute now = GNUNET_TIME_absolute_get ();
struct GNUNET_TIME_Relative delta =
GNUNET_TIME_absolute_get_difference (now, s->next_receive);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p / connection %p: No inbound bandwidth
available! Next read was delayed for %s\n",
- s, s->client_get,
- GNUNET_STRINGS_relative_time_to_string (delta,
- GNUNET_YES));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p / connection %p: No inbound bandwidth available! Next
read was delayed for %s\n",
+ s, s->client_get,
+ GNUNET_STRINGS_relative_time_to_string (delta,
+ GNUNET_YES));
if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK)
{
GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
@@ -1165,10 +1164,10 @@
if (easy_h == NULL)
{
GNUNET_break (0);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Client: connection to ended with reason %i: `%s', %i
handles running\n",
- msg->data.result,
- curl_easy_strerror (msg->data.result), running);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Client: connection to ended with reason %i: `%s', %i handles
running\n",
+ msg->data.result,
+ curl_easy_strerror (msg->data.result), running);
continue;
}
@@ -1191,21 +1190,19 @@
{
if ((0 != msg->data.result) || (http_statuscode != 200))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
- plugin->name,
- "Session %p/connection %p: PUT connection to
`%s' ended with status %i reason %i: `%s'\n",
- s, msg->easy_handle,
- GNUNET_i2s (&s->target),
- http_statuscode,
- msg->data.result,
- curl_easy_strerror (msg->data.result));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: PUT connection to `%s' ended
with status %i reason %i: `%s'\n",
+ s, msg->easy_handle,
+ GNUNET_i2s (&s->target),
+ http_statuscode,
+ msg->data.result,
+ curl_easy_strerror (msg->data.result));
}
else
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
- plugin->name,
- "Session %p/connection %p: PUT connection to
`%s' ended normal\n",
- s, msg->easy_handle,
- GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: PUT connection to `%s' ended
normal\n",
+ s, msg->easy_handle,
+ GNUNET_i2s (&s->target));
if (NULL == s->client_get)
{
/* Disconnect other transmission direction and tell transport */
@@ -1238,18 +1235,22 @@
{
if ((0 != msg->data.result) || (http_statuscode != 200))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: GET connection to `%s' ended with
status %i reason %i: `%s'\n",
- s, msg->easy_handle, GNUNET_i2s (&s->target),
- http_statuscode,
- msg->data.result,
- curl_easy_strerror (msg->data.result));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: GET connection to `%s' ended
with status %i reason %i: `%s'\n",
+ s,
+ msg->easy_handle,
+ GNUNET_i2s (&s->target),
+ http_statuscode,
+ msg->data.result,
+ curl_easy_strerror (msg->data.result));
}
else
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Session %p/connection %p: GET connection to `%s' ended
normal\n",
- s, msg->easy_handle, GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p/connection %p: GET connection to `%s' ended
normal\n",
+ s,
+ msg->easy_handle,
+ GNUNET_i2s (&s->target));
/* Disconnect other transmission direction and tell transport */
s->get.easyhandle = NULL;
s->get.s = NULL;
@@ -1345,10 +1346,10 @@
mret = curl_multi_add_handle (s->plugin->curl_multi_handle, s->client_get);
if (mret != CURLM_OK)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, s->plugin->name,
- "Session %p : Failed to add GET handle to multihandle:
`%s'\n",
- s,
- curl_multi_strerror (mret));
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Session %p : Failed to add GET handle to multihandle: `%s'\n",
+ s,
+ curl_multi_strerror (mret));
curl_easy_cleanup (s->client_get);
s->client_get = NULL;
s->get.s = NULL;
@@ -1373,8 +1374,8 @@
CURLMcode mret;
/* create put connection */
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
- "Session %p : Init PUT handle\n", s);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p: Init PUT handle\n", s);
s->client_put = curl_easy_init ();
s->put.s = s;
s->put.easyhandle = s->client_put;
@@ -1443,10 +1444,10 @@
mret = curl_multi_add_handle (s->plugin->curl_multi_handle, s->client_put);
if (mret != CURLM_OK)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, s->plugin->name,
- "Session %p : Failed to add PUT handle to multihandle:
`%s'\n",
- s,
- curl_multi_strerror (mret));
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Session %p : Failed to add PUT handle to multihandle: `%s'\n",
+ s,
+ curl_multi_strerror (mret));
curl_easy_cleanup (s->client_put);
s->client_put = NULL;
s->put.easyhandle = NULL;
@@ -1476,10 +1477,9 @@
if (NULL == http_common_plugin_address_to_string (NULL,
plugin->protocol, s->address->address, s->address->address_length))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
- plugin->name,
- "Invalid address peer `%s'\n",
- GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Invalid address peer `%s'\n",
+ GNUNET_i2s (&s->target));
return GNUNET_SYSERR;
}
@@ -1490,11 +1490,10 @@
plugin->last_tag);
plugin->last_tag++;
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Initiating outbound session peer `%s' using address `%s'\n",
+ GNUNET_i2s (&s->target), s->url);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Initiating outbound session peer `%s' using address
`%s'\n",
- GNUNET_i2s (&s->target), s->url);
-
if ((GNUNET_SYSERR == client_connect_get (s)) ||
(GNUNET_SYSERR == client_connect_put (s)))
{
@@ -1503,11 +1502,11 @@
return GNUNET_SYSERR;
}
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
- plugin->name,
- "Session %p: connected with connections GET %p and PUT
%p\n",
- s, s->client_get, s->client_put);
-
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p: connected with connections GET %p and PUT %p\n",
+ s,
+ s->client_get,
+ s->client_put);
/* Perform connect */
plugin->cur_connections += 2;
GNUNET_STATISTICS_set (plugin->env->stats,
@@ -1554,11 +1553,11 @@
struct Session *s = cls;
s->timeout_task = GNUNET_SCHEDULER_NO_TASK;
- GNUNET_log (TIMEOUT_LOG,
- "Session %p was idle for %s, disconnecting\n",
- s,
- GNUNET_STRINGS_relative_time_to_string
(HTTP_CLIENT_SESSION_TIMEOUT,
- GNUNET_YES));
+ LOG (TIMEOUT_LOG,
+ "Session %p was idle for %s, disconnecting\n",
+ s,
+ GNUNET_STRINGS_relative_time_to_string (HTTP_CLIENT_SESSION_TIMEOUT,
+ GNUNET_YES));
/* call session destroy function */
GNUNET_assert (GNUNET_OK == http_client_session_disconnect (s->plugin,
@@ -1594,11 +1593,11 @@
if (plugin->max_connections <= plugin->cur_connections)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, plugin->name,
- "Maximum number of connections (%u) reached: "
- "cannot connect to peer `%s'\n",
- plugin->max_connections,
- GNUNET_i2s (&address->peer));
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Maximum number of connections (%u) reached: "
+ "cannot connect to peer `%s'\n",
+ plugin->max_connections,
+ GNUNET_i2s (&address->peer));
return NULL;
}
@@ -1647,12 +1646,12 @@
s->timeout_task = GNUNET_SCHEDULER_add_delayed (HTTP_CLIENT_SESSION_TIMEOUT,
&client_session_timeout,
s);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Created new session %p for `%s' address `%s''\n",
- s, http_common_plugin_address_to_string (NULL,
- plugin->protocol, s->address->address,
- s->address->address_length),
- GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Created new session %p for `%s' address `%s''\n",
+ s, http_common_plugin_address_to_string (NULL,
+ plugin->protocol,
s->address->address,
+ s->address->address_length),
+ GNUNET_i2s (&s->target));
/* add new session */
GNUNET_CONTAINER_DLL_insert (plugin->head, plugin->tail, s);
@@ -1660,12 +1659,12 @@
/* initiate new connection */
if (GNUNET_SYSERR == client_connect (s))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
- "Cannot connect to peer `%s' address `%s''\n",
- http_common_plugin_address_to_string (NULL,
- plugin->protocol,
s->address->address,
- s->address->address_length),
- GNUNET_i2s (&s->target));
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Cannot connect to peer `%s' address `%s''\n",
+ http_common_plugin_address_to_string (NULL,
+ plugin->protocol,
s->address->address,
+ s->address->address_length),
+ GNUNET_i2s (&s->target));
client_delete_session (s);
return NULL;
}
@@ -1687,9 +1686,9 @@
if (NULL == plugin->curl_multi_handle)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
- _("Could not initialize curl multi handle, failed to
start %s plugin!\n"),
- plugin->name);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ _("Could not initialize curl multi handle, failed to start %s
plugin!\n"),
+ plugin->name);
return GNUNET_SYSERR;
}
return GNUNET_OK;
@@ -1709,11 +1708,11 @@
s->timeout_task = GNUNET_SCHEDULER_add_delayed (HTTP_CLIENT_SESSION_TIMEOUT,
&client_session_timeout,
s);
- GNUNET_log (TIMEOUT_LOG,
- "Timeout rescheduled for session %p set to %s\n",
- s,
- GNUNET_STRINGS_relative_time_to_string
(HTTP_CLIENT_SESSION_TIMEOUT,
- GNUNET_YES));
+ LOG (TIMEOUT_LOG,
+ "Timeout rescheduled for session %p set to %s\n",
+ s,
+ GNUNET_STRINGS_relative_time_to_string (HTTP_CLIENT_SESSION_TIMEOUT,
+ GNUNET_YES));
}
@@ -1762,11 +1761,10 @@
return NULL;
}
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- _("Shutting down plugin `%s'\n"),
- plugin->name);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ _("Shutting down plugin `%s'\n"),
+ plugin->name);
-
next = plugin->head;
while (NULL != (pos = next))
{
@@ -1787,9 +1785,9 @@
}
curl_global_cleanup ();
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- _("Shutdown for plugin `%s' complete\n"),
- plugin->name);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ _("Shutdown for plugin `%s' complete\n"),
+ plugin->name);
GNUNET_free_non_null (plugin->proxy_hostname);
GNUNET_free_non_null (plugin->proxy_username);
@@ -1821,33 +1819,36 @@
max_connections = 128;
plugin->max_connections = max_connections;
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- _("Maximum number of connections is %u\n"),
- plugin->max_connections);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ _("Maximum number of connections is %u\n"),
+ plugin->max_connections);
/* Read proxy configuration */
if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (plugin->env->cfg,
plugin->name, "PROXY", &plugin->proxy_hostname))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Found proxy host: `%s'\n",
- plugin->proxy_hostname);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found proxy host: `%s'\n",
+ plugin->proxy_hostname);
/* proxy username */
- if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (plugin->env->cfg,
- plugin->name, "PROXY_USERNAME", &plugin->proxy_username))
+ if (GNUNET_OK ==
+ GNUNET_CONFIGURATION_get_value_string (plugin->env->cfg,
+ plugin->name,
+ "PROXY_USERNAME",
+ &plugin->proxy_username))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Found proxy username name: `%s'\n",
- plugin->proxy_username);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found proxy username name: `%s'\n",
+ plugin->proxy_username);
}
/* proxy password */
if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (plugin->env->cfg,
plugin->name, "PROXY_PASSWORD", &plugin->proxy_password))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Found proxy password name: `%s'\n",
- plugin->proxy_password);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found proxy password name: `%s'\n",
+ plugin->proxy_password);
}
/* proxy type */
@@ -1868,7 +1869,7 @@
plugin->proxytype = CURLPROXY_SOCKS5_HOSTNAME ;
else
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
+ LOG (GNUNET_ERROR_TYPE_ERROR,
_("Invalid proxy type: `%s', disabling proxy! Check
configuration!\n"),
proxy_type);
@@ -1883,8 +1884,9 @@
return GNUNET_SYSERR;
}
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
- "Found proxy type: `%s'\n", proxy_type);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found proxy type: `%s'\n",
+ proxy_type);
}
/* proxy http tunneling */
Modified: gnunet/src/transport/transport-testing.c
===================================================================
--- gnunet/src/transport/transport-testing.c 2014-06-23 16:30:41 UTC (rev
33789)
+++ gnunet/src/transport/transport-testing.c 2014-06-23 16:57:10 UTC (rev
33790)
@@ -27,6 +27,9 @@
#include "transport-testing.h"
+#define LOG(kind,...) GNUNET_log_from(kind, "transport-testing", __VA_ARGS__)
+
+
static struct PeerContext *
find_peer_context (struct GNUNET_TRANSPORT_TESTING_handle *tth,
const struct GNUNET_PeerIdentity *peer)
@@ -82,9 +85,11 @@
GNUNET_asprintf (&p2_s, "%u (`%s')", p2->no, GNUNET_i2s (&p2->id));
else
GNUNET_asprintf (&p2_s, "`%s'", GNUNET_i2s (peer));
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Peers %s connected to peer %u (`%s')\n", p2_s, p->no,
- GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Peers %s connected to peer %u (`%s')\n",
+ p2_s,
+ p->no,
+ GNUNET_i2s (&p->id));
GNUNET_free (p2_s);
/* Find ConnectingContext */
@@ -129,9 +134,11 @@
GNUNET_asprintf (&p2_s, "%u (`%s')", p2->no, GNUNET_i2s (&p2->id));
else
GNUNET_asprintf (&p2_s, "`%s'", GNUNET_i2s (peer));
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Peers %s disconnected from peer %u (`%s')\n", p2_s, no,
- GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Peers %s disconnected from peer %u (`%s')\n",
+ p2_s,
+ no,
+ GNUNET_i2s (&p->id));
GNUNET_free (p2_s);
if (p == NULL)
@@ -170,9 +177,9 @@
if (NULL != p->start_cb)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Peer %u (`%s') successfully started\n", p->no,
- GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Peer %u (`%s') successfully started\n", p->no,
+ GNUNET_i2s (&p->id));
p->start_cb (p, p->cb_cls);
p->start_cb = NULL;
}
@@ -196,10 +203,10 @@
char *p2_s = GNUNET_strdup (GNUNET_i2s (&p2->id));
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Asking peer %u (`%s') to connect peer %u (`%s'), providing
HELLO with %u bytes\n",
- p1->no, GNUNET_i2s (&p1->id), p2->no, p2_s,
- GNUNET_HELLO_size (cc->p2->hello));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Asking peer %u (`%s') to connect peer %u (`%s'), providing HELLO with
%u bytes\n",
+ p1->no, GNUNET_i2s (&p1->id), p2->no, p2_s,
+ GNUNET_HELLO_size (cc->p2->hello));
GNUNET_free (p2_s);
GNUNET_TRANSPORT_offer_hello (cc->th_p1,
@@ -241,8 +248,9 @@
if (GNUNET_DISK_file_test (cfgname) == GNUNET_NO)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "File not found: `%s' \n", cfgname);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "File not found: `%s'\n",
+ cfgname);
return NULL;
}
@@ -255,9 +263,9 @@
if (GNUNET_SYSERR == GNUNET_TESTING_configuration_create (tth->tl_system,
p->cfg))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Testing library failed to create unique configuration
based on `%s'\n",
- cfgname);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Testing library failed to create unique configuration based on
`%s'\n",
+ cfgname);
GNUNET_free (p);
return NULL;
}
@@ -267,9 +275,10 @@
p->peer = GNUNET_TESTING_peer_configure (tth->tl_system, p->cfg, p->no,
NULL, &emsg);
if (NULL == p->peer)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Testing library failed to create unique configuration
based on `%s': `%s'\n",
- cfgname, emsg);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Testing library failed to create unique configuration based on `%s':
`%s'\n",
+ cfgname,
+ emsg);
GNUNET_TRANSPORT_TESTING_stop_peer (tth, p);
GNUNET_free_non_null (emsg);
return NULL;
@@ -277,9 +286,9 @@
GNUNET_free_non_null (emsg);
if (GNUNET_OK != GNUNET_TESTING_peer_start (p->peer))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Testing library failed to create unique configuration
based on `%s'\n",
- cfgname);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Testing library failed to create unique configuration based on
`%s'\n",
+ cfgname);
GNUNET_TRANSPORT_TESTING_stop_peer (tth, p);
return NULL;
}
@@ -288,18 +297,18 @@
GNUNET_TESTING_peer_get_identity (p->peer, &p->id);
if (0 == memcmp (&dummy, &p->id, sizeof (struct GNUNET_PeerIdentity)))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Testing library failed to obtain peer identity for peer
%u\n",
- p->no);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Testing library failed to obtain peer identity for peer %u\n",
+ p->no);
GNUNET_TRANSPORT_TESTING_stop_peer (tth, p);
return NULL;
}
else
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Peer %u configured with identity `%s'\n",
- p->no,
- GNUNET_i2s_full (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Peer %u configured with identity `%s'\n",
+ p->no,
+ GNUNET_i2s_full (&p->id));
}
p->tth = tth;
@@ -317,9 +326,10 @@
¬ify_connect, ¬ify_disconnect);
if (NULL == p->th)
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Failed to connect to transport service for peer `%s':
`%s'\n",
- cfgname, emsg);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to connect to transport service for peer `%s': `%s'\n",
+ cfgname,
+ emsg);
GNUNET_TRANSPORT_TESTING_stop_peer (tth, p);
return NULL;
}
@@ -350,12 +360,16 @@
GNUNET_assert (p != NULL);
GNUNET_assert (NULL != p->peer);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Restarting peer %u (`%s')\n", p->no, GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Restarting peer %u (`%s')\n",
+ p->no,
+ GNUNET_i2s (&p->id));
/* shutdown */
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Stopping peer %u (`%s')\n", p->no, GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Stopping peer %u (`%s')\n",
+ p->no,
+ GNUNET_i2s (&p->id));
if (NULL != p->ghh)
GNUNET_TRANSPORT_get_hello_cancel (p->ghh);
p->ghh = NULL;
@@ -365,19 +379,21 @@
if (GNUNET_SYSERR == GNUNET_TESTING_peer_stop(p->peer))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Failed to stop peer %u (`%s')\n", p->no, GNUNET_i2s
(&p->id));
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to stop peer %u (`%s')\n",
+ p->no,
+ GNUNET_i2s (&p->id));
return GNUNET_SYSERR;
}
- sleep (5);
+ sleep (5); // YUCK!
/* restart */
if (GNUNET_SYSERR == GNUNET_TESTING_peer_start(p->peer))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Failed to restart peer %u (`%s')\n",
- p->no, GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Failed to restart peer %u (`%s')\n",
+ p->no, GNUNET_i2s (&p->id));
return GNUNET_SYSERR;
}
@@ -423,9 +439,9 @@
{
if (GNUNET_OK != GNUNET_TESTING_peer_stop (p->peer))
{
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Testing lib failed to stop peer %u (`%s') \n", p->no,
- GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Testing lib failed to stop peer %u (`%s') \n", p->no,
+ GNUNET_i2s (&p->id));
}
GNUNET_TESTING_peer_destroy (p->peer);
p->peer = NULL;
@@ -442,9 +458,9 @@
p->cfg = NULL;
}
GNUNET_CONTAINER_DLL_remove (tth->p_head, tth->p_tail, p);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Peer %u (`%s') stopped \n", p->no,
- GNUNET_i2s (&p->id));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Peer %u (`%s') stopped \n", p->no,
+ GNUNET_i2s (&p->id));
GNUNET_free (p);
}
@@ -488,8 +504,9 @@
GNUNET_assert (cc->th_p2 != NULL);
GNUNET_CONTAINER_DLL_insert (tth->cc_head, tth->cc_tail, cc);
cc->tct = GNUNET_SCHEDULER_add_now (&try_connect, cc);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "New connect request %p\n", cc);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "New connect request %p\n",
+ cc);
return cc;
}
@@ -513,8 +530,9 @@
GNUNET_assert (tth != NULL);
- GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "transport-testing",
- "Canceling connect request %p!\n", cc);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Canceling connect request %p!\n",
+ cc);
if (cc->tct != GNUNET_SCHEDULER_NO_TASK)
GNUNET_SCHEDULER_cancel (cc->tct);
@@ -542,8 +560,9 @@
while (cc != tth->cc_tail)
{
ct = cc->next;
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Developer forgot to cancel connect request %p!\n", cc);
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Developer forgot to cancel connect request %p!\n",
+ cc);
GNUNET_TRANSPORT_TESTING_connect_peers_cancel (tth, cc);
cc = ct;
}
@@ -551,8 +570,8 @@
while (p != NULL)
{
t = p->next;
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "transport-testing",
- "Developer forgot to stop peer!\n");
+ LOG (GNUNET_ERROR_TYPE_ERROR,
+ "Developer forgot to stop peer!\n");
GNUNET_TRANSPORT_TESTING_stop_peer (tth, p);
p = t;
}
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r33790 - gnunet/src/transport,
gnunet <=