Skip to content

Commit e0a3797

Browse files
committed
1 parent 448c492 commit e0a3797

File tree

2 files changed

+2
-129
lines changed

2 files changed

+2
-129
lines changed

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/ClusterPointRepository.java

+2
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import org.apache.logging.log4j.LogManager;
2323
import org.apache.logging.log4j.Logger;
2424

25+
import javax.annotation.concurrent.GuardedBy;
2526
import java.util.ArrayList;
2627
import java.util.HashMap;
2728
import java.util.HashSet;
@@ -33,6 +34,7 @@ public class ClusterPointRepository<T extends ClusterPoint<?>> implements Cluste
3334

3435
private final Logger logger = LogManager.getLogger(this.getClass());
3536

37+
@GuardedBy("this")
3638
private final Map<ClusterKey, Set<T>> clusterPointRepository = new HashMap<>();
3739

3840
public boolean addAndIsKeyCreated(T clusterPoint) {

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/ThriftAgentConnection.java

-129
This file was deleted.

0 commit comments

Comments
 (0)