Method open

lib_acl_cpp/src/stream/openssl_io.cpp:222–284

#endif

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

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

#ifdef HAS_OPENSSL
	if (!nblock_ && conf_.is_sockopt_timeout() && s->rw_timeout > 0) {
		ACL_SOCKET fd = ACL_VSTREAM_SOCK(s);

		if (!set_sock_timeo(fd, SO_RCVTIMEO, s->rw_timeout)) {
			logger_error("set recv timeout error");
			return false;
		}

		if (!set_sock_timeo(fd, SO_SNDTIMEO, s->rw_timeout)) {
			logger_error("set send timeout error");
			return false;
		}
	}

	SSL_CTX* ctx = conf_.get_ssl_ctx();
	if (ctx == NULL) {
		logger_error("The default SSL_CTX in conf_ is null");
		return false;
	}

	SSL* ssl = __ssl_new(ctx);
	openssl_conf::bind(ssl, this);

	if (!__ssl_set_fd(ssl, (int) ACL_VSTREAM_SOCK(s))) {
		logger_error("SSL_set_fd error");
		__ssl_free(ssl);
		return false;
	}

	if (conf_.is_server_side()) {
		__ssl_set_accept_state(ssl);
	} else {
		if (!sni_host_.empty()) {
			__ssl_ctrl(ssl, SSL_CTRL_SET_TLSEXT_HOSTNAME,
				TLSEXT_NAMETYPE_host_name,
				(void*) sni_host_.c_str());
		}
		__ssl_set_connect_state(ssl);
	}

	ssl_ = ssl;

	if (nblock_) {
		return true;
	}

	return handshake();