summaryrefslogtreecommitdiff
path: root/controller/EmbeddedNetworkController.hpp
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2017-03-01 16:33:34 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2017-03-01 16:33:34 -0800
commita577b8d3816069a448a946302048a377b55cd74a (patch)
tree62a625ac0ef302e5b3ff82fed53e830592f22461 /controller/EmbeddedNetworkController.hpp
parent136fddc7f1d965aa5f4e3699195b4333131747a3 (diff)
downloadinfinitytier-a577b8d3816069a448a946302048a377b55cd74a.tar.gz
infinitytier-a577b8d3816069a448a946302048a377b55cd74a.zip
Update how controller handles circuit tests -- save results to filesystem.
Diffstat (limited to 'controller/EmbeddedNetworkController.hpp')
-rw-r--r--controller/EmbeddedNetworkController.hpp15
1 files changed, 6 insertions, 9 deletions
diff --git a/controller/EmbeddedNetworkController.hpp b/controller/EmbeddedNetworkController.hpp
index 3e39eaf5..ab7cdd53 100644
--- a/controller/EmbeddedNetworkController.hpp
+++ b/controller/EmbeddedNetworkController.hpp
@@ -46,6 +46,9 @@
// Number of background threads to start -- not actually started until needed
#define ZT_EMBEDDEDNETWORKCONTROLLER_BACKGROUND_THREAD_COUNT 2
+// TTL for circuit tests
+#define ZT_EMBEDDEDNETWORKCONTROLLER_CIRCUIT_TEST_EXPIRATION 120000
+
namespace ZeroTier {
class Node;
@@ -56,9 +59,8 @@ public:
/**
* @param node Parent node
* @param dbPath Path to store data
- * @param feed FILE to send feed of all data and changes to (zero-delimited JSON objects) or NULL for none
*/
- EmbeddedNetworkController(Node *node,const char *dbPath,FILE *feed);
+ EmbeddedNetworkController(Node *node,const char *dbPath);
virtual ~EmbeddedNetworkController();
virtual void init(const Identity &signingId,Sender *sender);
@@ -199,13 +201,8 @@ private:
NetworkController::Sender *_sender;
Identity _signingId;
- struct _CircuitTestEntry
- {
- ZT_CircuitTest *test;
- std::string jsonResults;
- };
- std::map< uint64_t,_CircuitTestEntry > _circuitTests;
- Mutex _circuitTests_m;
+ std::list< ZT_CircuitTest > _tests;
+ Mutex _tests_m;
std::map< std::pair<uint64_t,uint64_t>,uint64_t > _lastRequestTime;
Mutex _lastRequestTime_m;