Revision b38874a0
include/LogDB.h | ||
---|---|---|
302 | 302 |
time_t timestamp); |
303 | 303 |
}; |
304 | 304 |
|
305 |
// ----------------------------------------------------------------------------- |
|
306 |
// This is a LogDB decoration, it replicates the DB write commands on slaves |
|
307 |
// It should be passed as DB for federated pools. |
|
308 |
// ----------------------------------------------------------------------------- |
|
309 |
class FedLogDB: public SqlDB |
|
310 |
{ |
|
311 |
public: |
|
312 |
FedLogDB(LogDB *db):_logdb(db){}; |
|
313 |
|
|
314 |
virtual ~FedLogDB(){}; |
|
315 |
|
|
316 |
int exec_wr(ostringstream& cmd); |
|
317 |
|
|
318 |
int exec_local_wr(ostringstream& cmd) |
|
319 |
{ |
|
320 |
return _logdb->exec_local_wr(cmd); |
|
321 |
} |
|
322 |
|
|
323 |
int exec_rd(ostringstream& cmd, Callbackable* obj) |
|
324 |
{ |
|
325 |
return _logdb->exec_rd(cmd, obj); |
|
326 |
} |
|
327 |
|
|
328 |
char * escape_str(const string& str) |
|
329 |
{ |
|
330 |
return _logdb->escape_str(str); |
|
331 |
} |
|
332 |
|
|
333 |
void free_str(char * str) |
|
334 |
{ |
|
335 |
_logdb->free_str(str); |
|
336 |
} |
|
337 |
|
|
338 |
bool multiple_values_support() |
|
339 |
{ |
|
340 |
return _logdb->multiple_values_support(); |
|
341 |
} |
|
342 |
|
|
343 |
protected: |
|
344 |
int exec(std::ostringstream& cmd, Callbackable* obj, bool quiet) |
|
345 |
{ |
|
346 |
return -1; |
|
347 |
} |
|
348 |
|
|
349 |
private: |
|
350 |
|
|
351 |
LogDB * _logdb; |
|
352 |
} |
|
353 |
|
|
305 | 354 |
#endif /*LOG_DB_H_*/ |
306 | 355 |
|
include/ZonePool.h | ||
---|---|---|
128 | 128 |
}; |
129 | 129 |
|
130 | 130 |
/** |
131 |
* Get the servers of a zone |
|
132 |
* @param zone_id of the zone |
|
133 |
* @param _serv list of servers and associated xml-rpc endpoints |
|
134 |
* @return the number of servers in the zone |
|
135 |
*/ |
|
136 |
unsigned int get_zone_servers(int zone_id, |
|
137 |
std::map<unsigned int, std::string>& _serv); |
|
138 |
|
|
139 |
/** |
|
140 |
* Return the list of zones defined |
|
141 |
* @param zone_ids of the zones |
|
142 |
* @return 0 on success |
|
143 |
*/ |
|
144 |
int list_zones(vector<int>& zone_ids) |
|
145 |
{ |
|
146 |
return list( zone_ids, Zone::table); |
|
147 |
} |
|
148 |
|
|
149 |
/** |
|
131 | 150 |
* ID for the special local zone in stand-alone mode |
132 | 151 |
*/ |
133 | 152 |
static const int STANDALONE_ZONE_ID; |
src/raft/RaftManager.cc | ||
---|---|---|
101 | 101 |
|
102 | 102 |
// ------------------------------------------------------------------------- |
103 | 103 |
// Initialize Raft timers |
104 |
// TODO: randomize election timeout |
|
105 | 104 |
// ------------------------------------------------------------------------- |
106 | 105 |
purge_period_ms = log_purge * 1000; |
107 | 106 |
xmlrpc_timeout_ms = xmlrpc; |
... | ... | |
173 | 172 |
|
174 | 173 |
static unsigned int get_zone_servers(std::map<unsigned int, std::string>& _serv) |
175 | 174 |
{ |
176 |
unsigned int _num_servers; |
|
177 |
|
|
178 | 175 |
Nebula& nd = Nebula::instance(); |
179 | 176 |
ZonePool * zpool = nd.get_zonepool(); |
180 | 177 |
|
181 | 178 |
int zone_id = nd.get_zone_id(); |
182 | 179 |
|
183 |
ZoneServers::zone_iterator zit; |
|
184 |
|
|
185 |
Zone * zone = zpool->get(zone_id, true); |
|
186 |
|
|
187 |
if ( zone == 0 ) |
|
188 |
{ |
|
189 |
_serv.clear(); |
|
190 |
return 0; |
|
191 |
} |
|
192 |
|
|
193 |
ZoneServers * followers = zone->get_servers(); |
|
194 |
|
|
195 |
for (zit = followers->begin(); zit != followers->end(); ++zit) |
|
196 |
{ |
|
197 |
unsigned int id = (*zit)->get_id(); |
|
198 |
std::string edp = (*zit)->vector_value("ENDPOINT"); |
|
199 |
|
|
200 |
_serv.insert(make_pair(id, edp)); |
|
201 |
} |
|
202 |
|
|
203 |
_num_servers = zone->servers_size(); |
|
204 |
|
|
205 |
zone->unlock(); |
|
206 |
|
|
207 |
return _num_servers; |
|
180 |
return zpool->get_zone_servers(zone_id, _serv); |
|
208 | 181 |
} |
209 | 182 |
|
210 | 183 |
int RaftManager::get_leader_endpoint(std::string& endpoint) |
src/rm/RequestManagerZone.cc | ||
---|---|---|
295 | 295 |
|
296 | 296 |
NebulaLog::log("ReM", Log::INFO, oss); |
297 | 297 |
|
298 |
raftm->follower(leader_term); |
|
299 |
|
|
298 |
raftm->follower(candidate_term); |
|
300 | 299 |
} |
301 | 300 |
|
302 | 301 |
if ((log_term > candidate_log_term) || ((log_term == candidate_log_term) && |
src/sql/LogDB.cc | ||
---|---|---|
427 | 427 |
return db->exec_wr(oss); |
428 | 428 |
} |
429 | 429 |
|
430 |
/* -------------------------------------------------------------------------- */ |
|
431 |
/* -------------------------------------------------------------------------- */ |
|
432 |
|
|
433 |
int FedLogDB::exec_wr(ostringstream& cmd) |
|
434 |
{ |
|
435 |
//FedReplicaManager * fedrm = Nebula::instance().get_fedrm(); |
|
436 |
|
|
437 |
int rc = _logdb->exec_wr(cmd); |
|
438 |
|
|
439 |
if ( rc != 0 ) |
|
440 |
{ |
|
441 |
return rc; |
|
442 |
} |
|
443 |
|
|
444 |
//Replicate on slaves |
|
445 |
// fedrm->replicate(cmd); |
|
446 |
|
|
447 |
return rc; |
|
448 |
} |
|
449 |
|
src/zone/ZonePool.cc | ||
---|---|---|
202 | 202 |
/* -------------------------------------------------------------------------- */ |
203 | 203 |
/* -------------------------------------------------------------------------- */ |
204 | 204 |
|
205 |
unsigned int ZonePool::get_zone_servers(int zone_id, |
|
206 |
std::map<unsigned int, std::string>& _serv) |
|
207 |
{ |
|
208 |
unsigned int _num_servers; |
|
209 |
|
|
210 |
ZoneServers::zone_iterator zit; |
|
211 |
|
|
212 |
Zone * zone = get(zone_id, true); |
|
213 |
|
|
214 |
if ( zone == 0 ) |
|
215 |
{ |
|
216 |
_serv.clear(); |
|
217 |
return 0; |
|
218 |
} |
|
219 |
|
|
220 |
ZoneServers * followers = zone->get_servers(); |
|
221 |
|
|
222 |
for (zit = followers->begin(); zit != followers->end(); ++zit) |
|
223 |
{ |
|
224 |
unsigned int id = (*zit)->get_id(); |
|
225 |
std::string edp = (*zit)->vector_value("ENDPOINT"); |
|
226 |
|
|
227 |
_serv.insert(make_pair(id, edp)); |
|
228 |
} |
|
229 |
|
|
230 |
_num_servers = zone->servers_size(); |
|
231 |
|
|
232 |
zone->unlock(); |
|
233 |
|
|
234 |
return _num_servers; |
|
235 |
} |
|
236 |
|
Also available in: Unified diff