Function parent

lib_acl/samples/vstream_popen/main.cpp:92–150

}

static void parent(int argc acl_unused, char *argv[])
{
	const char *myname = "parent";
	char  *command;
	ACL_ARGV *env = acl_argv_split("name1&value1&name2&����ֵ2&name3&����ֵ4", "&");
	ACL_VSTREAM *stream;
	ACL_ARGV *args = acl_argv_alloc(1);
	char  buf[1024];
	int   ret, i;

	acl_lib_init();
	printf("%s: pid = %d\r\n", myname, getpid());
	command = argv[0];
	acl_argv_add(args, command, "-c", NULL);

	stream = acl_vstream_popen(O_RDWR,
				ACL_VSTREAM_POPEN_ARGV, args->argv,
				ACL_VSTREAM_POPEN_ENV, env->argv,
				ACL_VSTREAM_POPEN_END);
	if (stream == NULL) {
		acl_msg_error("%s(%d): popen %s error(%s)",
			myname, __LINE__, command, acl_last_serror());
		goto error_end;
	}

	pipe_status(stream);

	printf("%s: open pipe ok\r\n", myname);

	i = 0;
	while (1) {
		pipe_status(stream);
		ret =acl_vstream_fprintf(stream, ">>from server<<\r\n");
		if (ret == ACL_VSTREAM_EOF) {
			printf("%s: fprintf to child error(%s)\r\n",
				myname, acl_last_serror());
			break;
		} else
			printf("%s: fprintf to child ok\r\n", myname);

		printf("%s: begin wait client msg\n", myname);
		ret = acl_vstream_gets_nonl(stream, buf, sizeof(buf));
		if (ret == ACL_VSTREAM_EOF) {
			printf("%s: gets from child error(%s)\r\n",
				myname, acl_last_serror());
			break;
		}
		buf[ret] = 0;
		printf("%s: gets from child ok(%s), i=%d\r\n", myname, buf, i++);
	}

	acl_vstream_pclose(stream);

error_end:

	acl_argv_free(env);
	acl_argv_free(args);
	acl_lib_end();