GList *filters; /**< linked list of all filters */
GList *workers; /**< linked list of all workers params */
- struct rspamd_worker_cfg_parser *wrk_parsers; /**< hash for worker config parsers, indexed by worker quarks */
- ucl_object_t *rcl_obj; /**< rcl object */
- GHashTable * metrics; /**< hash of metrics indexed by metric name */
- GList * metrics_list; /**< linked list of metrics */
- GHashTable * metrics_symbols; /**< hash table of metrics indexed by symbol */
- GHashTable * c_modules; /**< hash of c modules indexed by module name */
- GHashTable * composite_symbols; /**< hash of composite symbols indexed by its name */
+ GHashTable *wrk_parsers; /**< hash for worker config parsers, indexed by worker quarks */
+ ucl_object_t *rcl_obj; /**< rcl object */
+ GHashTable * metrics; /**< hash of metrics indexed by metric name */
+ GList * metrics_list; /**< linked list of metrics */
+ GHashTable * metrics_symbols; /**< hash table of metrics indexed by symbol */
+ GHashTable * c_modules; /**< hash of c modules indexed by module name */
+ GHashTable * composite_symbols; /**< hash of composite symbols indexed by its name */
GList *classifiers; /**< list of all classifiers defined */
GList *statfiles; /**< list of all statfiles in config file order */
GHashTable *classifiers_symbols; /**< hashtable indexed by symbol name of classifiers */
- GHashTable * cfg_params; /**< all cfg params indexed by its name in this structure */
+ GHashTable * cfg_params; /**< all cfg params indexed by its name in this structure */
GList *pre_filters; /**< list of pre-processing lua filters */
GList *post_filters; /**< list of post-processing lua filters */
gchar *dynamic_conf; /**< path to dynamic configuration */
- ucl_object_t *current_dynamic_conf; /**< currently loaded dynamic configuration */
- GHashTable * domain_settings; /**< settings per-domains */
- GHashTable * user_settings; /**< settings per-user */
- gchar * domain_settings_str; /**< string representation of settings */
+ ucl_object_t *current_dynamic_conf; /**< currently loaded dynamic configuration */
+ GHashTable * domain_settings; /**< settings per-domains */
+ GHashTable * user_settings; /**< settings per-user */
+ gchar * domain_settings_str; /**< string representation of settings */
gchar * user_settings_str;
gint clock_res; /**< resolution of clock used */
gchar * history_file; /**< file to save rolling history */
- gchar * tld_file; /**< file to load effective tld list from */
+ gchar * tld_file; /**< file to load effective tld list from */
gdouble dns_timeout; /**< timeout in milliseconds for waiting for dns reply */
guint32 dns_retransmits; /**< maximum retransmits count */
gpointer fin_ud;
};
+struct rspamd_worker_param_key {
+ const gchar *name;
+ gpointer ptr;
+};
+
struct rspamd_worker_param_parser {
rspamd_rcl_default_handler_t handler; /**< handler function */
struct rspamd_rcl_struct_parser parser; /**< parser attributes */
- const gchar *name; /**< parameter's name */
- UT_hash_handle hh; /**< hash by name */
+
+ struct rspamd_worker_param_key key;
};
struct rspamd_worker_cfg_parser {
- struct rspamd_worker_param_parser *parsers; /**< parsers hash */
+ GHashTable *parsers; /**< parsers hash */
gint type; /**< workers quark */
- gboolean (*def_obj_parser)(ucl_object_t *obj, gpointer ud); /**< default object parser */
+ gboolean (*def_obj_parser)(ucl_object_t *obj, gpointer ud); /**<
+ default object parser */
gpointer def_ud;
- UT_hash_handle hh; /**< hash by type */
};
static gboolean rspamd_rcl_process_section (struct rspamd_rcl_section *sec,
struct rspamd_worker_conf *wrk;
struct rspamd_worker_cfg_parser *wparser;
struct rspamd_worker_param_parser *whandler;
+ struct rspamd_worker_param_key srch;
g_assert (key != NULL);
worker_type = key;
}
/* Parse other attributes */
- HASH_FIND_INT (cfg->wrk_parsers, (gint *)&qtype, wparser);
+ wparser = g_hash_table_lookup (cfg->wrk_parsers, &qtype);
+
if (wparser != NULL && obj->type == UCL_OBJECT) {
it = NULL;
while ((cur = ucl_iterate_object (obj, &it, true)) != NULL) {
- HASH_FIND_STR (wparser->parsers, ucl_object_key (cur), whandler);
+ srch.name = ucl_object_key (cur);
+ srch.ptr = wrk->ctx; /* XXX: is it valid? */
+ whandler = g_hash_table_lookup (wparser->parsers, &srch);
if (whandler != NULL) {
return TRUE;
}
+static guint
+rspamd_worker_param_key_hash (gconstpointer p)
+{
+ const struct rspamd_worker_param_key *k = p;
+ XXH64_state_t st;
+
+ XXH64_reset (&st, rspamd_hash_seed ());
+ XXH64_update (&st, k->name, strlen (k->name));
+ XXH64_update (&st, &k->ptr, sizeof (gpointer));
+
+ return XXH64_digest (&st);
+}
+
+static gboolean
+rspamd_worker_param_key_equal (gconstpointer p1, gconstpointer p2)
+{
+ struct rspamd_worker_param_key *k1 = p1, *k2 = p2;
+
+ if (k1->ptr == k2->ptr) {
+ return strcmp (k1->name, k2->name) == 0;
+ }
+
+ return FALSE;
+}
+
void
rspamd_rcl_register_worker_option (struct rspamd_config *cfg,
- gint type,
+ GQuark type,
const gchar *name,
rspamd_rcl_default_handler_t handler,
gpointer target,
{
struct rspamd_worker_param_parser *nhandler;
struct rspamd_worker_cfg_parser *nparser;
+ struct rspamd_worker_param_key srch;
- HASH_FIND_INT (cfg->wrk_parsers, &type, nparser);
+ nparser = g_hash_table_lookup (cfg->wrk_parsers, &type);
if (nparser == NULL) {
- /* Allocate new parser for this worker */
- nparser =
- rspamd_mempool_alloc0 (cfg->cfg_pool,
- sizeof (struct rspamd_worker_cfg_parser));
- nparser->type = type;
- HASH_ADD_INT (cfg->wrk_parsers, type, nparser);
+ rspamd_rcl_register_worker_parser (cfg, type, NULL, NULL);
+ nparser = g_hash_table_lookup (cfg->wrk_parsers, &type);
+
+ g_assert (nparser != NULL);
}
- HASH_FIND_STR (nparser->parsers, name, nhandler);
+ srch.name = name;
+ srch.ptr = target;
+
+ nhandler = g_hash_table_lookup (nparser->parsers, &srch);
if (nhandler != NULL) {
msg_warn_config (
"handler for parameter %s is already registered for worker type %s",
nhandler =
rspamd_mempool_alloc0 (cfg->cfg_pool,
sizeof (struct rspamd_worker_param_parser));
- nhandler->name = name;
+ nhandler->key.name = name;
+ nhandler->key.ptr = target;
nhandler->parser.flags = flags;
nhandler->parser.offset = offset;
nhandler->parser.user_struct = target;
nhandler->handler = handler;
- HASH_ADD_KEYPTR (hh, nparser->parsers, name, strlen (name), nhandler);
+
+ g_hash_table_insert (nparser->parsers, &nhandler->key, nhandler);
}
gboolean (*func)(ucl_object_t *, gpointer), gpointer ud)
{
struct rspamd_worker_cfg_parser *nparser;
- HASH_FIND_INT (cfg->wrk_parsers, &type, nparser);
+
+ nparser = g_hash_table_lookup (cfg->wrk_parsers, &type);
+
if (nparser == NULL) {
/* Allocate new parser for this worker */
nparser =
rspamd_mempool_alloc0 (cfg->cfg_pool,
sizeof (struct rspamd_worker_cfg_parser));
nparser->type = type;
- HASH_ADD_INT (cfg->wrk_parsers, type, nparser);
+ nparser->parsers = g_hash_table_new (rspamd_worker_param_key_hash,
+ rspamd_worker_param_key_equal);
+ rspamd_mempool_add_destructor (cfg->cfg_pool,
+ (rspamd_mempool_destruct_t)g_hash_table_unref, nparser->parsers);
+
+ g_hash_table_insert (cfg->wrk_parsers, &nparser->type, nparser);
}
nparser->def_obj_parser = func;
projects / rspamd.git / commitdiff