Function fs_run_esl_command

modules/freeswitch/fs_proc.c:393–432

}

void fs_run_esl_command(int sender, void *_cmd)
{
	fs_ipc_esl_cmd *cmd = (fs_ipc_esl_cmd *)_cmd;
	struct fs_esl_reply *reply;

	if (w_esl_send_recv(cmd->sock->handle, &cmd->fs_cmd, ESL_CMD) < 0) {
		LM_ERR("failed to run %.*s command on sock %s:%d\n",
		       cmd->fs_cmd.len, cmd->fs_cmd.s,
		       cmd->sock->host.s, cmd->sock->port);
		goto out;
	}

	LM_DBG("received reply: %s\n", cmd->sock->handle->last_sr_reply);

	reply = shm_malloc(sizeof *reply);
	if (!reply) {
		/* we already ran the command, just let the reader time out */
		LM_ERR("oom\n");
		goto out;
	}
	memset(reply, 0, sizeof *reply);

	reply->text.s = shm_strdup(cmd->sock->handle->last_sr_reply);
	if (!reply->text.s) {
		shm_free(reply);
		LM_ERR("oom\n");
		goto out;
	}
	reply->text.len = strlen(reply->text.s);
	reply->esl_reply_id = cmd->esl_reply_id;

	LM_DBG("adding to esl_replies\n");
	lock_start_write(cmd->sock->lists_lk);
	list_add_tail(&reply->list, &cmd->sock->esl_replies);
	lock_stop_write(cmd->sock->lists_lk);

out:
	shm_free(cmd->fs_cmd.s);
	shm_free(cmd);
}

int update_event_subscriptions(fs_evs *sock)
{