Function main

lib_acl_cpp/samples/multicast/main.cpp:141–262

}

int main(int argc, char* argv[]) {
	acl::string multicast_addr, local_iface = "0.0.0.0";
	int ch, nsenders = 1, nreaders = 0, port = 8089, count = 10000;
	acl::atomic_long write_counter, read_counter;
	bool echo = false, loopback = false;

	while ((ch = getopt(argc, argv, "hm:l:p:n:w:r:EO")) > 0) {
		switch (ch) {
		case 'h':
			usage(argv[0]);
			return 0;
		case 'w':
			nsenders= atoi(optarg);
			break;
		case 'r':
			nreaders = atoi(optarg);
			break;
		case 'm':
			multicast_addr = optarg;
			break;
		case 'l':
			local_iface = optarg;
			break;
		case 'p':
			port = atoi(optarg);
			break;
		case 'n':
			count = atoi(optarg);
			break;
		case 'E':
			echo = true;
			break;
		case 'O':
			loopback = true;
			break;
		default:
			break;
		}
	}

	if (multicast_addr.empty()) {
		printf("multicast_addr empty!\r\n");
		usage(argv[0]);
		return 0;
	}

	acl::log::stdout_open(true);

	std::vector<acl::thread*> senders, readers;

	struct timeval begin;
	gettimeofday(&begin, NULL);

	for (int i = 0; i < nsenders; i++) {
		sender_thread* thread = new sender_thread(count, write_counter);
		thread->set_multicast_loopback(loopback);

		if (!thread->open(multicast_addr, local_iface, port)) {