return "add";
case EVENT_ACTION_REMOVE:
return "remove";
+ case EVENT_ACTION_URL:
+ return "url";
case EVENT_ACTION_DHCP:
return "dhcp";
default:
return 0;
}
+static int user_event_url(struct user_event *uev, struct event *event)
+{
+ struct device_handler *handler = uev->handler;
+ const char *url;
+
+ url = event_get_param(event, "url");
+ if (url)
+ device_handler_process_url(handler, url, NULL, NULL);
+
+ return 0;
+}
+
static void user_event_handle_message(struct user_event *uev, char *buf,
int len)
{
case EVENT_ACTION_REMOVE:
result = user_event_remove(uev, event);
break;
+ case EVENT_ACTION_URL:
+ result = user_event_url(uev, event);
+ break;
case EVENT_ACTION_CONF:
result = user_event_conf(uev, event);
break;
static int user_event_process(void *arg)
{
struct user_event *uev = arg;
- char buf[PBOOT_USER_EVENT_SIZE];
+ char buf[PBOOT_USER_EVENT_SIZE + 1];
int len;
- len = recvfrom(uev->socket, buf, sizeof(buf), 0, NULL, NULL);
+ len = recvfrom(uev->socket, buf, PBOOT_USER_EVENT_SIZE, 0, NULL, NULL);
if (len < 0) {
pb_log("%s: socket read failed: %s", __func__, strerror(errno));
return 0;
}
+ buf[len] = '\0';
+
pb_debug("%s: %u bytes\n", __func__, len);
user_event_handle_message(uev, buf, len);