Skip to content

Commit 068bde0

Browse files
committed
More control when multiple changes close in time, including scaling
1 parent 1bb2473 commit 068bde0

File tree

1 file changed

+2
-2
lines changed
  • src/main/java/oracle/kubernetes/operator

1 file changed

+2
-2
lines changed

src/main/java/oracle/kubernetes/operator/Main.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1398,7 +1398,7 @@ private static void dispatchPodWatch(Watch.Response<V1Pod> item) {
13981398
if (domainUID != null) {
13991399
DomainPresenceInfo info = domains.get(domainUID);
14001400
if (info != null && serverName != null) {
1401-
ServerKubernetesObjects sko = info.getServers().get(serverName);
1401+
ServerKubernetesObjects sko = info.getServers().computeIfAbsent(serverName, k -> new ServerKubernetesObjects());
14021402
if (sko != null) {
14031403
Fiber f;
14041404
Packet packet;
@@ -1459,7 +1459,7 @@ private static void dispatchServiceWatch(Watch.Response<V1Service> item) {
14591459
if (domainUID != null) {
14601460
DomainPresenceInfo info = domains.get(domainUID);
14611461
if (info != null && serverName != null) {
1462-
ServerKubernetesObjects sko = info.getServers().get(serverName);
1462+
ServerKubernetesObjects sko = info.getServers().computeIfAbsent(serverName, k -> new ServerKubernetesObjects());
14631463
if (sko != null) {
14641464
switch (item.type) {
14651465
case "ADDED":

0 commit comments

Comments
 (0)