mawei/onepilot
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bump cereal (#29561)

Browse Source 
old-commit-hash: e726505918bfbaa4ee75714bd6ea391d7fff7fb8
This commit is contained in:
Adeeb Shihadeh
2023-08-23 13:42:37 -07:00
committed by GitHub
parent 97e9d55588
commit 6b2ffe9490
5 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
system/loggerd/loggerd.cc
View File

@@ -207,11 +207,11 @@ void loggerd_thread() {
std::unique_ptr<Poller> poller(Poller::create());
// subscribe to all socks
for (const auto& it : services) {
const bool encoder = strcmp(it.name+strlen(it.name)-strlen("EncodeData"), "EncodeData") == 0;
const bool livestream_encoder = strncmp(it.name, "livestream", strlen("livestream")) == 0;
for (const auto& [_, it] : services) {
const bool encoder = util::ends_with(it.name, "EncodeData");
const bool livestream_encoder = util::starts_with(it.name, "livestream");
if (!it.should_log && (!encoder || livestream_encoder)) continue;
LOGD("logging %s (on port %d)", it.name, it.port);
LOGD("logging %s (on port %d)", it.name.c_str(), it.port);
SubSocket * sock = SubSocket::create(ctx.get(), it.name);
assert(sock != NULL);
@@ -221,7 +221,7 @@ void loggerd_thread() {
.counter = 0,
.freq = it.decimation,
.encoder = encoder,
.user_flag = (strcmp(it.name, "userFlag") == 0),
.user_flag = it.name == "userFlag",
};
}