summaryrefslogtreecommitdiff
path: root/attic/JSONDB.hpp
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2018-01-09 11:23:39 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2018-01-09 11:23:39 -0800
commit0c71d658fbecacde3c38655d663946a1f044fe58 (patch)
tree0ee47434fcfab778dad62b9a451e9fa8b226070a /attic/JSONDB.hpp
parent1aea096b631cbd7734834f43c3beefeff3939b4e (diff)
downloadinfinitytier-0c71d658fbecacde3c38655d663946a1f044fe58.tar.gz
infinitytier-0c71d658fbecacde3c38655d663946a1f044fe58.zip
cleanup
Diffstat (limited to 'attic/JSONDB.hpp')
-rw-r--r--attic/JSONDB.hpp192
1 files changed, 0 insertions, 192 deletions
diff --git a/attic/JSONDB.hpp b/attic/JSONDB.hpp
deleted file mode 100644
index db909cb0..00000000
--- a/attic/JSONDB.hpp
+++ /dev/null
@@ -1,192 +0,0 @@
-/*
- * ZeroTier One - Network Virtualization Everywhere
- * Copyright (C) 2011-2015 ZeroTier, Inc.
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#ifndef ZT_JSONDB_HPP
-#define ZT_JSONDB_HPP
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include <string>
-#include <map>
-#include <stdexcept>
-#include <vector>
-#include <algorithm>
-#include <unordered_map>
-#include <unordered_set>
-
-#include "../node/Constants.hpp"
-#include "../node/Utils.hpp"
-#include "../node/InetAddress.hpp"
-#include "../node/Mutex.hpp"
-#include "../ext/json/json.hpp"
-#include "../osdep/OSUtils.hpp"
-#include "../osdep/Thread.hpp"
-
-namespace ZeroTier {
-
-class EmbeddedNetworkController;
-
-/**
- * Hierarchical JSON store that persists into the filesystem or via HTTP
- */
-class JSONDB
-{
-public:
- struct NetworkSummaryInfo
- {
- NetworkSummaryInfo() : authorizedMemberCount(0),activeMemberCount(0),totalMemberCount(0),mostRecentDeauthTime(0) {}
- std::vector<Address> activeBridges;
- std::vector<InetAddress> allocatedIps;
- unsigned long authorizedMemberCount;
- unsigned long activeMemberCount;
- unsigned long totalMemberCount;
- int64_t mostRecentDeauthTime;
- };
-
- JSONDB(const std::string &basePath,EmbeddedNetworkController *parent);
- ~JSONDB();
-
- /**
- * Write a JSON object to the data store
- *
- * It's important that obj contain a valid JSON object with no newlines (jsonDump with -1
- * for indentation), since newline-delimited JSON is what nodeJS's IPC speaks and this
- * is important in Central-harnessed mode.
- *
- * @param n Path name of object
- * @param obj Object in single-line no-CRs JSON object format (OSUtils::jsonDump(obj,-1))
- * @return True if write appears successful
- */
- bool writeRaw(const std::string &n,const std::string &obj);
-
- bool hasNetwork(const uint64_t networkId) const;
-
- bool getNetwork(const uint64_t networkId,nlohmann::json &config) const;
-
- bool getNetworkSummaryInfo(const uint64_t networkId,NetworkSummaryInfo &ns) const;
-
- /**
- * @return Bit mask: 0 == none, 1 == network only, 3 == network and member
- */
- int getNetworkAndMember(const uint64_t networkId,const uint64_t nodeId,nlohmann::json &networkConfig,nlohmann::json &memberConfig,NetworkSummaryInfo &ns) const;
-
- bool getNetworkMember(const uint64_t networkId,const uint64_t nodeId,nlohmann::json &memberConfig) const;
-
- void saveNetwork(const uint64_t networkId,const nlohmann::json &networkConfig);
-
- void saveNetworkMember(const uint64_t networkId,const uint64_t nodeId,const nlohmann::json &memberConfig);
-
- nlohmann::json eraseNetwork(const uint64_t networkId);
-
- nlohmann::json eraseNetworkMember(const uint64_t networkId,const uint64_t nodeId,bool recomputeSummaryInfo = true);
-
- std::vector<uint64_t> networkIds() const
- {
- std::vector<uint64_t> r;
- Mutex::Lock _l(_networks_m);
- for(std::unordered_map<uint64_t,_NW>::const_iterator n(_networks.begin());n!=_networks.end();++n)
- r.push_back(n->first);
- return r;
- }
-
- inline unsigned long memberCount(const uint64_t networkId)
- {
- Mutex::Lock _l(_networks_m);
- std::unordered_map<uint64_t,_NW>::const_iterator i(_networks.find(networkId));
- if (i != _networks.end())
- return (unsigned long)i->second.members.size();
- return 0;
- }
-
- template<typename F>
- inline void eachMember(const uint64_t networkId,F func)
- {
- Mutex::Lock _l(_networks_m);
- std::unordered_map<uint64_t,_NW>::const_iterator i(_networks.find(networkId));
- if (i != _networks.end()) {
- for(std::unordered_map< uint64_t,std::vector<uint8_t> >::const_iterator m(i->second.members.begin());m!=i->second.members.end();++m) {
- try {
- func(networkId,m->first,nlohmann::json::from_msgpack(m->second));
- } catch ( ... ) {}
- }
- }
- }
-
- template<typename F>
- inline void eachId(F func)
- {
- Mutex::Lock _l(_networks_m);
- for(std::unordered_map<uint64_t,_NW>::const_iterator i(_networks.begin());i!=_networks.end();++i) {
- for(std::unordered_map< uint64_t,std::vector<uint8_t> >::const_iterator m(i->second.members.begin());m!=i->second.members.end();++m) {
- try {
- func(i->first,m->first);
- } catch ( ... ) {}
- }
- }
- }
-
- inline std::vector<uint64_t> networksForMember(const uint64_t nodeId)
- {
- Mutex::Lock _l(_networks_m);
- std::unordered_map< uint64_t,std::unordered_set< uint64_t > >::const_iterator m(_members.find(nodeId));
- if (m != _members.end()) {
- return std::vector<uint64_t>(m->second.begin(),m->second.end());
- } else {
- return std::vector<uint64_t>();
- }
- }
-
- void threadMain()
- throw();
-
-private:
- bool _addOrUpdate(const nlohmann::json &j);
- bool _load(const std::string &p);
- void _recomputeSummaryInfo(const uint64_t networkId);
- std::string _genPath(const std::string &n,bool create);
-
- EmbeddedNetworkController *const _parent;
- std::string _basePath;
- int _rawInput,_rawOutput;
- Mutex _rawLock;
-
- Thread _summaryThread;
- std::vector<uint64_t> _summaryThreadToDo;
- volatile bool _summaryThreadRun;
- Mutex _summaryThread_m;
-
- struct _NW
- {
- _NW() : summaryInfoLastComputed(0) {}
- std::vector<uint8_t> config;
- NetworkSummaryInfo summaryInfo;
- uint64_t summaryInfoLastComputed;
- std::unordered_map< uint64_t,std::vector<uint8_t> > members;
- };
-
- std::unordered_map< uint64_t,_NW > _networks;
- std::unordered_map< uint64_t,std::unordered_set< uint64_t > > _members;
- bool _dataReady;
- Mutex _networks_m;
-};
-
-} // namespace ZeroTier
-
-#endif