mirrors/opendht
1
0 Fork 0
mirror of https://github.com/savoirfairelinux/opendht.git synced 2026-11-08 04:21:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

dht: preserve value creation time

Browse Source
This commit is contained in:
Adrien Béraud committed 2015-12-10 13:18:55 -05:00
1 parent 04aa3d3dba
commit 328a61df00
2 files changed
+3 -3
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

include/opendht/dht.h
+1 -1
View File
@@ -882,7 +882,7 @@ private:
}
void storageAddListener(const InfoHash& id, const InfoHash& node, const sockaddr *from, socklen_t fromlen, uint16_t tid);
ValueStorage* storageStore(const InfoHash& id, const std::shared_ptr<Value>& value, time_point created=time_point::max());
ValueStorage* storageStore(const InfoHash& id, const std::shared_ptr<Value>& value, time_point created);
void expireStorage();
void storageChanged(Storage& st, ValueStorage&);
src/dht.cpp
+2 -2
View File
@@ -984,7 +984,7 @@ Dht::searchStep(Search& sr)
if (in) {
DHT_WARN("[search %s IPv%c] [value %lu] storing locally",
sr.id.toString().c_str(), sr.af == AF_INET ? '4' : '6', vid);
storageStore(sr.id, a.value);
storageStore(sr.id, a.value, a.created);
}
for (auto& n : sr.nodes) {
if (not n.isSynced(now) or (n.candidate and t >= TARGET_NODES))
@@ -2807,7 +2807,7 @@ Dht::importValues(const std::vector<ValuesExport>& import)
DHT_DEBUG("Discarding expired value at %s", h.first.toString().c_str());
continue;
}
auto st = storageStore(h.first, std::make_shared<Value>(std::move(tmp_val)));
auto st = storageStore(h.first, std::make_shared<Value>(std::move(tmp_val)), val_time);
st->time = val_time;
}
} catch (const std::exception&) {