Function run_server

lib_protocol/samples/httpd/main.c:152–193

}

static void run_server(const char *addr)
{
	ACL_VSTREAM *sstream = acl_vstream_listen(addr, 128);
	acl_pthread_pool_t *pool;
	CONN *conn;
	acl_pthread_t tid;
	acl_pthread_attr_t attr;
	ACL_VSTREAM *client;

	if (sstream == NULL) {
		acl_msg_error("listen %s error(%s)", addr, acl_last_serror());
		return;
	}

	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

	printf("listening on %s ...\n", addr);
	pool = acl_thread_pool_create(10, 10);
	while (1) {
		acl_mem_slice_delay_destroy();
		if (acl_read_wait(ACL_VSTREAM_SOCK(sstream), 5) == -1)
			continue;
		client = acl_vstream_accept(sstream, NULL, 0);
		if (client == NULL) {
			acl_msg_error("accept error(%s)", acl_last_serror());
			break;
		}
		acl_tcp_set_nodelay(ACL_VSTREAM_SOCK(client));
		conn = acl_mycalloc(1, sizeof(CONN));
		conn->stream = client;

		if (0)
			thread_run(conn);
		else if (1)
			acl_pthread_create(&tid, &attr, thread_main, conn);
		else
			acl_pthread_pool_add(pool, thread_run, conn);
	}

	acl_vstream_close(sstream);
}

static void run_client(const char *addr, const char *filename)
{