X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fprocd.git;a=blobdiff_plain;f=service.c;h=44b10bef39481ccb5eda59a01086c222f804ea62;hp=27ed8c0a5ca3cad7485c8e807569f3eb39544bd8;hb=af863b697eacbe29db1d448886bebb2609922a64;hpb=133c19b8e4d1875a2ecb399fcadd29c0f81d98ae diff --git a/service.c b/service.c index 27ed8c0..44b10be 100644 --- a/service.c +++ b/service.c @@ -10,7 +10,6 @@ static void service_instance_add(struct service *s, struct blob_attr *attr) { struct service_instance *in; - const char *name = blobmsg_name(attr); if (blobmsg_type(attr) != BLOBMSG_TYPE_TABLE) return; @@ -20,7 +19,7 @@ service_instance_add(struct service *s, struct blob_attr *attr) return; instance_init(in, s, attr); - vlist_add(&s->instances, &in->node, (void *) name); + vlist_add(&s->instances, &in->node, (void *) in->name); } static void @@ -55,9 +54,7 @@ service_alloc(const char *name) struct service *s; char *new_name; - s = calloc(1, sizeof(*s) + strlen(name) + 1); - - new_name = (char *) (s + 1); + s = calloc_a(sizeof(*s), &new_name, strlen(name) + 1); strcpy(new_name, name); vlist_init(&s->instances, avl_strcmp, service_instance_update); @@ -119,6 +116,17 @@ static const struct blobmsg_policy service_attrs[__SERVICE_ATTR_MAX] = { [SERVICE_ATTR_NAME] = { "name", BLOBMSG_TYPE_STRING }, }; +enum { + SERVICE_DEL_ATTR_NAME, + SERVICE_DEL_ATTR_INSTANCE, + __SERVICE_DEL_ATTR_MAX, +}; + +static const struct blobmsg_policy service_del_attrs[__SERVICE_DEL_ATTR_MAX] = { + [SERVICE_DEL_ATTR_NAME] = { "name", BLOBMSG_TYPE_STRING }, + [SERVICE_DEL_ATTR_INSTANCE] = { "instance", BLOBMSG_TYPE_STRING }, +}; + static int service_handle_set(struct ubus_context *ctx, struct ubus_object *obj, @@ -197,12 +205,13 @@ service_handle_delete(struct ubus_context *ctx, struct ubus_object *obj, struct ubus_request_data *req, const char *method, struct blob_attr *msg) { - struct blob_attr *tb[__SERVICE_ATTR_MAX], *cur; + struct blob_attr *tb[__SERVICE_DEL_ATTR_MAX], *cur; struct service *s, *tmp; + struct service_instance *in; - blobmsg_parse(service_attrs, __SERVICE_ATTR_MAX, tb, blob_data(msg), blob_len(msg)); + blobmsg_parse(service_del_attrs, __SERVICE_DEL_ATTR_MAX, tb, blob_data(msg), blob_len(msg)); - cur = tb[SERVICE_ATTR_NAME]; + cur = tb[SERVICE_DEL_ATTR_NAME]; if (!cur) { avl_for_each_element_safe(&services, s, avl, tmp) service_delete(s); @@ -213,7 +222,20 @@ service_handle_delete(struct ubus_context *ctx, struct ubus_object *obj, if (!s) return UBUS_STATUS_NOT_FOUND; - service_delete(s); + cur = tb[SERVICE_DEL_ATTR_INSTANCE]; + if (!cur) { + service_delete(s); + return 0; + } + + in = vlist_find(&s->instances, blobmsg_data(cur), in, node); + if (!in) { + fprintf(stderr, "instance %s not found\n", (char *) blobmsg_data(cur)); + return UBUS_STATUS_NOT_FOUND; + } + + vlist_delete(&s->instances, &in->node); + return 0; } @@ -247,7 +269,7 @@ static struct ubus_method main_object_methods[] = { UBUS_METHOD("set", service_handle_set, service_set_attrs), UBUS_METHOD("add", service_handle_set, service_set_attrs), UBUS_METHOD("list", service_handle_list, service_attrs), - UBUS_METHOD("delete", service_handle_delete, service_attrs), + UBUS_METHOD("delete", service_handle_delete, service_del_attrs), UBUS_METHOD("update_start", service_handle_update, service_attrs), UBUS_METHOD("update_complete", service_handle_update, service_attrs), };