Method open

lib_acl_cpp/src/mqtt/mqtt_aclient.cpp:54–63

}

bool mqtt_aclient::open(const char* addr, int conn_timeout, int rw_timeout) {
	ACL_AIO* aio = handle_.get_handle();
	if (acl_aio_connect_addr(aio, addr, conn_timeout,
		  connect_callback, this) == -1) {
		logger_error("connect %s error %s", addr, last_serror());
		return false;
	}
	rw_timeout_ = rw_timeout;
	return true;
}

bool mqtt_aclient::open(aio_socket_stream* conn) {
	conn_ = conn;