From 4631e6cdfab6e9cb70c11a0c33098ee06e09e786 Mon Sep 17 00:00:00 2001 From: lazedo Date: Fri, 30 Jun 2017 12:38:32 +0100 Subject: [PATCH] FS-10453 [kazoo] fix dropped messages --- src/mod/event_handlers/mod_kazoo/kazoo_node.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/mod/event_handlers/mod_kazoo/kazoo_node.c b/src/mod/event_handlers/mod_kazoo/kazoo_node.c index 1748b7c3ee..17da6dc582 100644 --- a/src/mod/event_handlers/mod_kazoo/kazoo_node.c +++ b/src/mod/event_handlers/mod_kazoo/kazoo_node.c @@ -1312,8 +1312,8 @@ static void *SWITCH_THREAD_FUNC handle_node(switch_thread_t *thread, void *obj) } } - while (switch_queue_trypop(ei_node->send_msgs, &pop) == SWITCH_STATUS_SUCCESS - && ++send_msg_count <= kazoo_globals.send_msg_batch) { + while (++send_msg_count <= kazoo_globals.send_msg_batch + && switch_queue_trypop(ei_node->send_msgs, &pop) == SWITCH_STATUS_SUCCESS) { ei_send_msg_t *send_msg = (ei_send_msg_t *) pop; ei_helper_send(ei_node, &send_msg->pid, &send_msg->buf); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Sent erlang message to %s <%d.%d.%d>\n"