提交 66bd78cf 编写于 作者: wu-sheng's avatar wu-sheng

1.修复一批方法名,明确方法逻辑。

上级 fc10691f
......@@ -39,7 +39,7 @@ public class ChainSpecificTimeWindowSummary {
chainNodeSummaryResultMap.put(chainNodeSummaryResult.getTraceLevelId(), chainNodeSummaryResult);
}
public void summaryResult(ChainNode node) {
public void summaryNodeValue(ChainNode node) {
String tlid = node.getTraceLevelId();
ChainNodeSpecificTimeWindowSummary chainNodeSummaryResult = chainNodeSummaryResultMap.get(tlid);
if (chainNodeSummaryResult == null) {
......
......@@ -14,24 +14,22 @@ import java.util.Date;
public class ChainSummary {
private Map<String, ChainSpecificTimeWindowSummary> summaryResultMap;
private Map<String, ChainSpecificTimeWindowSummary> loadedChainSpecificTimeWindowSummary;
private Map<String, Timestamp> updateChainInfo;
public ChainSummary() {
summaryResultMap = new HashMap<String, ChainSpecificTimeWindowSummary>();
loadedChainSpecificTimeWindowSummary = new HashMap<String, ChainSpecificTimeWindowSummary>();
updateChainInfo = new HashMap<String, Timestamp>();
}
public void summary(ChainInfo chainInfo) {
for (ChainNode node : chainInfo.getNodes()) {
String csk = generateChainSummaryKey(chainInfo.getCID(), node.getStartDate());
ChainSpecificTimeWindowSummary chainSummaryResult = summaryResultMap.get(csk);
if (chainSummaryResult == null) {
chainSummaryResult = ChainSpecificTimeWindowSummary.load(csk);
summaryResultMap.put(csk, chainSummaryResult);
if (loadedChainSpecificTimeWindowSummary.containsKey(csk)) {
loadedChainSpecificTimeWindowSummary.put(csk, ChainSpecificTimeWindowSummary.load(csk));
}
summaryResultMap.get(csk).summaryResult(node);
loadedChainSpecificTimeWindowSummary.get(csk).summaryNodeValue(node);
}
updateChainInfo.put(chainInfo.getCID(), new Timestamp(System.currentTimeMillis()));
......@@ -44,16 +42,16 @@ public class ChainSummary {
public void save() throws IOException, InterruptedException, SQLException {
batchSaveChainSpecificTimeWindowSummary();
batchUpdateChainDetail();
updateChainLastActiveTime();
}
private void batchUpdateChainDetail() throws SQLException {
DBCallChainInfoDao.updateChainDetail(updateChainInfo);
private void updateChainLastActiveTime() throws SQLException {
DBCallChainInfoDao.updateChainLastActiveTime(updateChainInfo);
}
private void batchSaveChainSpecificTimeWindowSummary() throws IOException, InterruptedException {
List<Put> puts = new ArrayList<Put>();
for (Map.Entry<String, ChainSpecificTimeWindowSummary> entry : summaryResultMap.entrySet()) {
for (Map.Entry<String, ChainSpecificTimeWindowSummary> entry : loadedChainSpecificTimeWindowSummary.entrySet()) {
Put put = new Put(entry.getKey().getBytes());
entry.getValue().save(put);
puts.add(put);
......
......@@ -61,7 +61,7 @@ public class DBCallChainInfoDao {
connection.commit();
}
public synchronized static void updateChainDetail(Map<String, Timestamp> updateChainInfo)
public synchronized static void updateChainLastActiveTime(Map<String, Timestamp> updateChainInfo)
throws SQLException {
PreparedStatement preparedStatement = null;
try {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册