Method handle_connect

lib_acl_cpp/src/http/http_aclient.cpp:166–239

}

bool http_aclient::handle_connect(const ACL_ASTREAM_CTX *ctx)
{
	const ACL_SOCKADDR *ns_addr = acl_astream_get_ns_addr(ctx);
	if (ns_addr) {
		memcpy(&ns_addr_, &ns_addr->ss, sizeof(ns_addr_));
	}
	const ACL_SOCKADDR* serv_addr = acl_astream_get_serv_addr(ctx);
	if (serv_addr) {
		memcpy(&serv_addr_, &serv_addr->ss, sizeof(serv_addr_));
	}

	ACL_ASTREAM* astream = acl_astream_get_conn(ctx);
	if (astream == NULL) {
		int status = acl_astream_get_status(ctx);
		switch (status) {
		case ACL_ASTREAM_STATUS_NS_ERROR:
			this->on_ns_failed();
			this->destroy();
			break;
		case ACL_ASTREAM_STATUS_CONNECT_TIMEOUT:
			this->on_connect_timeout();
			this->destroy();
			break;
		default:
			this->on_connect_failed();
			this->destroy();
			break;
		}
		return false;
	}

	// ���ӳɹ������� C++ AIO ���Ӷ���
	conn_ = NEW aio_socket_stream(&handle_, astream, true);

	// ע�����ӹرջص���������
	conn_->add_close_callback(this);

	// ע�� IO ��ʱ�ص���������
	conn_->add_timeout_callback(this);

	if (!ssl_conf_ || !ssl_enable_) {
		return this->on_connect();
	}

	// ��Ϊ������ SSL ͨ�ŷ�ʽ��������Ҫ���� SSL IO ���̣���ʼ SSL ����
	sslbase_io* ssl_io = ssl_conf_->create(true);

	const char* host;
	if (sni_host_.empty()) {
		host = header_->get_host();
	} else {
		host = sni_host_.c_str();
	}
	if (host && *host) {
		ssl_io->set_sni_host(host,
			sni_prefix_.empty() ? NULL : sni_prefix_.c_str(),
			sni_suffix_.empty() ? NULL : sni_suffix_.c_str());
	}