Method read_message

lib_acl_cpp/src/mqtt/mqtt_client.cpp:140–173

}

bool mqtt_client::read_message(const mqtt_header& header, mqtt_message& body) {
	unsigned len = header.get_remaining_length();
	if (len == 0) {
		return true;
	}

	char buf[8192];
	while (len > 0) {
		size_t size = sizeof(buf) > len ? len : sizeof(buf);
		int n = conn_->read(buf, size);
		if (n == -1) {
			logger_debug(DEBUG_MQTT, 1, "read body error: %s",
				last_serror());
			return false;
		}

		len -= n;

		n = body.update(buf, (int) n);
		if (n == -1) {
			logger_debug(DEBUG_MQTT, 1, "update body error");
			return false;
		} else if (n != 0) {
			logger_debug(DEBUG_MQTT, 1, "invalid body data");
			return false;
		}
	}

	if (!body.finished()) {
		logger_debug(DEBUG_MQTT, 1, "body not finished!");
		return false;
	}
	return true;
}

} // namespace acl