You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-08-08 14:22:09 +03:00
5aa2a824c2
This patch introduces centralized logic of selecting what dbroot is accessible in PrimProc on what node. The logic is in OamCache for time being and can be moved later.
86 lines
2.6 KiB
C++
86 lines
2.6 KiB
C++
/* Copyright (C) 2014 InfiniDB, Inc.
|
|
Copyright (C) 2016 MariaDB Corporation
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; version 2 of
|
|
the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
|
|
MA 02110-1301, USA. */
|
|
|
|
#pragma once
|
|
|
|
#include <unistd.h>
|
|
#include <map>
|
|
#include <set>
|
|
#include <vector>
|
|
#include <boost/shared_ptr.hpp>
|
|
|
|
#include "liboamcpp.h"
|
|
|
|
|
|
namespace oam
|
|
{
|
|
class OamCache
|
|
{
|
|
public:
|
|
typedef boost::shared_ptr<std::map<int, std::set<int>> > dbRootPMMap_t;
|
|
typedef std::vector<int> dbRoots;
|
|
typedef boost::shared_ptr<std::map<int, dbRoots> > PMDbrootsMap_t;
|
|
virtual ~OamCache() = default;
|
|
|
|
void checkReload();
|
|
void forceReload()
|
|
{
|
|
mtime = 0;
|
|
}
|
|
|
|
int getClosestPM(int dbroot); // who can access dbroot's records for read requests - either owner or us.
|
|
int getClosestConnection(int dbroot); // connection index to owner's PM or ours PM - who can access dbRoot.
|
|
int getOwnerConnection(int dbroot); // connection index to owner's PM.
|
|
int getOwnerPM(int dbroot); // Owner's PM index.
|
|
std::vector<int> getPMDBRoots(int PM); // what DBRoots are owned by given PM.
|
|
std::vector<int> getAllDBRoots(); // get all DBRoots.
|
|
bool isAccessibleBy(int dbRoot, int pmId);
|
|
bool isOffline(int dbRoot); // not registered in map.
|
|
uint32_t getDBRootCount();
|
|
DBRootConfigList& getDBRootNums();
|
|
std::vector<int>& getModuleIds();
|
|
static OamCache* makeOamCache();
|
|
std::string getOAMParentModuleName();
|
|
int getLocalPMId(); // return the PM id of this machine.
|
|
std::string getSystemName();
|
|
std::string getModuleName();
|
|
|
|
private:
|
|
friend struct CacheReloaded;
|
|
OamCache() = default;
|
|
OamCache(const OamCache&) = delete;
|
|
OamCache& operator=(const OamCache&) const = delete;
|
|
|
|
dbRootPMMap_t dbRootPMMap;
|
|
map<int, int> dbRootConnectionMap;
|
|
PMDbrootsMap_t pmDbrootsMap;
|
|
uint32_t numDBRoots = 1;
|
|
time_t mtime = 0;
|
|
DBRootConfigList dbroots;
|
|
std::vector<int> moduleIds;
|
|
std::string OAMParentModuleName;
|
|
int mLocalPMId = 0; // The PM id running on this machine
|
|
std::string systemName;
|
|
std::string moduleName;
|
|
map<int, int> pmConnectionMap;
|
|
set<int> rwPMs;
|
|
};
|
|
|
|
} // namespace oam
|
|
|