Skip to content

Commit bf1bb0c

Browse files
committed
fix
1 parent 2067e75 commit bf1bb0c

File tree

2 files changed

+1
-19
lines changed

2 files changed

+1
-19
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/IgniteDhtPartitionHistorySuppliersMap.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -95,13 +95,7 @@ public synchronized void put(UUID nodeId, int grpId, int partId, long cntr) {
9595
if (map == null)
9696
map = new HashMap<>();
9797

98-
PartitionReservationsMap nodeMap = map.get(nodeId);
99-
100-
if (nodeMap == null) {
101-
nodeMap = new PartitionReservationsMap(new HashMap<>());
102-
103-
map.put(nodeId, nodeMap);
104-
}
98+
PartitionReservationsMap nodeMap = map.computeIfAbsent(nodeId, k -> new PartitionReservationsMap());
10599

106100
nodeMap.put(new GroupPartitionIdPair(grpId, partId), cntr);
107101
}

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/PartitionReservationsMap.java

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -32,18 +32,6 @@ public class PartitionReservationsMap implements Message {
3232
@Order(0)
3333
private Map<GroupPartitionIdPair, Long> map;
3434

35-
/** Default constructor. */
36-
public PartitionReservationsMap() {
37-
// No-op.
38-
}
39-
40-
/**
41-
* @param map Map.
42-
*/
43-
public PartitionReservationsMap(Map<GroupPartitionIdPair, Long> map) {
44-
this.map = map;
45-
}
46-
4735
/**
4836
* @return Map.
4937
*/

0 commit comments

Comments
 (0)