| | |
| | | { |
| | | class Impl |
| | | { |
| | | typedef std::unordered_map<Topic, Address> Records; |
| | | struct TimedRec { |
| | | Address addr_; |
| | | int64_t timestamp_; |
| | | }; |
| | | typedef std::unordered_map<Topic, TimedRec> Records; |
| | | Records records_; |
| | | |
| | | public: |
| | |
| | | { |
| | | auto pos = records_.find(topic); |
| | | if (pos != records_.end()) { |
| | | addr = pos->second; |
| | | return true; |
| | | } else { |
| | | return false; |
| | | if (NowSec() - pos->second.timestamp_ < NodeTimeoutSec() / 2) { |
| | | addr = pos->second.addr_; |
| | | return true; |
| | | } else { |
| | | LOG_TRACE() << "topic dest cache timeout."; |
| | | } |
| | | } |
| | | return false; |
| | | } |
| | | bool Store(const Topic &topic, const Address &addr) |
| | | { |
| | | records_[topic] = addr; |
| | | records_[topic] = {addr, NowSec()}; |
| | | return true; |
| | | } |
| | | }; |