Code Review
/
src
/
app-framework-binder.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix a bug in subscribers counting
[src/app-framework-binder.git]
/
src
/
afb-evt.c
diff --git
a/src/afb-evt.c
b/src/afb-evt.c
index
88b6d60
..
7b7ce4f
100644
(file)
--- a/
src/afb-evt.c
+++ b/
src/afb-evt.c
@@
-28,6
+28,7
@@
#include <afb/afb-event-itf.h>
#include "afb-evt.h"
#include <afb/afb-event-itf.h>
#include "afb-evt.h"
+#include "verbose.h"
struct afb_evt_watch;
struct afb_evt_watch;
@@
-173,10
+174,11
@@
static int evt_push(struct afb_evt_event *evt, struct json_object *obj)
while(watch) {
listener = watch->listener;
assert(listener->itf->push != NULL);
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));
listener->itf->push(listener->closure, evt->name, evt->id, json_object_get(obj));
+ result++;
+ }
watch = watch->next_by_event;
watch = watch->next_by_event;
- result++;
}
pthread_mutex_unlock(&evt->mutex);
json_object_put(obj);
}
pthread_mutex_unlock(&evt->mutex);
json_object_put(obj);
@@
-480,7
+482,6
@@
int afb_evt_remove_watch(struct afb_evt_listener *listener, struct afb_event eve
watch = listener->watchs;
while(watch != NULL) {
if (watch->event == evt) {
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)
if (watch->activity != 0) {
watch->activity--;
if (watch->activity == 0 && listener->itf->remove != NULL)