summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYoungHun Kim <yh8004.kim@samsung.com>2019-09-06 11:04:34 +0900
committerYoungHun Kim <yh8004.kim@samsung.com>2019-09-06 11:19:35 +0900
commit8e2e4707e4f441da9f9e91ce6720a06495baf2f0 (patch)
tree9a59654bd8399a4e44d85dc1b15348c212b841b4
parentefefe8c9a0fc257fa747593b3e5f6a486f58198d (diff)
downloadmurphy-8e2e4707e4f441da9f9e91ce6720a06495baf2f0.tar.gz
murphy-8e2e4707e4f441da9f9e91ce6720a06495baf2f0.tar.bz2
murphy-8e2e4707e4f441da9f9e91ce6720a06495baf2f0.zip
Change-Id: Id6c12df20650310305282298752ea4986ff16592
-rw-r--r--src/common/mainloop.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/common/mainloop.c b/src/common/mainloop.c
index 72bc15a..a6a2b68 100644
--- a/src/common/mainloop.c
+++ b/src/common/mainloop.c
@@ -2182,6 +2182,9 @@ static void dispatch_poll_events(mrp_mainloop_t *ml)
int i, fd;
for (i = 0, e = ml->events; i < ml->poll_result; i++, e++) {
+ if (ml->quit)
+ break;
+
fd = e->data.fd;
w = fdtbl_lookup(ml->fdtbl, fd);
@@ -2193,7 +2196,7 @@ static void dispatch_poll_events(mrp_mainloop_t *ml)
if (!is_deleted(w)) {
mrp_debug("dispatching I/O watch %p (fd %d)", w, fd);
pthread_mutex_unlock(&ml->lock);
- w->cb(w, w->fd, e->events, w->user_data);
+ w->cb(w, w->fd, e->events, w->user_data); /* strm_recv_cb */
pthread_mutex_lock(&ml->lock);
}
else
@@ -2238,9 +2241,6 @@ static void dispatch_poll_events(mrp_mainloop_t *ml)
}
}
}
-
- if (ml->quit)
- break;
}
if (ml->quit)