X-Git-Url: http://git.ozlabs.org/?p=petitboot;a=blobdiff_plain;f=ui%2Fcommon%2Fdiscover-client.c;h=8ad4611b3a913d7387fdb1946ff1e2efaa4e963b;hp=dce74f9080b527a23afc7acd73dcf7b971e04faa;hb=5b3dd56d982629349e612b9e984e65dec09b438f;hpb=d90efe9e2bbfb18ee05ec2032b5723dbfa902d82;ds=sidebyside diff --git a/ui/common/discover-client.c b/ui/common/discover-client.c index dce74f9..8ad4611 100644 --- a/ui/common/discover-client.c +++ b/ui/common/discover-client.c @@ -112,6 +112,21 @@ static void device_remove(struct discover_client *client, const char *id) talloc_free(device); } +static void plugin_option_add(struct discover_client *client, + struct plugin_option *opt) +{ + talloc_steal(client, opt); + + if (client->ops.plugin_option_add) + client->ops.plugin_option_add(opt, client->ops.cb_arg); +} + +static void plugins_remove(struct discover_client *client) +{ + if (client->ops.plugins_remove) + client->ops.plugins_remove(client->ops.cb_arg); +} + void discover_client_enumerate(struct discover_client *client) { struct boot_option *opt; @@ -155,6 +170,7 @@ static int discover_client_process(void *arg) { struct discover_client *client = arg; struct pb_protocol_message *message; + struct plugin_option *p_opt; struct system_info *sysinfo; struct boot_option *opt; struct status *status; @@ -235,6 +251,20 @@ static int discover_client_process(void *arg) } update_config(client, config); break; + case PB_PROTOCOL_ACTION_PLUGIN_OPTION_ADD: + p_opt = talloc_zero(ctx, struct plugin_option); + + rc = pb_protocol_deserialise_plugin_option(p_opt, message); + if (rc) { + pb_log("%s: no plugin_option?\n", __func__); + goto out; + } + + plugin_option_add(client, p_opt); + break; + case PB_PROTOCOL_ACTION_PLUGINS_REMOVE: + plugins_remove(client); + break; default: pb_log("%s: unknown action %d\n", __func__, message->action); } @@ -404,3 +434,21 @@ int discover_client_send_url(struct discover_client *client, return pb_protocol_write_message(client->fd, message); } + +int discover_client_send_plugin_install(struct discover_client *client, + char *file) +{ + struct pb_protocol_message *message; + int len; + + len = pb_protocol_url_len(file); + + message = pb_protocol_create_message(client, + PB_PROTOCOL_ACTION_PLUGIN_INSTALL, len); + if (!message) + return -1; + + pb_protocol_serialise_url(file, message->payload, len); + + return pb_protocol_write_message(client->fd, message); +}