Function w_async_exec

modules/exec/exec_mod.c:276–339

inline static int w_async_exec(struct sip_msg* msg, async_ctx *ctx,
		str* cmd, str* in, pv_spec_t* out, pv_spec_t* err, pv_spec_t* avp_env)
{
	struct hf_wrapper *hf=0;
	environment_t* backup_env=0;
	exec_async_param *param;
	int ret, fd;

	if (msg == 0 || cmd == 0)
		return -1;

	if (avp_env != NULL) {
		if ((hf=get_avp_values_list(msg, &(avp_env->pvp))) == 0)
			return -1;
		backup_env=replace_env(hf);
		if (!backup_env) {
			LM_ERR("replace env failed\n");
			release_vars(hf);
			release_hf_struct(hf);
			return -1;
		}
		release_hf_struct(hf);
	}

	/* better do this alloc now (before starting the async) to avoid
	 * the unplesant situation of having the async started and have a
	 * memory failure -> tricky to recover */
	param = (exec_async_param*)shm_malloc(sizeof(exec_async_param));
	if(param==NULL) {
		LM_ERR("failed to allocate new async param\n");
		if (backup_env) unset_env(backup_env);
		return -1;
	}

	ret = start_async_exec(msg, cmd, in, out, &fd);

	if (backup_env)
		unset_env(backup_env);

	/* populate resume point (if async started) */
	if (ret==1) {
		param->outvar = out;
		/* that ^^^^ is save as "out" is a in private mem, but in all
		 * processes (set before forking) */
		param->buf = NULL;
		ctx->resume_param = (void*)param;
		ASYNC_SET_RESUME_F(ctx, resume_async_exec);
		async_status = fd;
	} else if (ret==2) {
		/* no IO done, but success */
		shm_free(param);
		ctx->resume_param = NULL;
		ASYNC_CLEAR_RESUME_F(ctx);
		async_status = ASYNC_NO_IO;
	} else {
		/* error */
		shm_free(param);
		ctx->resume_param = NULL;