diff options
author | José Bollo <jose.bollo@iot.bzh> | 2017-09-21 13:11:02 +0200 |
---|---|---|
committer | José Bollo <jose.bollo@iot.bzh> | 2017-10-09 14:08:32 +0200 |
commit | c12c74c208a30c5b18716b8faa464f0b4f643255 (patch) | |
tree | cdc3d6d44a7105aa43173601acbfbec7ed53e5fd /include/afb/afb-event.h | |
parent | 271bb6fc606fc5068a7b7a8f22b0052aca2fb900 (diff) |
Introduce afb_eventid
This new name is better suited because it is not an event
but the id of an event.
This also prepares the new api with pointers.
Change-Id: I7be88bb36cf72bf7df70793a77452e405130b951
Signed-off-by: José Bollo <jose.bollo@iot.bzh>
Diffstat (limited to 'include/afb/afb-event.h')
-rw-r--r-- | include/afb/afb-event.h | 98 |
1 files changed, 98 insertions, 0 deletions
diff --git a/include/afb/afb-event.h b/include/afb/afb-event.h new file mode 100644 index 00000000..c3686fdd --- /dev/null +++ b/include/afb/afb-event.h @@ -0,0 +1,98 @@ +/* + * Copyright (C) 2016, 2017 "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. + */ + +#pragma once + +#include "afb-eventid-itf.h" + +/* + * Describes the request of afb-daemon for bindings + */ +struct afb_event +{ + const struct afb_eventid_itf *itf; /* the interface to use */ + struct afb_eventid *closure; /* the closure argument for functions of 'itf' */ +}; + +/* + * Checks wether the 'event' is valid or not. + * + * Returns 0 if not valid or 1 if valid. + */ +static inline int afb_event_is_valid(struct afb_event event) +{ + return !!event.itf; +} + +/* + * Broadcasts widely the 'event' with the data 'object'. + * 'object' can be NULL. + * + * For convenience, the function calls 'json_object_put' for 'object'. + * Thus, in the case where 'object' should remain available after + * the function returns, the function 'json_object_get' shall be used. + * + * Returns the count of clients that received the event. + */ +static inline int afb_event_broadcast(struct afb_event event, struct json_object *object) +{ + return event.itf->broadcast(event.closure, object); +} + +/* + * Pushes the 'event' with the data 'object' to its observers. + * 'object' can be NULL. + * + * For convenience, the function calls 'json_object_put' for 'object'. + * Thus, in the case where 'object' should remain available after + * the function returns, the function 'json_object_get' shall be used. + * + * Returns the count of clients that received the event. + */ +static inline int afb_event_push(struct afb_event event, struct json_object *object) +{ + return event.itf->push(event.closure, object); +} + +/* OBSOLETE */ +#define afb_event_drop afb_event_unref + +/* + * Gets the name associated to the 'event'. + */ +static inline const char *afb_event_name(struct afb_event event) +{ + return event.itf->name(event.closure); +} + +/* + * Decreases the count of reference to 'event' and + * destroys the event when the reference count falls to zero. + */ +static inline void afb_event_unref(struct afb_event event) +{ + event.itf->unref(event.closure); +} + +/* + * Increases the count of reference to 'event' + */ +static inline void afb_event_addref(struct afb_event event) +{ + event.itf->addref(event.closure); +} + |