if (entry->rt->finish_handler) {
entry->rt->finish_handler (entry);
}
+
+ DL_DELETE (entry->rt->conns, entry);
g_slice_free1 (sizeof (struct rspamd_http_connection_entry), entry);
}
}
rspamd_http_connection_read_message (conn->conn, conn, fd, router->ptv,
router->ev_base);
- LL_PREPEND (router->conns, conn);
+ DL_PREPEND (router->conns, conn);
}
void
struct rspamd_http_keypair *kp;
if (router) {
- LL_FOREACH_SAFE (router->conns, conn, tmp)
+ DL_FOREACH_SAFE (router->conns, conn, tmp)
{
rspamd_http_entry_free (conn);
}
struct rspamd_http_connection *conn;
gpointer ud;
gboolean is_reply;
- struct rspamd_http_connection_entry *next;
+ struct rspamd_http_connection_entry *prev, *next;
};
struct rspamd_http_connection_router {