You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-08-07 03:22:57 +03:00
WIP. First cut of excising OAM and root access from the dev process.
This passes most tests; need to make sure that the tests that fail have nothing to do with this change. DMLProc is doing something that results in a sudo password prompt. Will obliterate that next.
This commit is contained in:
@@ -2,6 +2,9 @@
|
|||||||
#ifndef TEST_CONFIG_H
|
#ifndef TEST_CONFIG_H
|
||||||
#define TEST_CONFIG_H
|
#define TEST_CONFIG_H
|
||||||
|
|
||||||
|
/* Define to 1 to let the system come up without using OAM */
|
||||||
|
#cmakedefine SKIP_OAM_INIT 1
|
||||||
|
|
||||||
/* Define to 1 if you have the `alarm' function. */
|
/* Define to 1 if you have the `alarm' function. */
|
||||||
#cmakedefine HAVE_ALARM 1
|
#cmakedefine HAVE_ALARM 1
|
||||||
|
|
||||||
|
@@ -17,6 +17,9 @@ INCLUDE (CheckSymbolExists)
|
|||||||
INCLUDE (CheckCXXSymbolExists)
|
INCLUDE (CheckCXXSymbolExists)
|
||||||
INCLUDE (CheckTypeSize)
|
INCLUDE (CheckTypeSize)
|
||||||
|
|
||||||
|
IF($ENV{SKIP_OAM_INIT})
|
||||||
|
SET(SKIP_OAM_INIT 1)
|
||||||
|
ENDIF()
|
||||||
CHECK_INCLUDE_FILE_CXX (alloca.h HAVE_ALLOCA_H)
|
CHECK_INCLUDE_FILE_CXX (alloca.h HAVE_ALLOCA_H)
|
||||||
CHECK_INCLUDE_FILE_CXX (arpa/inet.h HAVE_ARPA_INET_H)
|
CHECK_INCLUDE_FILE_CXX (arpa/inet.h HAVE_ARPA_INET_H)
|
||||||
CHECK_INCLUDE_FILE_CXX (dlfcn.h HAVE_DLFCN_H)
|
CHECK_INCLUDE_FILE_CXX (dlfcn.h HAVE_DLFCN_H)
|
||||||
|
@@ -63,6 +63,7 @@ using namespace std;
|
|||||||
#include <boost/scoped_ptr.hpp>
|
#include <boost/scoped_ptr.hpp>
|
||||||
using namespace boost;
|
using namespace boost;
|
||||||
|
|
||||||
|
#include "config.h"
|
||||||
#include "configcpp.h"
|
#include "configcpp.h"
|
||||||
using namespace config;
|
using namespace config;
|
||||||
#include "messagequeue.h"
|
#include "messagequeue.h"
|
||||||
@@ -100,6 +101,10 @@ using namespace querytele;
|
|||||||
#include "threadpool.h"
|
#include "threadpool.h"
|
||||||
#include "crashtrace.h"
|
#include "crashtrace.h"
|
||||||
|
|
||||||
|
#if defined(SKIP_OAM_INIT)
|
||||||
|
#include "dbrm.h"
|
||||||
|
#endif
|
||||||
|
|
||||||
namespace
|
namespace
|
||||||
{
|
{
|
||||||
|
|
||||||
@@ -1601,6 +1606,11 @@ int main(int argc, char* argv[])
|
|||||||
{
|
{
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
#if defined(SKIP_OAM_INIT)
|
||||||
|
BRM::DBRM *dbrm = new BRM::DBRM();
|
||||||
|
dbrm->setSystemQueryReady(true);
|
||||||
|
delete dbrm;
|
||||||
|
#endif
|
||||||
|
|
||||||
threadpool::ThreadPool exeMgrThreadPool(serverThreads, 0);
|
threadpool::ThreadPool exeMgrThreadPool(serverThreads, 0);
|
||||||
exeMgrThreadPool.setName("ExeMgrServer");
|
exeMgrThreadPool.setName("ExeMgrServer");
|
||||||
|
@@ -56,6 +56,7 @@
|
|||||||
#ifdef _MSC_VER
|
#ifdef _MSC_VER
|
||||||
#include "idbregistry.h"
|
#include "idbregistry.h"
|
||||||
#endif
|
#endif
|
||||||
|
#include "config.h"
|
||||||
#include "installdir.h"
|
#include "installdir.h"
|
||||||
#include "dbrm.h"
|
#include "dbrm.h"
|
||||||
#include "sessionmanager.h"
|
#include "sessionmanager.h"
|
||||||
|
@@ -34,6 +34,7 @@ using namespace boost;
|
|||||||
#include "exceptclasses.h"
|
#include "exceptclasses.h"
|
||||||
#include "configcpp.h"
|
#include "configcpp.h"
|
||||||
#include "installdir.h"
|
#include "installdir.h"
|
||||||
|
#include "config.h"
|
||||||
|
|
||||||
namespace
|
namespace
|
||||||
{
|
{
|
||||||
@@ -83,7 +84,7 @@ void OamCache::checkReload()
|
|||||||
for (uint32_t i = 0; i < dbroots.size(); i++)
|
for (uint32_t i = 0; i < dbroots.size(); i++)
|
||||||
{
|
{
|
||||||
oam.getDbrootPmConfig(dbroots[i], temp);
|
oam.getDbrootPmConfig(dbroots[i], temp);
|
||||||
//cout << " dbroot " << dbroots[i] << " -> PM " << temp << endl;
|
cout << " dbroot " << dbroots[i] << " -> PM " << temp << endl;
|
||||||
(*dbRootPMMap)[dbroots[i]] = temp;
|
(*dbRootPMMap)[dbroots[i]] = temp;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -180,6 +181,7 @@ void OamCache::checkReload()
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
#else
|
#else
|
||||||
|
pmToConnectionMap[*it] = i++;
|
||||||
moduleIds.push_back(*it);
|
moduleIds.push_back(*it);
|
||||||
#endif
|
#endif
|
||||||
it++;
|
it++;
|
||||||
|
Reference in New Issue
Block a user