Skip to content

Commit 8df532a

Browse files
committed
Intermittent status fix
1 parent 151be59 commit 8df532a

File tree

3 files changed

+13
-7
lines changed

3 files changed

+13
-7
lines changed

operator/src/main/java/oracle/kubernetes/weblogic/domain/model/DomainStatus.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -314,6 +314,9 @@ public void setServers(List<ServerStatus> servers) {
314314
private ServerStatus adjust(ServerStatus server) {
315315
if (server.getState() == null) {
316316
ServerStatus oldServer = getMatchingServer(server);
317+
if ((oldServer != null) && (oldServer.getHealth() == null)) {
318+
return server;
319+
}
317320
server.setState(oldServer == null ? SHUTDOWN_STATE : oldServer.getState());
318321
}
319322
return server;

operator/src/main/java/oracle/kubernetes/weblogic/domain/model/ServerStatus.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,7 @@ public ServerStatus withNodeName(String nodeName) {
208208
*
209209
* @return health
210210
*/
211-
private ServerHealth getHealth() {
211+
ServerHealth getHealth() {
212212
return health;
213213
}
214214

operator/src/test/java/oracle/kubernetes/weblogic/domain/model/DomainStatusTest.java

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -319,14 +319,17 @@ public void whenSetServerIncludesServerWithoutStateAndNoExistingState_defaultToS
319319

320320
@Test
321321
public void whenSetServerIncludesServerWithoutStateAndHasExistingState_preserveIt() {
322-
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("1").withState("state1"));
323-
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("2").withState("state1"));
324-
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("3").withState("state1"));
322+
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("1").withState("state1")
323+
.withHealth(new ServerHealth().withOverallHealth("ok")));
324+
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("2").withState("state1")
325+
.withHealth(new ServerHealth().withOverallHealth("ok")));
326+
domainStatus.addServer(new ServerStatus().withClusterName("1").withServerName("3").withState("state1")
327+
.withHealth(new ServerHealth().withOverallHealth("ok")));
325328

326329
domainStatus.setServers(Arrays.asList(
327-
new ServerStatus().withClusterName("1").withServerName("1").withState("state1"),
328-
new ServerStatus().withClusterName("1").withServerName("2").withState("state1"),
329-
new ServerStatus().withClusterName("1").withServerName("3")
330+
new ServerStatus().withClusterName("1").withServerName("1").withState("state1"),
331+
new ServerStatus().withClusterName("1").withServerName("2").withState("state1"),
332+
new ServerStatus().withClusterName("1").withServerName("3")
330333
));
331334

332335
assertThat(getServer("1", "3").getState(), equalTo("state1"));

0 commit comments

Comments
 (0)