summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2016-01-12 13:19:53 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2016-01-12 13:19:53 -0800
commit61fd8463f89c1f1b3e60b8297d65250710ddcc96 (patch)
tree35fa5dc1e29d6b6fabfc5467fbd91ea40156b932
parentdd233fdb8d3360c47aedcf0dabab63aa29d80ef9 (diff)
parent3883ac08c7736c9695f100c7937af089e00359d9 (diff)
downloadinfinitytier-61fd8463f89c1f1b3e60b8297d65250710ddcc96.tar.gz
infinitytier-61fd8463f89c1f1b3e60b8297d65250710ddcc96.zip
Merge branch 'dev' into edge
-rw-r--r--node/Network.cpp12
-rw-r--r--node/Network.hpp4
-rw-r--r--node/Peer.cpp2
-rw-r--r--node/Peer.hpp7
4 files changed, 9 insertions, 16 deletions
diff --git a/node/Network.cpp b/node/Network.cpp
index 7a4a187d..bb889937 100644
--- a/node/Network.cpp
+++ b/node/Network.cpp
@@ -47,7 +47,7 @@ const ZeroTier::MulticastGroup Network::BROADCAST(ZeroTier::MAC(0xffffffffffffUL
Network::Network(const RuntimeEnvironment *renv,uint64_t nwid,void *uptr) :
RR(renv),
- _uptr(uptr),
+ _uPtr(uptr),
_id(nwid),
_mac(renv->identity.address(),nwid),
_enabled(true),
@@ -89,7 +89,7 @@ Network::Network(const RuntimeEnvironment *renv,uint64_t nwid,void *uptr) :
if (!_portInitialized) {
ZT_VirtualNetworkConfig ctmp;
_externalConfig(&ctmp);
- _portError = RR->node->configureVirtualNetworkPort(_id,&_uptr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_UP,&ctmp);
+ _portError = RR->node->configureVirtualNetworkPort(_id,&_uPtr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_UP,&ctmp);
_portInitialized = true;
}
}
@@ -101,11 +101,11 @@ Network::~Network()
char n[128];
if (_destroyed) {
- RR->node->configureVirtualNetworkPort(_id,&_uptr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY,&ctmp);
+ RR->node->configureVirtualNetworkPort(_id,&_uPtr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY,&ctmp);
Utils::snprintf(n,sizeof(n),"networks.d/%.16llx.conf",_id);
RR->node->dataStoreDelete(n);
} else {
- RR->node->configureVirtualNetworkPort(_id,&_uptr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN,&ctmp);
+ RR->node->configureVirtualNetworkPort(_id,&_uPtr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN,&ctmp);
}
}
@@ -174,7 +174,7 @@ bool Network::applyConfiguration(const SharedPtr<NetworkConfig> &conf)
portInitialized = _portInitialized;
_portInitialized = true;
}
- _portError = RR->node->configureVirtualNetworkPort(_id,&_uptr,(portInitialized) ? ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE : ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_UP,&ctmp);
+ _portError = RR->node->configureVirtualNetworkPort(_id,&_uPtr,(portInitialized) ? ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE : ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_UP,&ctmp);
return true;
} else {
TRACE("ignored invalid configuration for network %.16llx (configuration contains mismatched network ID or issued-to address)",(unsigned long long)_id);
@@ -332,7 +332,7 @@ void Network::setEnabled(bool enabled)
_enabled = enabled;
ZT_VirtualNetworkConfig ctmp;
_externalConfig(&ctmp);
- _portError = RR->node->configureVirtualNetworkPort(_id,&_uptr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE,&ctmp);
+ _portError = RR->node->configureVirtualNetworkPort(_id,&_uPtr,ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE,&ctmp);
}
}
diff --git a/node/Network.hpp b/node/Network.hpp
index cb696d12..3cf83963 100644
--- a/node/Network.hpp
+++ b/node/Network.hpp
@@ -335,7 +335,7 @@ public:
/**
* @return Pointer to user PTR (modifiable user ptr used in API)
*/
- inline void **userPtr() throw() { return &_uptr; }
+ inline void **userPtr() throw() { return &_uPtr; }
inline bool operator==(const Network &n) const throw() { return (_id == n._id); }
inline bool operator!=(const Network &n) const throw() { return (_id != n._id); }
@@ -354,7 +354,7 @@ private:
std::vector<MulticastGroup> _allMulticastGroups() const;
const RuntimeEnvironment *RR;
- void *_uptr;
+ void *_uPtr;
uint64_t _id;
MAC _mac; // local MAC address
volatile bool _enabled;
diff --git a/node/Peer.cpp b/node/Peer.cpp
index bcfda722..ca194f8d 100644
--- a/node/Peer.cpp
+++ b/node/Peer.cpp
@@ -183,7 +183,6 @@ void Peer::received(
TRACE("got %s via unknown path %s(%s), confirming...",Packet::verbString(verb),_id.address().toString().c_str(),remoteAddr.toString().c_str());
if ( (_vProto >= 5) && ( !((_vMajor == 1)&&(_vMinor == 1)&&(_vRevision == 0)) ) ) {
- // 1.1.1 and newer nodes support ECHO, which is smaller -- but 1.1.0 has a bug so use HELLO there too
Packet outp(_id.address(),RR->identity.address(),Packet::VERB_ECHO);
outp.armor(_key,true);
RR->node->putPacket(localAddr,remoteAddr,outp.data(),outp.size());
@@ -498,7 +497,6 @@ bool Peer::_checkPath(Path &p,const uint64_t now)
TRACE("%s(%s) does not seem to be answering in a timely manner, checking if dead (probation == %u)",_id.address().toString().c_str(),p.address().toString().c_str(),p.probation());
if ( (_vProto >= 5) && ( !((_vMajor == 1)&&(_vMinor == 1)&&(_vRevision == 0)) ) ) {
- // 1.1.1 and newer nodes support ECHO, which is smaller -- but 1.1.0 has a bug so use HELLO there too
Packet outp(_id.address(),RR->identity.address(),Packet::VERB_ECHO);
outp.armor(_key,true);
p.send(RR,outp.data(),outp.size(),now);
diff --git a/node/Peer.hpp b/node/Peer.hpp
index e40f576a..7d400196 100644
--- a/node/Peer.hpp
+++ b/node/Peer.hpp
@@ -186,7 +186,7 @@ public:
void pushDirectPaths(Path *path,uint64_t now,bool force);
/**
- * @return All known direct paths to this peer
+ * @return All known direct paths to this peer (active or inactive)
*/
inline std::vector<Path> paths() const
{
@@ -217,11 +217,6 @@ public:
inline uint64_t lastFrame() const throw() { return std::max(_lastUnicastFrame,_lastMulticastFrame); }
/**
- * @return Time we last announced state TO this peer, such as multicast LIKEs
- */
- inline uint64_t lastAnnouncedTo() const throw() { return _lastAnnouncedTo; }
-
- /**
* @return True if this peer has sent us real network traffic recently
*/
inline uint64_t activelyTransferringFrames(uint64_t now) const throw() { return ((now - lastFrame()) < ZT_PEER_ACTIVITY_TIMEOUT); }