Merge branch 'dev' into edge

This commit is contained in:
Adam Ierymenko 2019-03-14 13:49:49 -07:00
commit 9d7b7c72b2
4 changed files with 6 additions and 8 deletions

@ -1,5 +1,7 @@
#include "RabbitMQ.hpp"
#ifdef ZT_CONTROLLER_USE_LIBPQ
#include <amqp.h>
#include <amqp_tcp_socket.h>
#include <stdexcept>
@ -92,3 +94,5 @@ std::string RabbitMQ::consume()
}
}
#endif // ZT_CONTROLLER_USE_LIBPQ

@ -161,7 +161,6 @@ public:
~Path()
{
#if ZT_PROTO_VERSION >= 10
delete _throughputSamples;
delete _latencySamples;
delete _packetValiditySamples;
@ -170,7 +169,6 @@ public:
_latencySamples = NULL;
_packetValiditySamples = NULL;
_throughputDisturbanceSamples = NULL;
#endif
}
/**
@ -653,14 +651,12 @@ 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:
@ -706,6 +702,8 @@ private:
float _lastComputedThroughputDistCoeff;
unsigned char _lastAllocation;
// cached human-readable strings for tracing purposes
char _ifname[16];
char _addrString[256];

@ -78,9 +78,7 @@ 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(

@ -62,9 +62,7 @@ private:
public:
~Peer() {
Utils::burn(_key,sizeof(_key));
#if ZT_PROTO_VERSION >= 10
delete _pathChoiceHist;
#endif
_pathChoiceHist = NULL;
}