InfiniSQL
v0.1.2-alpha
Massive Scale Transaction Processing
|
#include <Topology.h>
Classes | |
struct | actor_s |
characteristics for each actor More... | |
struct | addressStruct |
struct | partitionAddress |
Public Member Functions | |
Topology () | |
Topology (const Topology &orig) | |
virtual | ~Topology () |
partitionAddress * | newActor (actortypes_e type, class Mbox *mbox, int epollfd, const string &argstring, int64_t actorid, const vector< string > &nodes, const vector< string > &services) |
creates a new actor's addressing in the local node More... | |
Public Attributes | |
int16_t | nodeid |
int | numreplicas |
int | activereplica |
size_t | numtransactionagents |
size_t | numengines |
size_t | numobgateways |
vector< actor_s > | actorList |
int16_t | numpartitions |
int16_t | userSchemaMgrNode |
class Mbox * | userSchemaMgrMbox |
int16_t | deadlockMgrNode |
class Mbox * | deadlockMgrMbox |
std::vector< vector < partitionAddress > > | partitionList |
std::vector< partitionAddress > | partitionListThisReplica |
std::map< int64_t, vector < std::string > > | ibGateways |
std::vector< vector< int > > | allActors |
boost::unordered_map< int16_t, std::vector< int > > | allActorsThisReplica |
std::vector< vector< int16_t > > | replicaMembers |
std::vector< vector< int16_t > > | tas |
topology definition and functions to set and query topology attributes
Definition at line 54 of file Topology.h.
Topology::Topology | ( | ) |
Definition at line 33 of file Topology.cc.
Topology::Topology | ( | const Topology & | orig) |
Definition at line 40 of file Topology.cc.
|
virtual |
Definition at line 53 of file Topology.cc.
Topology::partitionAddress * Topology::newActor | ( | actortypes_e | type, |
class Mbox * | mbox, | ||
int | epollfd, | ||
const string & | argstring, | ||
int64_t | actorid, | ||
const vector< string > & | nodes, | ||
const vector< string > & | services | ||
) |
creates a new actor's addressing in the local node
creates a new actor's addressing in the local node. Should be followed by launching the thread should be followed by launching the thread
type | actor type |
mbox | Mbox |
epollfd | epoll descriptor |
argstring | argument field for some actors to use |
actorid | actorid |
nodes | |
services |
Definition at line 57 of file Topology.cc.
References Topology::addressStruct::actorid, Topology::partitionAddress::address, Topology::partitionAddress::argstring, Topology::partitionAddress::epollfd, logfile, Topology::partitionAddress::mbox, Topology::addressStruct::nodeid, nodeid, Topology::partitionAddress::nodes, Topology::partitionAddress::services, and Topology::partitionAddress::type.
Referenced by TopologyMgr::TopologyMgr().
int Topology::activereplica |
Definition at line 124 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig().
vector<actor_s> Topology::actorList |
Definition at line 131 of file Topology.h.
Referenced by TopologyMgr::broadcastConfig(), Mboxes::update(), TopologyMgr::updateGlobalConfig(), and TopologyMgr::updateLocalConfig().
std::vector< vector<int> > Topology::allActors |
Definition at line 144 of file Topology.h.
Referenced by TransactionAgent::newprocedure(), Mboxes::update(), and TopologyMgr::updateGlobalConfig().
boost::unordered_map< int16_t, std::vector<int> > Topology::allActorsThisReplica |
Definition at line 145 of file Topology.h.
Referenced by Mboxes::update(), and TopologyMgr::updateGlobalConfig().
class Mbox* Topology::deadlockMgrMbox |
Definition at line 138 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig().
int16_t Topology::deadlockMgrNode |
Definition at line 137 of file Topology.h.
Referenced by Mboxes::update(), and TopologyMgr::updateGlobalConfig().
std::map< int64_t, vector<std::string> > Topology::ibGateways |
Definition at line 142 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig(), and ObGateway::updateRemoteGateways().
int16_t Topology::nodeid |
this gets propagated to all addresses created by this class instance
Definition at line 121 of file Topology.h.
Referenced by TopologyMgr::broadcastConfig(), main(), newActor(), TransactionAgent::newprocedure(), ObGateway::ObGateway(), Mboxes::update(), TopologyMgr::updateGlobalConfig(), TopologyMgr::updateLocalConfig(), and ObGateway::updateRemoteGateways().
size_t Topology::numengines |
Definition at line 128 of file Topology.h.
Referenced by Operation::Operation(), Mboxes::update(), and TopologyMgr::updateLocalConfig().
size_t Topology::numobgateways |
Definition at line 129 of file Topology.h.
Referenced by Mboxes::update(), and TopologyMgr::updateLocalConfig().
int16_t Topology::numpartitions |
Definition at line 134 of file Topology.h.
Referenced by Transaction::continueCommitTransaction(), Transaction::getengine(), Transaction::getEngineid(), TransactionAgent::handledispatch(), Transaction::select(), Transaction::sqlPredicate(), Transaction::sqlSelectAll(), Mboxes::update(), and TopologyMgr::updateGlobalConfig().
int Topology::numreplicas |
Definition at line 123 of file Topology.h.
Referenced by Transaction::commit(), TopologyMgr::updateGlobalConfig(), and TransactionAgent::updateReplicas().
size_t Topology::numtransactionagents |
Definition at line 127 of file Topology.h.
Referenced by Listener::Listener(), Operation::Operation(), Mboxes::update(), and TopologyMgr::updateLocalConfig().
std::vector< vector<partitionAddress> > Topology::partitionList |
Definition at line 140 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig().
std::vector<partitionAddress> Topology::partitionListThisReplica |
Definition at line 141 of file Topology.h.
Referenced by Engine::getMyPartitionid(), Mboxes::update(), and TopologyMgr::updateGlobalConfig().
std::vector< vector<int16_t> > Topology::replicaMembers |
Definition at line 147 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig(), and TransactionAgent::updateReplicas().
std::vector< vector<int16_t> > Topology::tas |
Definition at line 149 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig(), and TransactionAgent::updateReplicas().
class Mbox* Topology::userSchemaMgrMbox |
Definition at line 136 of file Topology.h.
Referenced by TopologyMgr::updateGlobalConfig().
int16_t Topology::userSchemaMgrNode |
Definition at line 135 of file Topology.h.
Referenced by Mboxes::update(), and TopologyMgr::updateGlobalConfig().