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: Log information to debug federated zones with HA clusters. THIS

Browse Source 
COMMIT IS MEANT TO BE REVERTED
This commit is contained in:
Ruben S. Montero 2017-06-30 11:49:04 +02:00
parent 215bc0dff7
commit 7b22d8755b
2 changed files with 41 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/raft/FedReplicaManager.cc
View File

@ -290,11 +290,23 @@ int FedReplicaManager::get_next_record(int zone_id, std::string& zedp,
zedp = zs->endpoint;
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
std::ostringstream loss;
loss << "REPLICATE FOR ZONE: " << zone_id << " NEXT IS: " << zs->next
<< "LAST IS: " << zs->last;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
if ( zs->next == -1 )
{
zs->next= logdb->last_federated();
}
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
loss.str("");
loss << "REPLICATE FOR ZONE: " << zone_id << " NEXT IS: " << zs->next
<< "LAST IS: " << zs->last;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
if ( zs->last == zs->next )
{
pthread_mutex_unlock(&mutex);
@ -325,10 +337,19 @@ void FedReplicaManager::replicate_success(int zone_id)
ZoneServers * zs = it->second;
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
std::ostringstream loss;
loss << "SUCCESS REPLICATE FOR ZONE: " << zone_id << " NEXT: " << zs->next
<< " LAST: " << zs->last;
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
zs->last = zs->next;
zs->next = logdb->next_federated(zs->next);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
loss.str("");
loss << " NEW NEXT: " << zs->next << " NEW LAST: " << zs->last;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
if ( zs->next != -1 )
{
ReplicaManager::replicate(zone_id);
@ -356,6 +377,12 @@ void FedReplicaManager::replicate_failure(int zone_id, int last_zone)
zs->next = logdb->next_federated(zs->last);
}
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
std::ostringstream loss;
loss << "FAILURE REPLICATE FOR ZONE: " << zone_id << " NEXT: " << zs->next
<< "LAST: " << zs->last << " LAST_ZONE: " << last_zone;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
if ( zs->next != -1 )
{
ReplicaManager::replicate(zone_id);
@ -404,6 +431,12 @@ int FedReplicaManager::xmlrpc_replicate_log(int zone_id, bool& success,
replica_params.add(xmlrpc_c::value_int(prev_index));
replica_params.add(xmlrpc_c::value_string(lr.sql));
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
std::ostringstream loss;
loss << "REPLICATING INDEX: " <<lr.index<< " PREV_INDEX: " << prev_index
<< " SQL: " <<lr.sql;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
// -------------------------------------------------------------------------
// Do the XML-RPC call
// -------------------------------------------------------------------------

7
src/rm/RequestManagerZone.cc
View File

@ -522,6 +522,13 @@ void ZoneReplicateFedLog::request_execute(xmlrpc_c::paramList const& paramList,
int prev = xmlrpc_c::value_int(paramList.getInt(2));
string sql = xmlrpc_c::value_string(paramList.getString(3));
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
std::ostringstream loss;
loss << "REPLICATE REQUEST INDEX: " << index << " PREV: " << prev << " SQL: "
<< sql;
NebulaLog::log("ReM", Log::INFO, loss);
//LLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLL
if ( att.uid != 0 )
{
att.resp_id = -1;