X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafm-user-daemon.c;fp=src%2Fafm-user-daemon.c;h=d4a955830f907b7a3bb7abc5fa9ffbf9202115f5;hb=a1f7f7d2cd79c9391368d0c017452566a5edc44c;hp=e71e011278d8a98abcc36a9553da34b0bd2f6fd8;hpb=b6ac54640c918aecaf2f28edf82f8217154b12f3;p=src%2Fapp-framework-main.git diff --git a/src/afm-user-daemon.c b/src/afm-user-daemon.c index e71e011..d4a9558 100644 --- a/src/afm-user-daemon.c +++ b/src/afm-user-daemon.c @@ -185,7 +185,6 @@ static void on_detail(struct sd_bus_message *smsg, struct json_object *obj, void json_object_put(resp); } - /* * On query "start" from 'smsg' with parameters of 'obj'. */ @@ -253,6 +252,42 @@ static void on_start(struct sd_bus_message *smsg, struct json_object *obj, void free(uri); } +/* + * On query "once" from 'smsg' with parameters of 'obj'. + */ +static void on_once(struct sd_bus_message *smsg, struct json_object *obj, void *unused) +{ + const char *appid; + struct json_object *appli, *resp; + int runid; + + /* get the parameters */ + if (!j_read_string(obj, &appid) && !j_read_string_at(obj, "id", &appid)) { + jbus_reply_error_s(smsg, error_bad_request); + return; + } + + /* get the application */ + INFO("method once called for %s", appid); + appli = afm_db_get_application(afdb, appid); + if (appli == NULL) { + jbus_reply_error_s(smsg, error_not_found); + return; + } + + /* launch the application */ + runid = afm_run_once(appli); + if (runid <= 0) { + jbus_reply_error_s(smsg, error_cant_start); + return; + } + + /* returns the state */ + resp = afm_run_state(runid); + reply(smsg, resp, error_not_found); + json_object_put(resp); +} + /* * On query "pause" from 'smsg' with parameters of 'obj'. */ @@ -600,6 +635,7 @@ int main(int ac, char **av) if (jbus_add_service_j(user_bus, "runnables", on_runnables, NULL) || jbus_add_service_j(user_bus, "detail", on_detail, NULL) || jbus_add_service_j(user_bus, "start", on_start, NULL) + || jbus_add_service_j(user_bus, "once", on_once, NULL) || jbus_add_service_j(user_bus, "terminate", on_terminate, NULL) || jbus_add_service_j(user_bus, "pause", on_pause, NULL) || jbus_add_service_j(user_bus, "resume", on_resume, NULL)