Skip to content

Commit bdf47b0

Browse files
committed
No null values in ConcurrentMap
1 parent f54be2a commit bdf47b0

File tree

1 file changed

+4
-6
lines changed
  • src/main/java/oracle/kubernetes/operator/work

1 file changed

+4
-6
lines changed

src/main/java/oracle/kubernetes/operator/work/Packet.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,15 @@
88
import java.util.Map;
99
import java.util.Set;
1010
import java.util.concurrent.ConcurrentHashMap;
11+
import java.util.concurrent.ConcurrentMap;
1112

1213
/**
1314
* Context of a single processing flow. Acts as a map and as a registry of components.
1415
*
1516
*/
1617
public class Packet extends AbstractMap<String, Object> implements ComponentRegistry, ComponentEx {
17-
private final Map<String, Component> components = new ConcurrentHashMap<String, Component>();
18-
private final Map<String, Object> delegate = new ConcurrentHashMap<String, Object>();
18+
private final ConcurrentMap<String, Component> components = new ConcurrentHashMap<String, Component>();
19+
private final ConcurrentMap<String, Object> delegate = new ConcurrentHashMap<String, Object>();
1920

2021
public Packet() {}
2122

@@ -33,9 +34,6 @@ public Packet clone() {
3334
}
3435

3536
public <S> S getSPI(Class<S> spiType) {
36-
if (components == null) {
37-
return null;
38-
}
3937
for (Component c : components.values()) {
4038
S s = c.getSPI(spiType);
4139
if (s != null) {
@@ -66,6 +64,6 @@ public Set<Entry<String, Object>> entrySet() {
6664

6765
@Override
6866
public Object put(String key, Object value) {
69-
return delegate.put(key, value);
67+
return value != null ? delegate.put(key, value) : delegate.remove(key);
7068
}
7169
}

0 commit comments

Comments
 (0)