Function test

lib_acl_cpp/samples/ssl/ssl_client2/ssl_client.cpp:11–59

static acl::sslbase_conf* __ssl_conf;

static bool test(const char* addr, int k, int nloop)
{
	acl::socket_stream client;
	if (!client.open(addr, 60, 60)) {
		std::cout << "connect " << addr << " error!" << std::endl;
		exit (1);
	}

	acl::sslbase_io* ssl = __ssl_conf->create(false);
	if (client.setup_hook(ssl) == ssl) {
		std::cout << "open ssl " << addr << " error!" << std::endl;
		ssl->destroy();
		exit (1);
	}

	std::cout << "ssl handshake ok, k: " << k << std::endl;

	for (int i = 0 ; i < nloop; i++) {
		char line[1024], line2[1024];
		memset(line, 'x', sizeof(line));
		line[1023] = 0;
		line[1022] = '\n';
		if (client.write(line, strlen(line)) == -1) {
			std::cout << "write to " << addr << " error!" << std::endl;
			return false;
		}

		size_t n = sizeof(line2);
		if (!client.gets(line2, &n)) {
			std::cout << "gets from " << addr << " error!"
				<< acl_last_serror() << std::endl;
			return false;
		}
		if (memcmp(line, line2, n) != 0) {
			std::cout << "read invalid line" << std::endl;
			return false;
		}
		if (i < 1 && k < 10) {
			std::cout << ">>gets(" << n << "): " << line2 << std::endl;
		}
		if (i > 0 && i % 1000 == 0) {
			char  buf[256];
			snprintf(buf, sizeof(buf), "write count: %d", i);
			ACL_METER_TIME(buf);
		}
	}

	return true;
}

class test_thread : public acl::thread
{