Method run

lib_acl_cpp/samples/check_trigger/http_job.cpp:19–81

}

void* http_job::run()
{
	char  addr[256];
	if (acl::http_utils::get_addr(url_, addr, sizeof(addr)) == false)
	{
		logger_error("invalid url: %s", url_.c_str());
		return NULL;
	}

	char* domain = addr, *ptr = strchr(domain, ':');
	int   port;
	if (ptr == NULL)
		port = 80;
	else
	{
		*ptr++ = 0;
		port = atoi(ptr);
	}

	std::vector<acl::string> ips;

	struct timeval begin, end;

	gettimeofday(&begin, NULL);

	// ��ѯ������ IP �б�
	if (dns_lookup(domain, ips) == false)
	{
		delete this;
		return NULL;
	}

	gettimeofday(&end, NULL);

	// ���� DNS �IJ�ѯ��ʱ
	double spent = util::stamp_sub(&end, &begin);

	std::vector<acl::thread*> threads;

	// ���� IP ��ַ�б���ÿһ�� IP ����һ�� HTTP �ͻ����߳�
	std::vector<acl::string>::const_iterator cit = ips.begin();
	for (; cit != ips.end(); ++cit)
	{
		// ����������һ���̶߳���
		acl::thread* thr = new http_thread(domain, (*cit).c_str(),
				port, url_.c_str(), spent);
		thr->set_detachable(false);  // �����߳�Ϊ�Ƿ���״̬
		thr->start();
		threads.push_back(thr);
	}

	// �ȴ����� HTTP �����߳�ִ�����
	std::vector<acl::thread*>::iterator it = threads.begin();
	for (; it != threads.end(); ++it)
	{
		acl::thread* thr = (*it);
		thr->wait();
		delete thr;