#include <afb/afb-event-itf.h>
#include "afb-evt.h"
+#include "verbose.h"
struct afb_evt_watch;
while(watch) {
listener = watch->listener;
assert(listener->itf->push != NULL);
- if (watch->activity != 0)
+ if (watch->activity != 0) {
listener->itf->push(listener->closure, evt->name, evt->id, json_object_get(obj));
+ result++;
+ }
watch = watch->next_by_event;
- result++;
}
pthread_mutex_unlock(&evt->mutex);
json_object_put(obj);
if (evt != NULL) {
/* unlinks the event if valid! */
pthread_mutex_lock(&events_mutex);
+ found = 0;
prv = &events;
while (*prv && !(found = (*prv == evt)))
prv = &(*prv)->next;
watch = listener->watchs;
while(watch != NULL) {
if (watch->event == evt) {
- /* found: remove it */
if (watch->activity != 0) {
watch->activity--;
if (watch->activity == 0 && listener->itf->remove != NULL)