Function main_dispatch_receive

lib_fiber/cpp/src/fiber_server.cpp:463–496

}

static int main_dispatch_receive(int dispatch_fd)
{
	char  buf[256], remote[256], local[256];
	int   fd = -1, ret;
	ACL_VSTREAM *cstream;
	ACL_FIBER_ATTR attr;

	acl_fiber_attr_init(&attr);
	acl_fiber_attr_setstacksize(&attr, acl_var_fiber_stack_size);
	acl_fiber_attr_setsharestack(&attr, acl_var_fiber_share_stack ? 1 : 0);

	ret = acl_read_fd(dispatch_fd, buf, sizeof(buf) - 1, &fd);
	if (ret < 0 || fd < 0) {
		acl_msg_warn("%s(%d), %s: read from master_dispatch(%s) error",
			__FILE__, __LINE__, __FUNCTION__,
			acl_var_fiber_dispatch_addr);
		return -1;
	}

	buf[ret] = 0;

	cstream = acl_vstream_fdopen(fd, O_RDWR, acl_var_fiber_buf_size,
		acl_var_fiber_rw_timeout, ACL_VSTREAM_TYPE_SOCK);

	if (acl_getsockname(fd, local, sizeof(local)) == 0) {
		acl_vstream_set_local(cstream, local);
	}
	if (acl_getpeername(fd, remote, sizeof(remote)) == 0) {
		acl_vstream_set_peer(cstream, remote);
	}

	acl_fiber_create2(&attr, fiber_client, cstream);
	return 0;
}

static int main_dispatch_report(ACL_VSTREAM *conn)
{