Green-Sky/solanaceae_zox
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

time moved to util

Browse Source
This commit is contained in:
Green Sky 2025-01-07 16:06:39 +01:00
parent 09f9c01e68
commit 5f2f92d9d1
No known key found for this signature in database
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/solanaceae/zox/ngc_hs.cpp
View File

@ -1,5 +1,7 @@
#include "./ngc_hs.hpp" #include "./ngc_hs.hpp"
#include <solanaceae/util/time.hpp>
#include <solanaceae/toxcore/tox_interface.hpp> #include <solanaceae/toxcore/tox_interface.hpp>
#include <solanaceae/contact/components.hpp> #include <solanaceae/contact/components.hpp>
#include <solanaceae/tox_contacts/tox_contact_model2.hpp> #include <solanaceae/tox_contacts/tox_contact_model2.hpp>
@ -269,7 +271,7 @@ bool ZoxNGCHistorySync::onEvent(const Events::ZoxNGC_ngch_request& e) {
// convert sync delta to ms // convert sync delta to ms
const int64_t sync_delta_offset_ms = int64_t(e.sync_delta) * 1000 * 60; const int64_t sync_delta_offset_ms = int64_t(e.sync_delta) * 1000 * 60;
const uint64_t ts_start = Message::getTimeMS() - sync_delta_offset_ms; const uint64_t ts_start = getTimeMS() - sync_delta_offset_ms;
auto view = reg.view<Message::Components::Timestamp>(); auto view = reg.view<Message::Components::Timestamp>();
for (auto it = view.rbegin(), it_end = view.rend(); it != it_end; it++) { for (auto it = view.rbegin(), it_end = view.rend(); it != it_end; it++) {
@ -349,7 +351,7 @@ bool ZoxNGCHistorySync::onEvent(const Events::ZoxNGC_ngch_syncmsg& e) {
auto* reg_ptr = _rmm.get(sync_by_c); auto* reg_ptr = _rmm.get(sync_by_c);
if (reg_ptr == nullptr) { if (reg_ptr == nullptr) {
std::cerr << "ZNGCHS error: group without reg\n"; std::cerr << "ZNGCHS error: group without msg reg\n";
return false; return false;
} }
@ -360,7 +362,7 @@ bool ZoxNGCHistorySync::onEvent(const Events::ZoxNGC_ngch_syncmsg& e) {
// convert to ms // convert to ms
uint64_t sync_ts = std::chrono::milliseconds(std::chrono::seconds{e.timestamp}).count(); // o.o uint64_t sync_ts = std::chrono::milliseconds(std::chrono::seconds{e.timestamp}).count(); // o.o
uint64_t now_ts = Message::getTimeMS(); uint64_t now_ts = getTimeMS();
const uint64_t max_future_ms = 1u*60u*1000u; // accept up to 1 minute into the future const uint64_t max_future_ms = 1u*60u*1000u; // accept up to 1 minute into the future
if (sync_ts - max_future_ms > now_ts) { if (sync_ts - max_future_ms > now_ts) {