|
@@ -101,8 +101,8 @@ public class ClusterNode extends StatisticNode { |
|
|
public Node getOrCreateOriginNode(String origin) { |
|
|
public Node getOrCreateOriginNode(String origin) { |
|
|
StatisticNode statisticNode = originCountMap.get(origin); |
|
|
StatisticNode statisticNode = originCountMap.get(origin); |
|
|
if (statisticNode == null) { |
|
|
if (statisticNode == null) { |
|
|
|
|
|
lock.lock(); |
|
|
try { |
|
|
try { |
|
|
lock.lock(); |
|
|
|
|
|
statisticNode = originCountMap.get(origin); |
|
|
statisticNode = originCountMap.get(origin); |
|
|
if (statisticNode == null) { |
|
|
if (statisticNode == null) { |
|
|
// The node is absent, create a new node for the origin. |
|
|
// The node is absent, create a new node for the origin. |
|
|