shaba/one
1
0
Fork 0
mirror of https://github.com/OpenNebula/one.git synced 2025-03-21 14:50:08 +03:00
Code Releases Wiki Activity

F #4809: Start replication on new exec_wr calls

Browse Source
This commit is contained in:
Ruben S. Montero 2017-04-23 13:15:57 +02:00
parent f2039e0260
commit 034e23166f
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/logdb/LogDB.cc
View File

@ -74,6 +74,8 @@ int LogDB::exec_wr(ostringstream& cmd)
Nebula& nd = Nebula::instance();
ZonePool * zpool = nd.get_zonepool();
Zone * zone;
int server_id = nd.get_server_id();
int zone_id = nd.get_zone_id();
@ -84,7 +86,7 @@ int LogDB::exec_wr(ostringstream& cmd)
if ( server_id != -1 )
{
Zone * zone = zpool->get(zone_id, true);
zone = zpool->get(zone_id, true);
if ( zone != 0 )
{
@ -151,7 +153,25 @@ int LogDB::exec_wr(ostringstream& cmd)
pthread_mutex_unlock(&mutex);
//LogDBManager->triger(NEW_LOG_RECORD);
zone = zpool->get(zone_id, true);
if ( zone == 0 )
{
return -1;
}
server = zone->get_server(server_id);
if ( server == 0 )
{
zone->unlock();
return -1;
}
server->logdbm_replicate();
zone->unlock();
// Wait for completion
lr->wait();