diff options
author | José Bollo <jose.bollo@iot.bzh> | 2018-04-09 18:16:07 +0200 |
---|---|---|
committer | José Bollo <jose.bollo@iot.bzh> | 2018-06-15 17:57:36 +0200 |
commit | 4521c1e7ae5371ab9d639adc617d17fb4e8ded0c (patch) | |
tree | a8a1416a2d58c16ab3993c7e4dc405fc71daab6a /src/afb-autoset.c | |
parent | 63682b4da9d3e892d1d0a671de860adc43068142 (diff) |
api-v3: First draft
This commit introduces the bindings v3 API for bindings.
The documentation has still to be improved and will come
very soon.
Change-Id: I8f9007370e29f671fdfd1da87fff7372a17db7af
Signed-off-by: José Bollo <jose.bollo@iot.bzh>
Diffstat (limited to 'src/afb-autoset.c')
-rw-r--r-- | src/afb-autoset.c | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/src/afb-autoset.c b/src/afb-autoset.c new file mode 100644 index 00000000..102830cb --- /dev/null +++ b/src/afb-autoset.c @@ -0,0 +1,104 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo <jose.bollo@iot.bzh> + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#define _GNU_SOURCE + +#include <stdlib.h> +#include <stdint.h> +#include <string.h> +#include <errno.h> +#include <sys/types.h> +#include <sys/stat.h> +#include <fcntl.h> +#include <unistd.h> + +#include "verbose.h" +#include "afb-api-ws.h" +#include "afb-api-so.h" +#include "afb-apiset.h" +#include "afb-autoset.h" + +static void cleanup(void *closure) +{ + struct afb_apiset *call_set = closure; + afb_apiset_unref(call_set); +} + +static int onlack(void *closure, struct afb_apiset *set, const char *name, int (*create)(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set)) +{ + struct afb_apiset *call_set = closure; + char *path; + const char *base; + size_t lbase, lname; + + base = afb_apiset_name(set); + lbase = strlen(base); + lname = strlen(name); + + path = alloca(2 + lbase + lname); + memcpy(path, base, lbase); + path[lbase] = '/'; + memcpy(&path[lbase + 1], name, lname + 1); + + return create(path, set, call_set); +} + +static int add(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set, int (*callback)(void *, struct afb_apiset *, const char*)) +{ + struct afb_apiset *ownset; + + /* create a sub-apiset */ + ownset = afb_apiset_create_subset_last(declare_set, path, 3600); + if (!ownset) { + ERROR("Can't create apiset autoset-ws %s", path); + return -1; + } + + /* set the onlack behaviour on this set */ + afb_apiset_onlack_set(ownset, callback, afb_apiset_addref(call_set), cleanup); + return 0; +} + +static int create_ws(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set) +{ + return afb_api_ws_add_client(path, declare_set, call_set, 0) >= 0; +} + +static int onlack_ws(void *closure, struct afb_apiset *set, const char *name) +{ + return onlack(closure, set, name, create_ws); +} + +int afb_autoset_add_ws(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set) +{ + return add(path, declare_set, call_set, onlack_ws); +} + +static int create_so(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set) +{ + return afb_api_so_add_binding(path, declare_set, call_set) >= 0; +} + +static int onlack_so(void *closure, struct afb_apiset *set, const char *name) +{ + return onlack(closure, set, name, create_so); +} + +int afb_autoset_add_so(const char *path, struct afb_apiset *declare_set, struct afb_apiset *call_set) +{ + return add(path, declare_set, call_set, onlack_so); +} |