Path.hpp 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2018 ZeroTier, Inc. https://www.zerotier.com/
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. *
  18. * --
  19. *
  20. * You can be released from the requirements of the license by purchasing
  21. * a commercial license. Buying such a license is mandatory as soon as you
  22. * develop commercial closed-source software that incorporates or links
  23. * directly against ZeroTier software without disclosing the source code
  24. * of your own application.
  25. */
  26. #ifndef ZT_PATH_HPP
  27. #define ZT_PATH_HPP
  28. #include <stdint.h>
  29. #include <string.h>
  30. #include <stdlib.h>
  31. #include <stdexcept>
  32. #include <algorithm>
  33. #include "Constants.hpp"
  34. #include "InetAddress.hpp"
  35. #include "SharedPtr.hpp"
  36. #include "AtomicCounter.hpp"
  37. #include "Utils.hpp"
  38. #include "RingBuffer.hpp"
  39. #include "Packet.hpp"
  40. #include "../osdep/Phy.hpp"
  41. /**
  42. * Maximum return value of preferenceRank()
  43. */
  44. #define ZT_PATH_MAX_PREFERENCE_RANK ((ZT_INETADDRESS_MAX_SCOPE << 1) | 1)
  45. namespace ZeroTier {
  46. class RuntimeEnvironment;
  47. /**
  48. * A path across the physical network
  49. */
  50. class Path
  51. {
  52. friend class SharedPtr<Path>;
  53. Phy<Path *> *_phy;
  54. public:
  55. /**
  56. * Efficient unique key for paths in a Hashtable
  57. */
  58. class HashKey
  59. {
  60. public:
  61. HashKey() {}
  62. HashKey(const int64_t l,const InetAddress &r)
  63. {
  64. if (r.ss_family == AF_INET) {
  65. _k[0] = (uint64_t)reinterpret_cast<const struct sockaddr_in *>(&r)->sin_addr.s_addr;
  66. _k[1] = (uint64_t)reinterpret_cast<const struct sockaddr_in *>(&r)->sin_port;
  67. _k[2] = (uint64_t)l;
  68. } else if (r.ss_family == AF_INET6) {
  69. ZT_FAST_MEMCPY(_k,reinterpret_cast<const struct sockaddr_in6 *>(&r)->sin6_addr.s6_addr,16);
  70. _k[2] = ((uint64_t)reinterpret_cast<const struct sockaddr_in6 *>(&r)->sin6_port << 32) ^ (uint64_t)l;
  71. } else {
  72. ZT_FAST_MEMCPY(_k,&r,std::min(sizeof(_k),sizeof(InetAddress)));
  73. _k[2] += (uint64_t)l;
  74. }
  75. }
  76. inline unsigned long hashCode() const { return (unsigned long)(_k[0] + _k[1] + _k[2]); }
  77. inline bool operator==(const HashKey &k) const { return ( (_k[0] == k._k[0]) && (_k[1] == k._k[1]) && (_k[2] == k._k[2]) ); }
  78. inline bool operator!=(const HashKey &k) const { return (!(*this == k)); }
  79. private:
  80. uint64_t _k[3];
  81. };
  82. Path() :
  83. _lastOut(0),
  84. _lastIn(0),
  85. _lastTrustEstablishedPacketReceived(0),
  86. _lastPathQualityComputeTime(0),
  87. _localSocket(-1),
  88. _latency(0xffff),
  89. _addr(),
  90. _ipScope(InetAddress::IP_SCOPE_NONE),
  91. _lastAck(0),
  92. _lastThroughputEstimation(0),
  93. _lastQoSMeasurement(0),
  94. _lastQoSRecordPurge(0),
  95. _unackedBytes(0),
  96. _expectingAckAsOf(0),
  97. _packetsReceivedSinceLastAck(0),
  98. _packetsReceivedSinceLastQoS(0),
  99. _maxLifetimeThroughput(0),
  100. _lastComputedMeanThroughput(0),
  101. _bytesAckedSinceLastThroughputEstimation(0),
  102. _lastComputedMeanLatency(0.0),
  103. _lastComputedPacketDelayVariance(0.0),
  104. _lastComputedPacketErrorRatio(0.0),
  105. _lastComputedPacketLossRatio(0),
  106. _lastComputedStability(0.0),
  107. _lastComputedRelativeQuality(0),
  108. _lastComputedThroughputDistCoeff(0.0),
  109. _lastAllocation(0)
  110. {
  111. prepareBuffers();
  112. }
  113. Path(const int64_t localSocket,const InetAddress &addr) :
  114. _lastOut(0),
  115. _lastIn(0),
  116. _lastTrustEstablishedPacketReceived(0),
  117. _lastPathQualityComputeTime(0),
  118. _localSocket(localSocket),
  119. _latency(0xffff),
  120. _addr(addr),
  121. _ipScope(addr.ipScope()),
  122. _lastAck(0),
  123. _lastThroughputEstimation(0),
  124. _lastQoSMeasurement(0),
  125. _lastQoSRecordPurge(0),
  126. _unackedBytes(0),
  127. _expectingAckAsOf(0),
  128. _packetsReceivedSinceLastAck(0),
  129. _packetsReceivedSinceLastQoS(0),
  130. _maxLifetimeThroughput(0),
  131. _lastComputedMeanThroughput(0),
  132. _bytesAckedSinceLastThroughputEstimation(0),
  133. _lastComputedMeanLatency(0.0),
  134. _lastComputedPacketDelayVariance(0.0),
  135. _lastComputedPacketErrorRatio(0.0),
  136. _lastComputedPacketLossRatio(0),
  137. _lastComputedStability(0.0),
  138. _lastComputedRelativeQuality(0),
  139. _lastComputedThroughputDistCoeff(0.0),
  140. _lastAllocation(0)
  141. {
  142. prepareBuffers();
  143. _phy->getIfName((PhySocket *)((uintptr_t)_localSocket), _ifname, 16);
  144. }
  145. ~Path()
  146. {
  147. delete _throughputSamples;
  148. delete _latencySamples;
  149. delete _packetValiditySamples;
  150. delete _throughputDisturbanceSamples;
  151. _throughputSamples = NULL;
  152. _latencySamples = NULL;
  153. _packetValiditySamples = NULL;
  154. _throughputDisturbanceSamples = NULL;
  155. }
  156. /**
  157. * Called when a packet is received from this remote path, regardless of content
  158. *
  159. * @param t Time of receive
  160. */
  161. inline void received(const uint64_t t) { _lastIn = t; }
  162. /**
  163. * Set time last trusted packet was received (done in Peer::received())
  164. */
  165. inline void trustedPacketReceived(const uint64_t t) { _lastTrustEstablishedPacketReceived = t; }
  166. /**
  167. * Send a packet via this path (last out time is also updated)
  168. *
  169. * @param RR Runtime environment
  170. * @param tPtr Thread pointer to be handed through to any callbacks called as a result of this call
  171. * @param data Packet data
  172. * @param len Packet length
  173. * @param now Current time
  174. * @return True if transport reported success
  175. */
  176. bool send(const RuntimeEnvironment *RR,void *tPtr,const void *data,unsigned int len,int64_t now);
  177. /**
  178. * Manually update last sent time
  179. *
  180. * @param t Time of send
  181. */
  182. inline void sent(const int64_t t) { _lastOut = t; }
  183. /**
  184. * Update path latency with a new measurement
  185. *
  186. * @param l Measured latency
  187. */
  188. inline void updateLatency(const unsigned int l, int64_t now)
  189. {
  190. unsigned int pl = _latency;
  191. if (pl < 0xffff) {
  192. _latency = (pl + l) / 2;
  193. }
  194. else {
  195. _latency = l;
  196. }
  197. _latencySamples->push(l);
  198. }
  199. /**
  200. * @return Local socket as specified by external code
  201. */
  202. inline int64_t localSocket() const { return _localSocket; }
  203. /**
  204. * @return Physical address
  205. */
  206. inline const InetAddress &address() const { return _addr; }
  207. /**
  208. * @return IP scope -- faster shortcut for address().ipScope()
  209. */
  210. inline InetAddress::IpScope ipScope() const { return _ipScope; }
  211. /**
  212. * @return True if path has received a trust established packet (e.g. common network membership) in the past ZT_TRUST_EXPIRATION ms
  213. */
  214. inline bool trustEstablished(const int64_t now) const { return ((now - _lastTrustEstablishedPacketReceived) < ZT_TRUST_EXPIRATION); }
  215. /**
  216. * @return Preference rank, higher == better
  217. */
  218. inline unsigned int preferenceRank() const
  219. {
  220. // This causes us to rank paths in order of IP scope rank (see InetAdddress.hpp) but
  221. // within each IP scope class to prefer IPv6 over IPv4.
  222. return ( ((unsigned int)_ipScope << 1) | (unsigned int)(_addr.ss_family == AF_INET6) );
  223. }
  224. /**
  225. * Check whether this address is valid for a ZeroTier path
  226. *
  227. * This checks the address type and scope against address types and scopes
  228. * that we currently support for ZeroTier communication.
  229. *
  230. * @param a Address to check
  231. * @return True if address is good for ZeroTier path use
  232. */
  233. static inline bool isAddressValidForPath(const InetAddress &a)
  234. {
  235. if ((a.ss_family == AF_INET)||(a.ss_family == AF_INET6)) {
  236. switch(a.ipScope()) {
  237. /* Note: we don't do link-local at the moment. Unfortunately these
  238. * cause several issues. The first is that they usually require a
  239. * device qualifier, which we don't handle yet and can't portably
  240. * push in PUSH_DIRECT_PATHS. The second is that some OSes assign
  241. * these very ephemerally or otherwise strangely. So we'll use
  242. * private, pseudo-private, shared (e.g. carrier grade NAT), or
  243. * global IP addresses. */
  244. case InetAddress::IP_SCOPE_PRIVATE:
  245. case InetAddress::IP_SCOPE_PSEUDOPRIVATE:
  246. case InetAddress::IP_SCOPE_SHARED:
  247. case InetAddress::IP_SCOPE_GLOBAL:
  248. if (a.ss_family == AF_INET6) {
  249. // TEMPORARY HACK: for now, we are going to blacklist he.net IPv6
  250. // tunnels due to very spotty performance and low MTU issues over
  251. // these IPv6 tunnel links.
  252. const uint8_t *ipd = reinterpret_cast<const uint8_t *>(reinterpret_cast<const struct sockaddr_in6 *>(&a)->sin6_addr.s6_addr);
  253. if ((ipd[0] == 0x20)&&(ipd[1] == 0x01)&&(ipd[2] == 0x04)&&(ipd[3] == 0x70))
  254. return false;
  255. }
  256. return true;
  257. default:
  258. return false;
  259. }
  260. }
  261. return false;
  262. }
  263. /**
  264. * @return Latency or 0xffff if unknown
  265. */
  266. inline unsigned int latency() const { return _latency; }
  267. /**
  268. * @return Path quality -- lower is better
  269. */
  270. inline long quality(const int64_t now) const
  271. {
  272. const int l = (long)_latency;
  273. const int age = (long)std::min((now - _lastIn),(int64_t)(ZT_PATH_HEARTBEAT_PERIOD * 10)); // set an upper sanity limit to avoid overflow
  274. return (((age < (ZT_PATH_HEARTBEAT_PERIOD + 5000)) ? l : (l + 0xffff + age)) * (long)((ZT_INETADDRESS_MAX_SCOPE - _ipScope) + 1));
  275. }
  276. /**
  277. * Record statistics on outgoing packets. Used later to estimate QoS metrics.
  278. *
  279. * @param now Current time
  280. * @param packetId ID of packet
  281. * @param payloadLength Length of payload
  282. * @param verb Packet verb
  283. */
  284. inline void recordOutgoingPacket(int64_t now, int64_t packetId, uint16_t payloadLength, Packet::Verb verb)
  285. {
  286. Mutex::Lock _l(_statistics_m);
  287. if (verb != Packet::VERB_ACK && verb != Packet::VERB_QOS_MEASUREMENT) {
  288. if ((packetId & (ZT_PATH_QOS_ACK_PROTOCOL_DIVISOR - 1)) == 0) {
  289. _unackedBytes += payloadLength;
  290. // Take note that we're expecting a VERB_ACK on this path as of a specific time
  291. _expectingAckAsOf = ackAge(now) > ZT_PATH_ACK_INTERVAL ? _expectingAckAsOf : now;
  292. if (_outQoSRecords.size() < ZT_PATH_MAX_OUTSTANDING_QOS_RECORDS) {
  293. _outQoSRecords[packetId] = now;
  294. }
  295. }
  296. }
  297. }
  298. /**
  299. * Record statistics on incoming packets. Used later to estimate QoS metrics.
  300. *
  301. * @param now Current time
  302. * @param packetId ID of packet
  303. * @param payloadLength Length of payload
  304. * @param verb Packet verb
  305. */
  306. inline void recordIncomingPacket(int64_t now, int64_t packetId, uint16_t payloadLength, Packet::Verb verb)
  307. {
  308. Mutex::Lock _l(_statistics_m);
  309. if (verb != Packet::VERB_ACK && verb != Packet::VERB_QOS_MEASUREMENT) {
  310. if ((packetId & (ZT_PATH_QOS_ACK_PROTOCOL_DIVISOR - 1)) == 0) {
  311. _inACKRecords[packetId] = payloadLength;
  312. _packetsReceivedSinceLastAck++;
  313. _inQoSRecords[packetId] = now;
  314. _packetsReceivedSinceLastQoS++;
  315. }
  316. _packetValiditySamples->push(true);
  317. }
  318. }
  319. /**
  320. * Record that we've received a VERB_ACK on this path, also compute throughput if required.
  321. *
  322. * @param now Current time
  323. * @param ackedBytes Number of bytes acknowledged by other peer
  324. */
  325. inline void receivedAck(int64_t now, int32_t ackedBytes)
  326. {
  327. _expectingAckAsOf = 0;
  328. _unackedBytes = (ackedBytes > _unackedBytes) ? 0 : _unackedBytes - ackedBytes;
  329. int64_t timeSinceThroughputEstimate = (now - _lastThroughputEstimation);
  330. if (timeSinceThroughputEstimate >= ZT_PATH_THROUGHPUT_MEASUREMENT_INTERVAL) {
  331. uint64_t throughput = (float)(_bytesAckedSinceLastThroughputEstimation * 8) / ((float)timeSinceThroughputEstimate / (float)1000);
  332. _throughputSamples->push(throughput);
  333. _maxLifetimeThroughput = throughput > _maxLifetimeThroughput ? throughput : _maxLifetimeThroughput;
  334. _lastThroughputEstimation = now;
  335. _bytesAckedSinceLastThroughputEstimation = 0;
  336. } else {
  337. _bytesAckedSinceLastThroughputEstimation += ackedBytes;
  338. }
  339. }
  340. /**
  341. * @return Number of bytes this peer is responsible for ACKing since last ACK
  342. */
  343. inline int32_t bytesToAck()
  344. {
  345. Mutex::Lock _l(_statistics_m);
  346. int32_t bytesToAck = 0;
  347. std::map<uint64_t,uint16_t>::iterator it = _inACKRecords.begin();
  348. while (it != _inACKRecords.end()) {
  349. bytesToAck += it->second;
  350. it++;
  351. }
  352. return bytesToAck;
  353. }
  354. /**
  355. * @return Number of bytes thus far sent that have not been acknowledged by the remote peer
  356. */
  357. inline int64_t unackedSentBytes()
  358. {
  359. return _unackedBytes;
  360. }
  361. /**
  362. * Account for the fact that an ACK was just sent. Reset counters, timers, and clear statistics buffers
  363. *
  364. * @param Current time
  365. */
  366. inline void sentAck(int64_t now)
  367. {
  368. Mutex::Lock _l(_statistics_m);
  369. _inACKRecords.clear();
  370. _packetsReceivedSinceLastAck = 0;
  371. _lastAck = now;
  372. }
  373. /**
  374. * Receive QoS data, match with recorded egress times from this peer, compute latency
  375. * estimates.
  376. *
  377. * @param now Current time
  378. * @param count Number of records
  379. * @param rx_id table of packet IDs
  380. * @param rx_ts table of holding times
  381. */
  382. inline void receivedQoS(int64_t now, int count, uint64_t *rx_id, uint16_t *rx_ts)
  383. {
  384. Mutex::Lock _l(_statistics_m);
  385. // Look up egress times and compute latency values for each record
  386. std::map<uint64_t,uint64_t>::iterator it;
  387. for (int j=0; j<count; j++) {
  388. it = _outQoSRecords.find(rx_id[j]);
  389. if (it != _outQoSRecords.end()) {
  390. uint16_t rtt = (uint16_t)(now - it->second);
  391. uint16_t rtt_compensated = rtt - rx_ts[j];
  392. float latency = rtt_compensated / 2.0;
  393. updateLatency(latency, now);
  394. _outQoSRecords.erase(it);
  395. }
  396. }
  397. }
  398. /**
  399. * Generate the contents of a VERB_QOS_MEASUREMENT packet.
  400. *
  401. * @param now Current time
  402. * @param qosBuffer destination buffer
  403. * @return Size of payload
  404. */
  405. inline int32_t generateQoSPacket(int64_t now, char *qosBuffer)
  406. {
  407. Mutex::Lock _l(_statistics_m);
  408. int32_t len = 0;
  409. std::map<uint64_t,uint64_t>::iterator it = _inQoSRecords.begin();
  410. int i=0;
  411. while (i<_packetsReceivedSinceLastQoS && it != _inQoSRecords.end()) {
  412. uint64_t id = it->first;
  413. memcpy(qosBuffer, &id, sizeof(uint64_t));
  414. qosBuffer+=sizeof(uint64_t);
  415. uint16_t holdingTime = (now - it->second);
  416. memcpy(qosBuffer, &holdingTime, sizeof(uint16_t));
  417. qosBuffer+=sizeof(uint16_t);
  418. len+=sizeof(uint64_t)+sizeof(uint16_t);
  419. _inQoSRecords.erase(it++);
  420. i++;
  421. }
  422. return len;
  423. }
  424. /**
  425. * Account for the fact that a VERB_QOS_MEASUREMENT was just sent. Reset timers.
  426. *
  427. * @param Current time
  428. */
  429. inline void sentQoS(int64_t now) {
  430. _packetsReceivedSinceLastQoS = 0;
  431. _lastQoSMeasurement = now;
  432. }
  433. /**
  434. * @param now Current time
  435. * @return Whether an ACK (VERB_ACK) packet needs to be emitted at this time
  436. */
  437. inline bool needsToSendAck(int64_t now) {
  438. return ((now - _lastAck) >= ZT_PATH_ACK_INTERVAL ||
  439. (_packetsReceivedSinceLastAck == ZT_PATH_QOS_TABLE_SIZE)) && _packetsReceivedSinceLastAck;
  440. }
  441. /**
  442. * @param now Current time
  443. * @return Whether a QoS (VERB_QOS_MEASUREMENT) packet needs to be emitted at this time
  444. */
  445. inline bool needsToSendQoS(int64_t now) {
  446. return ((_packetsReceivedSinceLastQoS >= ZT_PATH_QOS_TABLE_SIZE) ||
  447. ((now - _lastQoSMeasurement) > ZT_PATH_QOS_INTERVAL)) && _packetsReceivedSinceLastQoS;
  448. }
  449. /**
  450. * How much time has elapsed since we've been expecting a VERB_ACK on this path. This value
  451. * is used to determine a more relevant path "age". This lets us penalize paths which are no
  452. * longer ACKing, but not those that simple aren't being used to carry traffic at the
  453. * current time.
  454. */
  455. inline int64_t ackAge(int64_t now) { return _expectingAckAsOf ? now - _expectingAckAsOf : 0; }
  456. /**
  457. * The maximum observed throughput (in bits/s) for this path
  458. */
  459. inline uint64_t maxLifetimeThroughput() { return _maxLifetimeThroughput; }
  460. /**
  461. * @return The mean throughput (in bits/s) of this link
  462. */
  463. inline uint64_t meanThroughput() { return _lastComputedMeanThroughput; }
  464. /**
  465. * Assign a new relative quality value for this path in the aggregate link
  466. *
  467. * @param rq Quality of this path in comparison to other paths available to this peer
  468. */
  469. inline void updateRelativeQuality(float rq) { _lastComputedRelativeQuality = rq; }
  470. /**
  471. * @return Quality of this path compared to others in the aggregate link
  472. */
  473. inline float relativeQuality() { return _lastComputedRelativeQuality; }
  474. /**
  475. * Assign a new allocation value for this path in the aggregate link
  476. *
  477. * @param allocation Percentage of traffic to be sent over this path to a peer
  478. */
  479. inline void updateComponentAllocationOfAggregateLink(unsigned char allocation) { _lastAllocation = allocation; }
  480. /**
  481. * @return Percentage of traffic allocated to this path in the aggregate link
  482. */
  483. inline unsigned char allocation() { return _lastAllocation; }
  484. /**
  485. * @return Stability estimates can become expensive to compute, we cache the most recent result.
  486. */
  487. inline float lastComputedStability() { return _lastComputedStability; }
  488. /**
  489. * @return A pointer to a cached copy of the human-readable name of the interface this Path's localSocket is bound to
  490. */
  491. inline char *getName() { return _ifname; }
  492. /**
  493. * @return Packet delay variance
  494. */
  495. inline float packetDelayVariance() { return _lastComputedPacketDelayVariance; }
  496. /**
  497. * @return Previously-computed mean latency
  498. */
  499. inline float meanLatency() { return _lastComputedMeanLatency; }
  500. /**
  501. * @return Packet loss rate (PLR)
  502. */
  503. inline float packetLossRatio() { return _lastComputedPacketLossRatio; }
  504. /**
  505. * @return Packet error ratio (PER)
  506. */
  507. inline float packetErrorRatio() { return _lastComputedPacketErrorRatio; }
  508. /**
  509. * Record an invalid incoming packet. This packet failed MAC/compression/cipher checks and will now
  510. * contribute to a Packet Error Ratio (PER).
  511. */
  512. inline void recordInvalidPacket() { _packetValiditySamples->push(false); }
  513. /**
  514. * @return A pointer to a cached copy of the address string for this Path (For debugging only)
  515. */
  516. inline char *getAddressString() { return _addrString; }
  517. /**
  518. * @return The current throughput disturbance coefficient
  519. */
  520. inline float throughputDisturbanceCoefficient() { return _lastComputedThroughputDistCoeff; }
  521. /**
  522. * Compute and cache stability and performance metrics. The resultant stability coefficient is a measure of how "well behaved"
  523. * this path is. This figure is substantially different from (but required for the estimation of the path's overall "quality".
  524. *
  525. * @param now Current time
  526. */
  527. inline void processBackgroundPathMeasurements(int64_t now) {
  528. if (now - _lastPathQualityComputeTime > ZT_PATH_QUALITY_COMPUTE_INTERVAL) {
  529. Mutex::Lock _l(_statistics_m);
  530. _lastPathQualityComputeTime = now;
  531. address().toString(_addrString);
  532. _lastComputedMeanLatency = _latencySamples->mean();
  533. _lastComputedPacketDelayVariance = _latencySamples->stddev(); // Similar to "jitter" (SEE: RFC 3393, RFC 4689)
  534. _lastComputedMeanThroughput = (uint64_t)_throughputSamples->mean();
  535. // If no packet validity samples, assume PER==0
  536. _lastComputedPacketErrorRatio = 1 - (_packetValiditySamples->count() ? _packetValiditySamples->mean() : 1);
  537. // Compute path stability
  538. // Normalize measurements with wildly different ranges into a reasonable range
  539. float normalized_pdv = Utils::normalize(_lastComputedPacketDelayVariance, 0, ZT_PATH_MAX_PDV, 0, 10);
  540. float normalized_la = Utils::normalize(_lastComputedMeanLatency, 0, ZT_PATH_MAX_MEAN_LATENCY, 0, 10);
  541. float throughput_cv = _throughputSamples->mean() > 0 ? _throughputSamples->stddev() / _throughputSamples->mean() : 1;
  542. // Form an exponential cutoff and apply contribution weights
  543. float pdv_contrib = exp((-1)*normalized_pdv) * ZT_PATH_CONTRIB_PDV;
  544. float latency_contrib = exp((-1)*normalized_la) * ZT_PATH_CONTRIB_LATENCY;
  545. // Throughput Disturbance Coefficient
  546. float throughput_disturbance_contrib = exp((-1)*throughput_cv) * ZT_PATH_CONTRIB_THROUGHPUT_DISTURBANCE;
  547. _throughputDisturbanceSamples->push(throughput_cv);
  548. _lastComputedThroughputDistCoeff = _throughputDisturbanceSamples->mean();
  549. // Obey user-defined ignored contributions
  550. pdv_contrib = ZT_PATH_CONTRIB_PDV > 0.0 ? pdv_contrib : 1;
  551. latency_contrib = ZT_PATH_CONTRIB_LATENCY > 0.0 ? latency_contrib : 1;
  552. throughput_disturbance_contrib = ZT_PATH_CONTRIB_THROUGHPUT_DISTURBANCE > 0.0 ? throughput_disturbance_contrib : 1;
  553. // Stability
  554. _lastComputedStability = pdv_contrib + latency_contrib + throughput_disturbance_contrib;
  555. _lastComputedStability *= 1 - _lastComputedPacketErrorRatio;
  556. // Prevent QoS records from sticking around for too long
  557. std::map<uint64_t,uint64_t>::iterator it = _outQoSRecords.begin();
  558. while (it != _outQoSRecords.end()) {
  559. // Time since egress of tracked packet
  560. if ((now - it->second) >= ZT_PATH_QOS_TIMEOUT) {
  561. _outQoSRecords.erase(it++);
  562. } else { it++; }
  563. }
  564. }
  565. }
  566. /**
  567. * @return True if this path is alive (receiving heartbeats)
  568. */
  569. inline bool alive(const int64_t now) const { return ((now - _lastIn) < (ZT_PATH_HEARTBEAT_PERIOD + 5000)); }
  570. /**
  571. * @return True if this path needs a heartbeat
  572. */
  573. inline bool needsHeartbeat(const int64_t now) const { return ((now - _lastOut) >= ZT_PATH_HEARTBEAT_PERIOD); }
  574. /**
  575. * @return Last time we sent something
  576. */
  577. inline int64_t lastOut() const { return _lastOut; }
  578. /**
  579. * @return Last time we received anything
  580. */
  581. inline int64_t lastIn() const { return _lastIn; }
  582. /**
  583. * @return Time last trust-established packet was received
  584. */
  585. inline int64_t lastTrustEstablishedPacketReceived() const { return _lastTrustEstablishedPacketReceived; }
  586. /**
  587. * Initialize statistical buffers
  588. */
  589. inline void prepareBuffers() {
  590. _throughputSamples = new RingBuffer<uint64_t>(ZT_PATH_QUALITY_METRIC_WIN_SZ);
  591. _latencySamples = new RingBuffer<uint32_t>(ZT_PATH_QUALITY_METRIC_WIN_SZ);
  592. _packetValiditySamples = new RingBuffer<bool>(ZT_PATH_QUALITY_METRIC_WIN_SZ);
  593. _throughputDisturbanceSamples = new RingBuffer<float>(ZT_PATH_QUALITY_METRIC_WIN_SZ);
  594. memset(_ifname, 0, 16);
  595. memset(_addrString, 0, sizeof(_addrString));
  596. }
  597. private:
  598. Mutex _statistics_m;
  599. volatile int64_t _lastOut;
  600. volatile int64_t _lastIn;
  601. volatile int64_t _lastTrustEstablishedPacketReceived;
  602. volatile int64_t _lastPathQualityComputeTime;
  603. int64_t _localSocket;
  604. volatile unsigned int _latency;
  605. InetAddress _addr;
  606. InetAddress::IpScope _ipScope; // memoize this since it's a computed value checked often
  607. AtomicCounter __refCount;
  608. std::map<uint64_t, uint64_t> _outQoSRecords; // id:egress_time
  609. std::map<uint64_t, uint64_t> _inQoSRecords; // id:now
  610. std::map<uint64_t, uint16_t> _inACKRecords; // id:len
  611. int64_t _lastAck;
  612. int64_t _lastThroughputEstimation;
  613. int64_t _lastQoSMeasurement;
  614. int64_t _lastQoSRecordPurge;
  615. int64_t _unackedBytes;
  616. int64_t _expectingAckAsOf;
  617. int16_t _packetsReceivedSinceLastAck;
  618. int16_t _packetsReceivedSinceLastQoS;
  619. uint64_t _maxLifetimeThroughput;
  620. uint64_t _lastComputedMeanThroughput;
  621. uint64_t _bytesAckedSinceLastThroughputEstimation;
  622. float _lastComputedMeanLatency;
  623. float _lastComputedPacketDelayVariance;
  624. float _lastComputedPacketErrorRatio;
  625. float _lastComputedPacketLossRatio;
  626. // cached estimates
  627. float _lastComputedStability;
  628. float _lastComputedRelativeQuality;
  629. float _lastComputedThroughputDistCoeff;
  630. unsigned char _lastAllocation;
  631. // cached human-readable strings for tracing purposes
  632. char _ifname[16];
  633. char _addrString[256];
  634. RingBuffer<uint64_t> *_throughputSamples;
  635. RingBuffer<uint32_t> *_latencySamples;
  636. RingBuffer<bool> *_packetValiditySamples;
  637. RingBuffer<float> *_throughputDisturbanceSamples;
  638. };
  639. } // namespace ZeroTier
  640. #endif