Method open

lib_acl_cpp/src/stream/mbedtls_io.cpp:213–288

#endif

bool mbedtls_io::open(ACL_VSTREAM* s)
{
	if (s == NULL) {
		logger_error("s null");
		return false;
	}

#ifdef HAS_MBEDTLS
	// ��ֹ�ظ����� open ����
	if (ssl_ != NULL) {
		// �����ͬһ�������򷵻� true
		if (this->stream_ == s) {
			return true;
		} else if (ACL_VSTREAM_SOCK(stream_) == ACL_VSTREAM_SOCK(s)) {
			long long n = ++(*refers_);
			logger_warn("used by multiple stream, refers=%lld", n);
			return true;
		}

		// ���򣬽�ֹͬһ�� SSL IO ���󱻰��ڲ�ͬ����������
		logger_error("open again, stream_ changed!");
		return false;
	}

	char host[128];
	host[0] = 0;

	const char* peer = ACL_VSTREAM_PEER(s);
	if (peer && *peer) {
		safe_snprintf(host, sizeof(host), "%s", peer);
	} else if (acl_getpeername(ACL_VSTREAM_SOCK(s), host, sizeof(host))) {
		logger_error("can't acl_getpeername error=%s", last_serror());
		return false;
	}

	char* ptr = strrchr(host, '|');
	if (ptr == NULL) {
		ptr = strrchr(host, ':');
	}
	if (ptr) {
		*ptr = 0;
	}

	this->stream_ = s;
	++(*refers_);

	ssl_ = acl_mycalloc(1, sizeof(mbedtls_ssl_context));

	// ��ʼ�� SSL ����
	__ssl_init((mbedtls_ssl_context*) ssl_);

	if (!sni_host_.empty()) {
		__ssl_set_hostname((mbedtls_ssl_context*) ssl_, sni_host_.c_str());
	} else if (host[0]) {
		__ssl_set_hostname((mbedtls_ssl_context*) ssl_, host);
	}

	// ����ȫ�ֲ���������֤�顢˽Կ��