Method read_header

lib_acl_cpp/src/mqtt/mqtt_client.cpp:103–138

}

bool mqtt_client::read_header(mqtt_header& header) {
	char ch;
	if (!conn_->read(ch)) {
		//logger_error("read header type error: %s", last_serror());
		return false;
	}

	// update the first char for mqtt_type_t
	if (header.update(&ch, 1) != 0) {
		logger_debug(DEBUG_MQTT, 1, "invalid header type=%d", (int) ch);
		return false;
	}

	for (int i = 0; i < 4; i++) {
		if (!conn_->read(ch)) {
			logger_debug(DEBUG_MQTT, 1, "read char error: %s, i=%d",
				last_serror(), i);
			return false;
		}
		if (header.update(&ch, 1) != 0) {
			logger_debug(DEBUG_MQTT, 1, "header_update error, ch=%d",
				(int) ch);
			return false;
		}
		if (header.finished()) {
			break;
		}
	}

	if (!header.finished()) {
		logger_debug(DEBUG_MQTT, 1, "get mqtt header error");
		return false;
	}

	return true;
}

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