|
@@ -474,7 +474,9 @@ void readStaticTopology()
|
|
|
if (!numDataCopies)
|
|
|
throw MakeStringException(MSGAUD_operator, ROXIE_INVALID_TOPOLOGY, "Invalid topology file - numDataCopies should be > 0");
|
|
|
unsigned channelsPerNode = topology->getPropInt("@channelsPerNode", 1);
|
|
|
- const char *slaveConfig = topology->queryProp("@slaveConfig");
|
|
|
+ const char *slaveConfig = topology->queryProp("@agentConfig");
|
|
|
+ if (!slaveConfig)
|
|
|
+ slaveConfig = topology->queryProp("@slaveConfig"); // legacy name
|
|
|
if (!slaveConfig)
|
|
|
slaveConfig = "simple";
|
|
|
|
|
@@ -864,7 +866,7 @@ int STARTQUERY_API start_query(int argc, const char *argv[])
|
|
|
}
|
|
|
useDynamicServers = topology->getPropBool("@useDynamicServers", topologyServers.length()>0);
|
|
|
useAeron = topology->getPropBool("@useAeron", useDynamicServers);
|
|
|
- localSlave = topology->getPropBool("@localSlave", false);
|
|
|
+ localSlave = topology->getPropBool("@localAgent", topology->getPropBool("@localSlave", false)); // legacy name
|
|
|
numChannels = topology->getPropInt("@numChannels", 0);
|
|
|
doIbytiDelay = topology->getPropBool("@doIbytiDelay", true);
|
|
|
minIbytiDelay = topology->getPropInt("@minIbytiDelay", 2);
|
|
@@ -961,14 +963,14 @@ int STARTQUERY_API start_query(int argc, const char *argv[])
|
|
|
multicastTTL = ttlTmp;
|
|
|
|
|
|
indexReadChunkSize = topology->getPropInt("@indexReadChunkSize", 60000);
|
|
|
- numSlaveThreads = topology->getPropInt("@slaveThreads", 30);
|
|
|
+ numSlaveThreads = topology->getPropInt("@agentThreads", topology->getPropInt("@slaveThreads", 30)); // legacy name
|
|
|
numServerThreads = topology->getPropInt("@serverThreads", 30);
|
|
|
numRequestArrayThreads = topology->getPropInt("@requestArrayThreads", 5);
|
|
|
maxBlockSize = topology->getPropInt("@maxBlockSize", 10000000);
|
|
|
maxLockAttempts = topology->getPropInt("@maxLockAttempts", 5);
|
|
|
enableHeartBeat = topology->getPropBool("@enableHeartBeat", true);
|
|
|
checkCompleted = topology->getPropBool("@checkCompleted", true);
|
|
|
- prestartSlaveThreads = topology->getPropBool("@prestartSlaveThreads", false);
|
|
|
+ prestartSlaveThreads = topology->getPropBool("@prestartAgentThreads", topology->getPropBool("@prestartSlaveThreads", false)); // legacy name
|
|
|
preabortKeyedJoinsThreshold = topology->getPropInt("@preabortKeyedJoinsThreshold", 100);
|
|
|
preabortIndexReadsThreshold = topology->getPropInt("@preabortIndexReadsThreshold", 100);
|
|
|
defaultMemoryLimit = (memsize_t) topology->getPropInt64("@defaultMemoryLimit", 0);
|
|
@@ -992,7 +994,7 @@ int STARTQUERY_API start_query(int argc, const char *argv[])
|
|
|
defaultCheckingHeap = topology->getPropBool("@checkingHeap", false); // NOTE - not in configmgr - too dangerous!
|
|
|
defaultDisableLocalOptimizations = topology->getPropBool("@disableLocalOptimizations", false); // NOTE - not in configmgr - too dangerous!
|
|
|
|
|
|
- slaveQueryReleaseDelaySeconds = topology->getPropInt("@slaveQueryReleaseDelaySeconds", 60);
|
|
|
+ slaveQueryReleaseDelaySeconds = topology->getPropInt("@agentQueryReleaseDelaySeconds", topology->getPropInt("@slaveQueryReleaseDelaySeconds", 60)); // legacy name
|
|
|
coresPerQuery = topology->getPropInt("@coresPerQuery", 0);
|
|
|
|
|
|
diskReadBufferSize = topology->getPropInt("@diskReadBufferSize", 0x10000);
|
|
@@ -1036,7 +1038,7 @@ int STARTQUERY_API start_query(int argc, const char *argv[])
|
|
|
trapTooManyActiveQueries = topology->getPropBool("@trapTooManyActiveQueries", true);
|
|
|
maxEmptyLoopIterations = topology->getPropInt("@maxEmptyLoopIterations", 1000);
|
|
|
maxGraphLoopIterations = topology->getPropInt("@maxGraphLoopIterations", 1000);
|
|
|
- mergeSlaveStatistics = topology->getPropBool("@mergeSlaveStatistics", true);
|
|
|
+ mergeSlaveStatistics = topology->getPropBool("@mergeAgentStatistics", topology->getPropBool("@mergeSlaveStatistics", true)); // legacy name
|
|
|
defaultCollectFactoryStatistics = topology->getPropBool("@collectFactoryStatistics", true);
|
|
|
|
|
|
enableKeyDiff = topology->getPropBool("@enableKeyDiff", true);
|