Skip to content

Commit 7e8535c

Browse files
committed
Update pr9885: consider new mgmt server node which has msId=managementServerNodeId
1 parent 861da3b commit 7e8535c

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

server/src/main/java/com/cloud/server/StatsCollector.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1159,8 +1159,14 @@ public String newStatus(ClusterServicePdu pdu) {
11591159
managementServerHostStats.put(hostStatsEntry.getManagementServerHostUuid(), hostStatsEntry);
11601160

11611161
// Update peer state to Up in mshost_peer
1162-
if (msId != hostStatsEntry.getManagementServerHostId()) {
1163-
managementServerHostPeerDao.updatePeerInfo(msId, hostStatsEntry.getManagementServerHostId(), hostStatsEntry.getManagementServerRunId(), ManagementServerHost.State.Up);
1162+
ManagementServerHostVO mgmtServerVo = managementServerHostDao.findByMsid(managementServerNodeId);
1163+
if (mgmtServerVo != null) {
1164+
msId = mgmtServerVo.getId();
1165+
if (msId != hostStatsEntry.getManagementServerHostId()) {
1166+
managementServerHostPeerDao.updatePeerInfo(msId, hostStatsEntry.getManagementServerHostId(), hostStatsEntry.getManagementServerRunId(), ManagementServerHost.State.Up);
1167+
}
1168+
} else {
1169+
logger.warn(String.format("Cannot find management server with msid [%s]. Therefore, do not update peer info.", managementServerNodeId));
11641170
}
11651171
} catch (JsonParseException e) {
11661172
logger.error("Exception in decoding of other MS hosts status from : " + pdu.getSourcePeer());

0 commit comments

Comments
 (0)