sstrncpy (t->name, ptr->name, sizeof (t->name));
memcpy (&t->proc, &ptr->proc, sizeof (t->proc));
- assert (t->proc.create != NULL);
t->user_data = NULL;
t->next = NULL;
- status = (*t->proc.create) (ci, &t->user_data);
- if (status != 0)
+ if (t->proc.create != NULL)
{
- WARNING ("Filter subsystem: Failed to create a %s match.",
- t->name);
- fc_free_targets (t);
- return (-1);
+ status = (*t->proc.create) (ci, &t->user_data);
+ if (status != 0)
+ {
+ WARNING ("Filter subsystem: Failed to create a %s match.",
+ t->name);
+ fc_free_targets (t);
+ return (-1);
+ }
+ }
+ else
+ {
+ t->user_data = NULL;
}
if (*targets_head != NULL)
if (strcasecmp ("Rule", option->key) == 0)
status = fc_config_add_rule (chain, option);
+ else if (strcasecmp ("Target", option->key) == 0)
+ status = fc_config_add_target (&chain->targets, option);
else
{
WARNING ("Filter subsystem: Chain %s: Option `%s' not allowed "
if (chain == NULL)
return (-1);
+ DEBUG ("fc_process_chain (chain = %s);", chain->name);
+
status = FC_ACTION_CONTINUE;
for (rule = chain->rules; rule != NULL; rule = rule->next)
{
fc_match_t *match;
+ if (rule->name[0] != 0)
+ {
+ DEBUG ("fc_process_chain: Testing the `%s' rule.", rule->name);
+ }
+
/* N. B.: rule->matches may be NULL. */
for (match = rule->matches; match != NULL; match = match->next)
{
&match->user_data);
if (status < 0)
{
- WARNING ("fc_process: A match failed.");
+ WARNING ("fc_process_chain: A match failed.");
break;
}
else if (status != FC_MATCH_MATCHES)
if (match != NULL)
continue;
+ if (rule->name[0] != 0)
+ {
+ DEBUG ("fc_process_chain: Rule `%s' matches.", rule->name);
+ }
+
for (target = rule->targets; target != NULL; target = target->next)
{
- /* If we get here, all matches have matched the value. Execute the target. */
+ /* If we get here, all matches have matched the value. Execute the
+ * target. */
status = (*target->proc.invoke) (ds, vl, /* meta = */ NULL,
&target->user_data);
if (status < 0)
{
- WARNING ("fc_process: A target failed.");
+ WARNING ("fc_process_chain: A target failed.");
continue;
}
else if (status == FC_ACTION_CONTINUE)
break;
else
{
- WARNING ("fc_process: Unknown target return value: %i", status);
+ WARNING ("fc_process_chain: Unknown target return value: %i", status);
}
}
if (status == FC_ACTION_STOP)
+ {
+ if (rule->name[0] != 0)
+ {
+ DEBUG ("fc_process_chain: Rule `%s' signaled the stop condition.",
+ rule->name);
+ }
break;
+ }
} /* for (rule) */
/* for-loop has been aborted: A target returned `FC_ACTION_STOP' */
for (target = chain->targets; target != NULL; target = target->next)
{
- /* If we get here, all matches have matched the value. Execute the target. */
+ /* If we get here, all matches have matched the value. Execute the
+ * target. */
status = (*target->proc.invoke) (ds, vl, /* meta = */ NULL,
&target->user_data);
if (status < 0)
{
- WARNING ("fc_process: The default target failed.");
+ WARNING ("fc_process_chain: The default target failed.");
}
}
{
fc_match_t *m;
+ DEBUG ("fc_register_match (%s);", name);
+
m = (fc_match_t *) malloc (sizeof (*m));
if (m == NULL)
return (-ENOMEM);
{
fc_target_t *t;
+ DEBUG ("fc_register_target (%s);", name);
+
t = (fc_target_t *) malloc (sizeof (*t));
if (t == NULL)
return (-ENOMEM);
if (chain != NULL)
return (fc_process_chain (ds, vl, chain));
- ERROR ("fc_process: TODO: Implement default behavior!");
-
- return (0);
+ return (fc_bit_write_invoke (ds, vl,
+ /* meta = */ NULL, /* user_data = */ NULL));
} /* }}} int fc_process */
int fc_configure (const oconfig_item_t *ci) /* {{{ */