Function mi_script_async_func

modules/mi_script/mi_script.c:708–771

}

static int mi_script_async_func(struct sip_msg *msg, async_ctx *ctx,
		str *m, pv_spec_p r, pv_spec_p p, pv_spec_p v)
{
	struct mi_cmd *cmd = NULL;
	struct mi_script_async_job *job;
	mi_request_t *req;
	str method, params;
	int fd;
	pv_value_t val;
	char *err = "unknown error";

	mi_script_get_method(m, &method, &params);

	cmd = lookup_mi_cmd(method.s, method.len);
	if (!cmd)
		return -1;

	req = mi_script_parse_request(&method, &params, p, v, 1);
	if (!req) {
		err = "could not parse parameters";
		goto error;
	}
	fd = eventfd(0, 0);
	if (fd < 0) {
		err = "could not create event descriptor";
		goto error;
	}
	job = shm_malloc(sizeof *job);
	if (!job) {
		err = "could not create new job";
		goto error;
	}
	memset(job, 0, sizeof *job);

	async_status = fd;
	ASYNC_SET_RESUME_F(ctx, mi_script_async_resume);
	ctx->resume_param = job;

	job->ret = r;
	job->fd = fd;
	job->cmd = cmd;
	job->req = req;
	job->process_no = process_no;

	if (ipc_dispatch_rpc(mi_script_async_start_job, job) < 0) {
		err = "could not dispatch job";
		shm_free(job);
		goto close;
	}
	return 1;

close:
	close(fd);
error:
	LM_ERR("%s!\n", err);
	if (r) {
		init_str(&val.rs, err);
		val.flags = PV_VAL_STR;