提交 0c25c3de authored 作者: Travis Cross's avatar Travis Cross

mod_fifo: Document node_thread_run()

上级 80ccaf34
......@@ -1997,6 +1997,20 @@ static void find_consumers(fifo_node_t *node)
switch_safe_free(sql);
}
/*\brief Continuously attempt to deliver calls to outbound members
*
* For each outbound priority level 1-10, find fifo nodes with a
* matching priority. For each of those nodes with outbound members,
* run `find_consumers()` if the fifo node has calls needing to be
* delivered and not enough ready and waiting inbound consumers.
*
* In the event of nothing needing to be done, each cycle starts at
* priority 1 and ends at priority 10, yielding for one second
* afterward. We also yield after initiating outbound calls, starting
* again where we left off on the next node.
*
* We also take care of cleaning up after nodes queued for deletion.
*/
static void *SWITCH_THREAD_FUNC node_thread_run(switch_thread_t *thread, void *obj)
{
fifo_node_t *node, *last, *this_node;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论