Function main

lib_acl/samples/udp/server/main.cpp:141–203

}

int main(int argc, char *argv[])
{
	char  local[64];
	int   ch, inter = 1000, nthreads = 1;
	int   need_echo = 0, mio_on = 0;

	acl_lib_init();
	acl_msg_stdout_enable(1);

	snprintf(local, sizeof(local), "127.0.0.1:8888");

	while ((ch = getopt(argc, argv, "hs:i:t:em")) > 0) {
		switch (ch) {
		case 'h':
			usage(argv[0]);
			return 0;
		case 's':
			snprintf(local, sizeof(local), "%s", optarg);
			break;
		case 'i':
			inter = atoi(optarg);
			break;
		case 't':
			nthreads = atoi(optarg);
			break;
		case 'e':
			need_echo = 1;
			break;
		case 'm':
			mio_on = 1;
			break;
		default:
			break;
		}
	}

	if (local[0] == 0) {
		usage(argv[0]);
		return 1;
	}

	if (nthreads > 1) {
		int   i;
		acl_pthread_pool_t *threads =
			acl_thread_pool_create(nthreads, 120);
		for (i = 0; i < nthreads; i++) {
			THREAD_CTX *ctx = (THREAD_CTX*)
				acl_mymalloc(sizeof(THREAD_CTX));
			snprintf(ctx->local, sizeof(ctx->local), "%s", local);
			ctx->inter = inter;
			ctx->need_echo = need_echo;
			ctx->mio_on = mio_on;
			acl_pthread_pool_add(threads, thread_run, ctx);
		}

		acl_pthread_pool_destroy(threads);
	} else
		run(local, inter, mio_on, need_echo);