kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #1321 in FS/freeswitch from ~LAZEDO/freeswitch:bug/fs-10453 to master 

* commit '4631e6cdfab6e9cb70c11a0c33098ee06e09e786':
  FS-10453 [kazoo] fix dropped messages
This commit is contained in:
Mike Jerris 2017-06-30 17:19:51 +00:00
parent 8be0a2c1c4 4631e6cdfa
commit fc1dd2a4ef
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/mod/event_handlers/mod_kazoo/kazoo_node.c
View File

@ -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"