GPtrArray *results;
struct rspamd_task *task;
struct upstream *server;
- rspamd_inet_addr_t *addr;
struct fuzzy_rule *rule;
struct event ev;
struct event timev;
struct rspamd_http_connection_entry *http_entry;
struct rspamd_async_session *session;
struct upstream *server;
- rspamd_inet_addr_t *addr;
struct fuzzy_rule *rule;
struct rspamd_task *task;
struct event ev;
/* Error state */
msg_err_task ("got error on IO with server %s(%s), on %s, %d, %s",
rspamd_upstream_name (session->server),
- rspamd_inet_address_to_string_pretty (session->addr),
+ rspamd_inet_address_to_string_pretty (
+ rspamd_upstream_addr (session->server)),
session->state == 1 ? "read" : "write",
errno,
strerror (errno));
if (session->retransmits >= session->rule->ctx->retransmits) {
msg_err_task ("got IO timeout with server %s(%s), after %d retransmits",
rspamd_upstream_name (session->server),
- rspamd_inet_address_to_string_pretty (session->addr),
+ rspamd_inet_address_to_string_pretty (
+ rspamd_upstream_addr (session->server)),
session->retransmits);
rspamd_upstream_fail (session->server, FALSE);
rspamd_session_remove_event (session->task->s, fuzzy_io_fin, session);
else if (ret == return_error) {
msg_err_task ("got error in IO with server %s(%s), %d, %s",
rspamd_upstream_name (session->server),
- rspamd_inet_address_to_string_pretty (session->addr),
+ rspamd_inet_address_to_string_pretty (
+ rspamd_upstream_addr (session->server)),
errno, strerror (errno));
rspamd_upstream_fail (session->server, FALSE);
}
msg_err_task_check ("got IO timeout with server %s(%s), "
"after %d retransmits",
rspamd_upstream_name (session->server),
- rspamd_inet_address_to_string_pretty (session->addr),
+ rspamd_inet_address_to_string_pretty (
+ rspamd_upstream_addr (session->server)),
session->retransmits);
if (session->session) {
session->fd = sock;
session->server = selected;
session->rule = rule;
- session->addr = addr;
session->results = g_ptr_array_sized_new (32);
event_set (&session->ev, sock, EV_WRITE, fuzzy_check_io_callback,
msec_to_tv (fuzzy_module_ctx->io_timeout, &s->tv);
s->task = task;
- s->addr = addr;
s->commands = commands;
s->http_entry = entry;
s->server = selected;
msec_to_tv (rule->ctx->io_timeout, &s->tv);
s->task = task;
- s->addr = addr;
s->commands = commands;
s->http_entry = NULL;
s->server = selected;