diff options
author | Grant Limberg <grant.limberg@zerotier.com> | 2019-03-04 16:27:52 -0800 |
---|---|---|
committer | Grant Limberg <grant.limberg@zerotier.com> | 2019-03-04 16:31:36 -0800 |
commit | 801401a6e7022fa44c129f6626d944722d1ec6be (patch) | |
tree | 3771b94d80abd1307b965e537d7cfa0f80841ef9 | |
parent | de1fc43cc58ce6a02c6eeef7791328c44189aa7c (diff) | |
parent | 270debb3fc39c3f1f6a3f6fbc2c5fb6183182c8f (diff) | |
download | infinitytier-801401a6e7022fa44c129f6626d944722d1ec6be.tar.gz infinitytier-801401a6e7022fa44c129f6626d944722d1ec6be.zip |
Merge branch 'dev' of http://git.int.zerotier.com/ZeroTier/ZeroTierOne into dev
-rw-r--r-- | controller/PostgreSQL.cpp | 1 | ||||
-rw-r--r-- | node/Path.hpp | 6 | ||||
-rw-r--r-- | node/Peer.cpp | 2 | ||||
-rw-r--r-- | node/Peer.hpp | 2 |
4 files changed, 9 insertions, 2 deletions
diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 9eb64800..29d61a39 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -33,6 +33,7 @@ #include <libpq-fe.h> #include <sstream> #include <amqp.h> +#include <amqp_tcp_socket.h> using json = nlohmann::json; namespace { diff --git a/node/Path.hpp b/node/Path.hpp index a9e7d84d..6acba172 100644 --- a/node/Path.hpp +++ b/node/Path.hpp @@ -161,6 +161,7 @@ public: ~Path() { +#if ZT_PROTO_VERSION >= 10 delete _throughputSamples; delete _latencySamples; delete _packetValiditySamples; @@ -169,6 +170,7 @@ public: _latencySamples = NULL; _packetValiditySamples = NULL; _throughputDisturbanceSamples = NULL; +#endif } /** @@ -651,12 +653,14 @@ public: * Initialize statistical buffers */ inline void prepareBuffers() { +#if ZT_PROTO_VERSION >= 10 _throughputSamples = new RingBuffer<uint64_t>(ZT_PATH_QUALITY_METRIC_WIN_SZ); _latencySamples = new RingBuffer<uint32_t>(ZT_PATH_QUALITY_METRIC_WIN_SZ); _packetValiditySamples = new RingBuffer<bool>(ZT_PATH_QUALITY_METRIC_WIN_SZ); _throughputDisturbanceSamples = new RingBuffer<float>(ZT_PATH_QUALITY_METRIC_WIN_SZ); memset(_ifname, 0, 16); memset(_addrString, 0, sizeof(_addrString)); +#endif } private: @@ -702,8 +706,6 @@ private: float _lastComputedThroughputDistCoeff; unsigned char _lastAllocation; - - // cached human-readable strings for tracing purposes char _ifname[16]; char _addrString[256]; diff --git a/node/Peer.cpp b/node/Peer.cpp index aecbd3a0..9f8c5bbc 100644 --- a/node/Peer.cpp +++ b/node/Peer.cpp @@ -78,7 +78,9 @@ Peer::Peer(const RuntimeEnvironment *renv,const Identity &myIdentity,const Ident Utils::getSecureRandom(&_freeRandomByte, 1); if (!myIdentity.agree(peerIdentity,_key,ZT_PEER_SECRET_KEY_LENGTH)) throw ZT_EXCEPTION_INVALID_ARGUMENT; +#if ZT_PROTO_VERSION >= 10 _pathChoiceHist = new RingBuffer<int>(ZT_MULTIPATH_PROPORTION_WIN_SZ); +#endif } void Peer::received( diff --git a/node/Peer.hpp b/node/Peer.hpp index ae8f1e78..99d3fac2 100644 --- a/node/Peer.hpp +++ b/node/Peer.hpp @@ -62,7 +62,9 @@ private: public: ~Peer() { Utils::burn(_key,sizeof(_key)); +#if ZT_PROTO_VERSION >= 10 delete _pathChoiceHist; +#endif _pathChoiceHist = NULL; } |