Tha_14/tomato-testing
1
0
Fork 0
forked from Green-Sky/tomato
Code Pull Requests Actions Packages Releases Activity

dirty frag on message updates (if still open)

Browse Source
This commit is contained in:
Green Sky 2024-03-03 12:50:39 +01:00
parent 7b8e93eec3
commit bc22451524
No known key found for this signature in database
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/fragment_store/message_fragment_store.cpp
View File

@ -231,16 +231,33 @@ void MessageFragmentStore::handleMessage(const Message3Handle& m) {
return; return;
} }
m.emplace<Message::Components::FID>(fragment_id); m.emplace_or_replace<Message::Components::FID>(fragment_id);
// in this case we know the fragment needs an update // in this case we know the fragment needs an update
_fuid_save_queue.push({Message::getTimeMS(), fragment_id, m.registry()}); _fuid_save_queue.push({Message::getTimeMS(), fragment_id, m.registry()});
return; // done return; // done
} }
//m.get<Message::Components::FID>(); const auto msg_fh = _fs.fragmentHandle(m.get<Message::Components::FID>().fid);
if (!static_cast<bool>(msg_fh)) {
std::cerr << "MFS error: fid in message is invalid\n";
return; // TODO: properly handle this case
}
// TODO: save updates, and not only new messages (read state etc) if (!m.registry()->ctx().contains<Message::Components::OpenFragments>()) {
m.registry()->ctx().emplace<Message::Components::OpenFragments>();
}
auto& fid_open = m.registry()->ctx().get<Message::Components::OpenFragments>().fid_open;
if (fid_open.contains(msg_fh)) {
// TODO: dedup events
// TODO: cooldown per fragsave
_fuid_save_queue.push({Message::getTimeMS(), msg_fh, m.registry()});
return;
}
// TODO: save updates to old fragments, but writing them to a new fragment that would overwrite on merge
// new fragment?, since we dont write to others fragments? // new fragment?, since we dont write to others fragments?