return NULL;
}
}
+
+
+rspamd_mempool_t *
+rspamd_session_mempool (struct rspamd_async_session *session)
+{
+ g_assert (session != NULL);
+
+ return session->pool;
+}
\ No newline at end of file
*/
void rspamd_session_cleanup (struct rspamd_async_session *session);
+/**
+ * Returns mempool associated with async session
+ * @param session
+ * @return
+ */
+rspamd_mempool_t * rspamd_session_mempool (struct rspamd_async_session *session);
+
/**
* Check session for events pending and call fin callback if no events are pending
* @param session session object
fd = rspamd_inet_address_connect (cbd->addr, SOCK_STREAM, TRUE);
if (fd == -1) {
- msg_info ("cannot connect to %s", rspamd_inet_address_to_string (cbd->addr));
+ if (cbd->session) {
+ rspamd_mempool_t *pool = rspamd_session_mempool (cbd->session);
+ msg_info_pool ("cannot connect to %s: %s",
+ rspamd_inet_address_to_string (cbd->addr),
+ strerror (errno));
+ }
+ else {
+ msg_info ("cannot connect to %s: %s",
+ rspamd_inet_address_to_string (cbd->addr),
+ strerror (errno));
+ }
+
return FALSE;
}