logcatd: fix bug: subsequent reads after the first always return empty (#19994)
* refactor logcatd * cleanup * rename logger_list to loggers * apply review * little cleaner Co-authored-by: Adeeb Shihadeh <adeebshihadeh@gmail.com>albatross
parent
000bd226aa
commit
1b140bdbca
|
@ -1,68 +1,57 @@
|
|||
#include <unistd.h>
|
||||
#include <cstdio>
|
||||
#include <cstdlib>
|
||||
#include <cassert>
|
||||
#include <csignal>
|
||||
#include <cerrno>
|
||||
|
||||
#include <android/log.h>
|
||||
#include <log/logger.h>
|
||||
#include <log/logprint.h>
|
||||
|
||||
#include "common/timing.h"
|
||||
#include "common/util.h"
|
||||
#include "messaging.hpp"
|
||||
|
||||
#define LOG_ID_KERNEL (log_id_t)5
|
||||
|
||||
int main() {
|
||||
ExitHandler do_exit;
|
||||
|
||||
// setup android logging
|
||||
struct logger_list *logger_list = android_logger_list_alloc(ANDROID_LOG_RDONLY, 0, 0);
|
||||
assert(logger_list);
|
||||
struct logger *main_logger = android_logger_open(logger_list, LOG_ID_MAIN);
|
||||
assert(main_logger);
|
||||
struct logger *radio_logger = android_logger_open(logger_list, LOG_ID_RADIO);
|
||||
assert(radio_logger);
|
||||
struct logger *system_logger = android_logger_open(logger_list, LOG_ID_SYSTEM);
|
||||
assert(system_logger);
|
||||
struct logger *crash_logger = android_logger_open(logger_list, LOG_ID_CRASH);
|
||||
assert(crash_logger);
|
||||
struct logger *kernel_logger = android_logger_open(logger_list, (log_id_t)5); // LOG_ID_KERNEL
|
||||
assert(kernel_logger);
|
||||
log_time last_log_time = {};
|
||||
|
||||
PubMaster pm({"androidLog"});
|
||||
|
||||
while (!do_exit) {
|
||||
log_msg log_msg;
|
||||
int err = android_logger_list_read(logger_list, &log_msg);
|
||||
// setup android logging
|
||||
logger_list *loggers = last_log_time.tv_sec == 0 ?
|
||||
android_logger_list_alloc(ANDROID_LOG_RDONLY | ANDROID_LOG_NONBLOCK, 0, 0) :
|
||||
android_logger_list_alloc_time(ANDROID_LOG_RDONLY | ANDROID_LOG_NONBLOCK, last_log_time, 0);
|
||||
assert(loggers);
|
||||
|
||||
if (err == -EAGAIN) {
|
||||
util::sleep_for(500);
|
||||
continue;
|
||||
} else if (err <= 0) {
|
||||
break;
|
||||
const log_id_t log_ids[] = {LOG_ID_MAIN, LOG_ID_RADIO, LOG_ID_SYSTEM, LOG_ID_CRASH, LOG_ID_KERNEL};
|
||||
for (const auto &id : log_ids) {
|
||||
struct logger *log = android_logger_open(loggers, id);
|
||||
assert(log != nullptr);
|
||||
}
|
||||
|
||||
AndroidLogEntry entry;
|
||||
err = android_log_processLogBuffer(&log_msg.entry_v1, &entry);
|
||||
if (err < 0) {
|
||||
continue;
|
||||
while (!do_exit) {
|
||||
log_msg log_msg;
|
||||
int err = android_logger_list_read(loggers, &log_msg);
|
||||
if (err <= 0) break;
|
||||
|
||||
AndroidLogEntry entry;
|
||||
err = android_log_processLogBuffer(&log_msg.entry_v1, &entry);
|
||||
if (err == 0) {
|
||||
last_log_time.tv_sec = entry.tv_sec;
|
||||
last_log_time.tv_nsec = entry.tv_nsec;
|
||||
|
||||
MessageBuilder msg;
|
||||
auto androidEntry = msg.initEvent().initAndroidLog();
|
||||
androidEntry.setId(log_msg.id());
|
||||
androidEntry.setTs(entry.tv_sec * 1000000000ULL + entry.tv_nsec);
|
||||
androidEntry.setPriority(entry.priority);
|
||||
androidEntry.setPid(entry.pid);
|
||||
androidEntry.setTid(entry.tid);
|
||||
androidEntry.setTag(entry.tag);
|
||||
androidEntry.setMessage(entry.message);
|
||||
|
||||
pm.send("androidLog", msg);
|
||||
}
|
||||
}
|
||||
|
||||
MessageBuilder msg;
|
||||
auto androidEntry = msg.initEvent().initAndroidLog();
|
||||
androidEntry.setId(log_msg.id());
|
||||
androidEntry.setTs(entry.tv_sec * 1000000000ULL + entry.tv_nsec);
|
||||
androidEntry.setPriority(entry.priority);
|
||||
androidEntry.setPid(entry.pid);
|
||||
androidEntry.setTid(entry.tid);
|
||||
androidEntry.setTag(entry.tag);
|
||||
androidEntry.setMessage(entry.message);
|
||||
|
||||
pm.send("androidLog", msg);
|
||||
android_logger_list_free(loggers);
|
||||
util::sleep_for(500);
|
||||
}
|
||||
|
||||
android_logger_list_free(logger_list);
|
||||
return 0;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue