summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoseph Henry <josephjah@gmail.com>2019-05-17 10:15:40 -0700
committerJoseph Henry <josephjah@gmail.com>2019-05-17 10:15:40 -0700
commit90d324ae964fddf3355505d5d9651e75872f76b7 (patch)
treed36ecd7b409d4d5ca5486effac5215d37c19f93b
parent4743ad0b16a72c00039de1aed98499fe0adf633f (diff)
downloadinfinitytier-90d324ae964fddf3355505d5d9651e75872f76b7.tar.gz
infinitytier-90d324ae964fddf3355505d5d9651e75872f76b7.zip
Fixed ZT_SDK build issue. Moved ZT_SDK preprocessor directives to more permanent homes
-rw-r--r--node/Constants.hpp4
-rw-r--r--node/NetworkConfig.hpp9
-rw-r--r--node/Node.cpp2
-rw-r--r--node/Switch.cpp6
4 files changed, 16 insertions, 5 deletions
diff --git a/node/Constants.hpp b/node/Constants.hpp
index e8a3e020..4f45f616 100644
--- a/node/Constants.hpp
+++ b/node/Constants.hpp
@@ -482,7 +482,11 @@
/**
* Timeout for overall peer activity (measured from last receive)
*/
+#ifndef ZT_SDK
#define ZT_PEER_ACTIVITY_TIMEOUT 500000
+#else
+#define ZT_PEER_ACTIVITY_TIMEOUT 30000
+#endif
/**
* General rate limit timeout for multiple packet types (HELLO, etc.)
diff --git a/node/NetworkConfig.hpp b/node/NetworkConfig.hpp
index 6367b8ec..be8c03dd 100644
--- a/node/NetworkConfig.hpp
+++ b/node/NetworkConfig.hpp
@@ -274,7 +274,14 @@ public:
/**
* @return True if frames should not be compressed
*/
- inline bool disableCompression() const { return ((this->flags & ZT_NETWORKCONFIG_FLAG_DISABLE_COMPRESSION) != 0); }
+ inline bool disableCompression() const
+ {
+#ifndef ZT_SDK
+ return ((this->flags & ZT_NETWORKCONFIG_FLAG_DISABLE_COMPRESSION) != 0);
+#else
+ return false; // Compression is disabled for SDK builds since it doesn't play nice with lwIP
+#endif
+ }
/**
* @return Network type is public (no access control)
diff --git a/node/Node.cpp b/node/Node.cpp
index ffa4a700..c9f38ad3 100644
--- a/node/Node.cpp
+++ b/node/Node.cpp
@@ -340,7 +340,7 @@ ZT_ResultCode Node::processBackgroundTasks(void *tptr,int64_t now,volatile int64
// Update online status, post status change as event
const bool oldOnline = _online;
- _online = (((now - lastReceivedFromUpstream) < (ZT_PEER_ACTIVITY_TIMEOUT / (ZT_SDK ? 16 : 1)))||(RR->topology->amUpstream()));
+ _online = (((now - lastReceivedFromUpstream) < ZT_PEER_ACTIVITY_TIMEOUT)||(RR->topology->amUpstream()));
if (oldOnline != _online)
postEvent(tptr,_online ? ZT_EVENT_ONLINE : ZT_EVENT_OFFLINE);
} catch ( ... ) {
diff --git a/node/Switch.cpp b/node/Switch.cpp
index eeab051e..55275dc3 100644
--- a/node/Switch.cpp
+++ b/node/Switch.cpp
@@ -425,7 +425,7 @@ void Switch::onLocalEthernet(void *tPtr,const SharedPtr<Network> &network,const
from.appendTo(outp);
outp.append((uint16_t)etherType);
outp.append(data,len);
- if (!network->config().disableCompression() && !ZT_SDK)
+ if (!network->config().disableCompression())
outp.compress();
aqm_enqueue(tPtr,network,outp,true,qosBucket);
} else {
@@ -433,7 +433,7 @@ void Switch::onLocalEthernet(void *tPtr,const SharedPtr<Network> &network,const
outp.append(network->id());
outp.append((uint16_t)etherType);
outp.append(data,len);
- if (!network->config().disableCompression() && !ZT_SDK)
+ if (!network->config().disableCompression())
outp.compress();
aqm_enqueue(tPtr,network,outp,true,qosBucket);
}
@@ -490,7 +490,7 @@ void Switch::onLocalEthernet(void *tPtr,const SharedPtr<Network> &network,const
from.appendTo(outp);
outp.append((uint16_t)etherType);
outp.append(data,len);
- if (!network->config().disableCompression() && !ZT_SDK)
+ if (!network->config().disableCompression())
outp.compress();
aqm_enqueue(tPtr,network,outp,true,qosBucket);
} else {