diff --git a/src/solanaceae/message_fragment_store/message_fragment_store.cpp b/src/solanaceae/message_fragment_store/message_fragment_store.cpp index fc69c59..9c72e38 100644 --- a/src/solanaceae/message_fragment_store/message_fragment_store.cpp +++ b/src/solanaceae/message_fragment_store/message_fragment_store.cpp @@ -94,7 +94,7 @@ void MessageFragmentStore::handleMessage(const Message3Handle& m) { } // TODO: use fid, seving full fuid for every message consumes alot of memory (and heap frag) - if (!m.all_of()) { + if (!m.all_of()) { std::cout << "MFS: new msg missing Object\n"; if (!m.registry()->ctx().contains()) { m.registry()->ctx().emplace(); @@ -232,7 +232,7 @@ void MessageFragmentStore::handleMessage(const Message3Handle& m) { return; } - m.emplace_or_replace(fragment_id); + m.emplace_or_replace(fragment_id); // in this case we know the fragment needs an update for (const auto& it : _frag_save_queue) { @@ -245,7 +245,7 @@ void MessageFragmentStore::handleMessage(const Message3Handle& m) { return; // done } - const auto msg_fh = _os.objectHandle(m.get().o); + const auto msg_fh = _os.objectHandle(m.get().o); if (!static_cast(msg_fh)) { std::cerr << "MFS error: fid in message is invalid\n"; return; // TODO: properly handle this case @@ -336,7 +336,7 @@ void MessageFragmentStore::loadFragment(Message3Registry& reg, ObjectHandle fh) } } - new_real_msg.emplace_or_replace(fh); + new_real_msg.emplace_or_replace(fh); // dup check (hacky, specific to protocols) Message3 dup_msg {entt::null}; @@ -401,7 +401,7 @@ bool MessageFragmentStore::syncFragToStorage(ObjectHandle fh, Message3Registry& for (auto it = msg_view.rbegin(), it_end = msg_view.rend(); it != it_end; it++) { const Message3 m = *it; - if (!reg.all_of(m)) { + if (!reg.all_of(m)) { continue; } @@ -411,7 +411,7 @@ bool MessageFragmentStore::syncFragToStorage(ObjectHandle fh, Message3Registry& continue; } - if (_frag_save_queue.front().id != reg.get(m).o) { + if (_frag_save_queue.front().id != reg.get(m).o) { continue; // not ours } diff --git a/src/solanaceae/message_fragment_store/message_fragment_store.hpp b/src/solanaceae/message_fragment_store/message_fragment_store.hpp index f31a4a1..12b7248 100644 --- a/src/solanaceae/message_fragment_store/message_fragment_store.hpp +++ b/src/solanaceae/message_fragment_store/message_fragment_store.hpp @@ -24,7 +24,7 @@ namespace Message::Components { // unused, consumes too much memory (highly compressable) //using FUID = FragComp::ID; - struct Obj { + struct MFSObj { // message fragment's object Object o {entt::null}; }; @@ -37,7 +37,7 @@ namespace Message::Components { // every tick we check all cursers for this tag and continue // and remove once no fragment could be loaded anymore // (internal) - struct TagCurserUnsatisfied {}; + struct MFSCurserUnsatisfiedTag {}; } // Message::Components