summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGrant Limberg <grant.limberg@zerotier.com>2019-03-04 16:27:52 -0800
committerGrant Limberg <grant.limberg@zerotier.com>2019-03-04 16:31:36 -0800
commit801401a6e7022fa44c129f6626d944722d1ec6be (patch)
tree3771b94d80abd1307b965e537d7cfa0f80841ef9
parentde1fc43cc58ce6a02c6eeef7791328c44189aa7c (diff)
parent270debb3fc39c3f1f6a3f6fbc2c5fb6183182c8f (diff)
downloadinfinitytier-801401a6e7022fa44c129f6626d944722d1ec6be.tar.gz
infinitytier-801401a6e7022fa44c129f6626d944722d1ec6be.zip
Merge branch 'dev' of http://git.int.zerotier.com/ZeroTier/ZeroTierOne into dev
-rw-r--r--controller/PostgreSQL.cpp1
-rw-r--r--node/Path.hpp6
-rw-r--r--node/Peer.cpp2
-rw-r--r--node/Peer.hpp2
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;
}