From f2ec80f10d553eff922b843f6ad64d967d29cdd7 Mon Sep 17 00:00:00 2001 From: Evan Tschannen Date: Mon, 2 Jul 2018 13:06:54 -0400 Subject: [PATCH] added trace events for cluster controller changing datacenters --- fdbserver/ClusterController.actor.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/fdbserver/ClusterController.actor.cpp b/fdbserver/ClusterController.actor.cpp index 85d23492dc..898256a4b6 100644 --- a/fdbserver/ClusterController.actor.cpp +++ b/fdbserver/ClusterController.actor.cpp @@ -1959,6 +1959,7 @@ ACTOR Future updatedChangingDatacenters(ClusterControllerData *self) { uint8_t newFitness = ClusterControllerPriorityInfo::calculateDCFitness( worker.interf.locality.dcId(), self->desiredDcIds.get().get() ); self->changingDcIds.set(std::make_pair(worker.priorityInfo.dcFitness > newFitness,self->desiredDcIds.get())); + TraceEvent("UpdateChangingDatacenter", self->id).detail("OldFitness", worker.priorityInfo.dcFitness).detail("NewFitness", newFitness); if ( worker.priorityInfo.dcFitness > newFitness ) { worker.priorityInfo.dcFitness = newFitness; if(!worker.reply.isSet()) { @@ -2007,6 +2008,7 @@ ACTOR Future updatedChangedDatacenters(ClusterControllerData *self) { self->changedDcIds.set(self->changingDcIds.get()); if(self->changedDcIds.get().second.present()) { + TraceEvent("UpdateChangedDatacenter", self->id).detail("CCFirst", self->changedDcIds.get().first); if( !self->changedDcIds.get().first ) { auto& worker = self->id_worker[self->clusterControllerProcessId]; uint8_t newFitness = ClusterControllerPriorityInfo::calculateDCFitness( worker.interf.locality.dcId(), self->changedDcIds.get().second.get() );