headerlen = strnlen(buf, len);
if (!headerlen) {
- pb_log("%s: bad header, no data\n", __func__);
+ pb_log_fn("bad header, no data\n");
return -1;
}
/* we should see an <action>@<device>\0 at the head of the buffer */
sep = strchr(buf, '@');
if (!sep) {
- pb_log("%s: bad header: %s\n", __func__, buf);
+ pb_log_fn("bad header: %s\n", buf);
return -1;
}
*action = EVENT_ACTION_BOOT;
else if (streq(buf, "sync"))
*action = EVENT_ACTION_SYNC;
+ else if (streq(buf, "plugin"))
+ *action = EVENT_ACTION_PLUGIN;
else {
- pb_log("%s: unknown action: %s\n", __func__, buf);
+ pb_log_fn("unknown action: %s\n", buf);
return -1;
}
if (!*(sep + 1)) {
- pb_log("%s: bad device: %s\n", __func__, buf);
+ pb_log_fn("bad device: %s\n", buf);
return -1;
}
static void event_parse_params(struct event *event, const char *buf, int len)
{
int param_len, name_len, value_len;
- struct param *param;
+ struct event_param *param;
char *sep;
for (; len > 0; len -= param_len + 1, buf += param_len + 1) {
/* update the params array */
event->params = talloc_realloc(event, event->params,
- struct param, ++event->n_params);
+ struct event_param, ++event->n_params);
param = &event->params[event->n_params - 1];
sep = memchr(buf, '=', param_len);
void event_set_param(struct event *event, const char *name, const char *value)
{
- struct param *param;
+ struct event_param *param;
int i;
/* if it's already present, replace the value of the old param */
/* not found - create a new param */
event->params = talloc_realloc(event, event->params,
- struct param, ++event->n_params);
+ struct event_param, ++event->n_params);
param = &event->params[event->n_params - 1];
param->name = talloc_strdup(event, name);