12 static const struct blobmsg_policy instance_attr[__INSTANCE_ATTR_MAX] = {
13 [INSTANCE_ATTR_COMMAND] = { "command", BLOBMSG_TYPE_ARRAY },
14 [INSTANCE_ATTR_ENV] = { "env", BLOBMSG_TYPE_TABLE },
15 [INSTANCE_ATTR_DATA] = { "data", BLOBMSG_TYPE_TABLE },
19 instance_start(struct service_instance *in)
27 instance_timeout(struct uloop_timeout *t)
29 struct service_instance *in;
31 in = container_of(t, struct service_instance, timeout);
32 kill(in->proc.pid, SIGKILL);
33 uloop_process_delete(&in->proc);
34 in->proc.cb(&in->proc, -1);
38 instance_exit(struct uloop_process *p, int ret)
40 struct service_instance *in;
42 in = container_of(p, struct service_instance, proc);
43 uloop_timeout_cancel(&in->timeout);
49 instance_stop(struct service_instance *in, bool restart)
51 if (!in->proc.pending)
54 kill(in->proc.pid, SIGTERM);
58 instance_config_changed(struct service_instance *in, struct service_instance *in_new)
63 if (!blob_attr_equal(in->command, in_new->command))
66 if (!blobmsg_list_equal(&in->env, &in_new->env))
69 if (!blobmsg_list_equal(&in->data, &in_new->data))
76 instance_config_parse(struct service_instance *in)
78 struct blob_attr *tb[__INSTANCE_ATTR_MAX];
79 struct blob_attr *cur;
81 blobmsg_parse(instance_attr, __INSTANCE_ATTR_MAX, tb,
82 blobmsg_data(in->config), blobmsg_data_len(in->config));
83 if (!tb[INSTANCE_ATTR_COMMAND])
86 if ((cur = tb[INSTANCE_ATTR_ENV]))
87 blobmsg_list_fill(&in->env, blobmsg_data(cur), blobmsg_data_len(cur));
89 if ((cur = tb[INSTANCE_ATTR_DATA]))
90 blobmsg_list_fill(&in->data, blobmsg_data(cur), blobmsg_data_len(cur));
96 instance_config_cleanup(struct service_instance *in)
98 blobmsg_list_free(&in->env);
99 blobmsg_list_free(&in->data);
103 instance_config_move(struct service_instance *in, struct service_instance *in_src)
105 instance_config_cleanup(in);
106 blobmsg_list_move(&in->env, &in_src->env);
107 blobmsg_list_move(&in->data, &in_src->data);
108 in->command = in_src->command;
112 instance_update(struct service_instance *in, struct service_instance *in_new)
114 bool changed = instance_config_changed(in, in_new);
116 in->config = in_new->config;
121 instance_stop(in, true);
122 instance_config_move(in, in_new);
127 instance_free(struct service_instance *in)
129 uloop_process_delete(&in->proc);
130 uloop_timeout_cancel(&in->timeout);
131 instance_config_cleanup(in);
136 instance_init(struct service_instance *in, struct blob_attr *config)
139 in->timeout.cb = instance_timeout;
140 in->proc.cb = instance_exit;
142 blobmsg_list_simple_init(&in->env);
143 blobmsg_list_simple_init(&in->data);
144 in->valid = instance_config_parse(in);