Function run

lib_acl_cpp/samples/udp_client/main.cpp:10–83

static bool  __server_fixed = true;

static void run(void)
{
	acl::socket_stream stream;
	char* buf;

	// �󶨱��ص�ַ
	if (stream.bind_udp(__local_addr) == false)
	{
		printf("bind addr %s error %s\r\n",
			__server_addr, acl::last_serror());
		return;
	}

	// ����Զ�̷����ַ
	else
		stream.set_peer(__server_addr);

	stream.set_rw_timeout(1);

	// �����ڴ�
	buf = (char*) malloc(__dat_length + 1);
	memset(buf, 'X', __dat_length);
	buf[__dat_length] = 0;

	char res[4096];

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

	int   i = 0, ret;
	for (; i < __max_count; i++)
	{
		// ����˿��ܻ��ñ�ĵ�ַ�ظ����ݣ�������Ҫ��������Զ�̷����ַ
		if (!__server_fixed)
			stream.set_peer(__server_addr);

		// ��������
		if (stream.write(buf, __dat_length) == -1)
		{
			printf("write error %s\r\n", acl::last_serror());
			break;
		}

		// ��������
		else if ((ret = stream.read(res, sizeof(res) - 1, false)) == -1)
		{
			printf("read error %s\r\n", acl::last_serror());
			break;
		}

		if (i % 1000 == 0)
		{
			res[ret] = 0;
			printf("read >>> %s\r\n", res);
		}

		if (i % 1000 == 0)
		{