Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
@@ -299,6 +299,7 @@ extern PTreeReaderOptions defaultXmlReadFlags;
extern bool mergeSlaveStatistics;
extern bool defaultNoSeekBuildIndex;
extern unsigned parallelLoadQueries;
+extern bool adhocRoxie;
#ifdef _CONTAINERIZED
static constexpr bool roxieMulticastEnabled = false;
@@ -1937,6 +1937,7 @@ IHpccProtocolListener *createRoxieWorkUnitListener(unsigned poolSize, bool suspe
{
if (traceLevel)
DBGLOG("Creating Roxie workunit listener, pool size %d%s", poolSize, suspended?" SUSPENDED":"");
+ adhocRoxie = true;
return new RoxieWorkUnitListener(poolSize, suspended);
}
@@ -172,6 +172,7 @@ unsigned maxGraphLoopIterations;
bool probeAllRows;
bool steppingEnabled = true;
bool simpleLocalKeyedJoins = true;
+bool adhocRoxie = false;
unsigned __int64 minFreeDiskSpace = 1024 * 0x100000; // default to 1 GB
unsigned socketCheckInterval = 5000;
@@ -2348,6 +2348,8 @@ private:
else if (stricmp(queryName, "control:lockDali")==0)
+ if (adhocRoxie)
+ throw MakeStringException(ROXIE_CONTROL_MSG_ERROR, "Cannot lock dali when listening for workunits");
topology->setPropBool("@lockDali", true);
if (daliHelper)
daliHelper->disconnect();