Function apply_socket_commands

modules/freeswitch/fs_proc.c:591–627

* - reconnects any socket found in the "fs_sockets_down" list * - performs any necessary event subscribe / unsubscribe socket operations */

 * - performs any necessary event subscribe / unsubscribe socket operations
 */
static void apply_socket_commands(void)
{
	struct list_head *_, *__;
	fs_evs *sock;
	int rc;

#ifdef EXTRA_DEBUG
	LM_DBG("applying FS socket commands\n");
#endif

	lock_start_write(sockets_esl_lock);
	list_for_each_safe(_, __, fs_sockets_esl) {
		sock = list_entry(_, fs_evs, esl_cmd_list);

		/* above connect may have failed for this socket; skip it for now */
		if (!SHOULD_KEEP_EVS(sock) || !list_empty(&sock->reconnect_list))
			continue;

		rc = update_event_subscriptions(sock);
		if (rc != 0) {
			LM_ERR("%d errors while processing sock %s:%d commands\n",
			       rc, sock->host.s, sock->port);
			continue;
		}

		list_del(&sock->esl_cmd_list);
		INIT_LIST_HEAD(&sock->esl_cmd_list);
	}
	lock_stop_write(sockets_esl_lock);

	/* we may also clean up some sockets */
	lock_start_write(sockets_lock);
	lock_start_write(sockets_down_lock);
	handle_reconnects();
	lock_stop_write(sockets_down_lock);
	lock_stop_write(sockets_lock);
}

void fs_conn_mgr_loop(int proc_no)
{