kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复StorageChainController死循环的问题

This commit is contained in:
ascrutae 2016-02-25 16:16:09 +08:00
parent 5f41a3d334
commit 48d3abaab8
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/Chain.java
View File

@ -1,6 +1,8 @@
package com.ai.cloud.skywalking.reciever.storage;
import com.ai.cloud.skywalking.protocol.Span;
import com.ai.cloud.skywalking.reciever.selfexamination.ServerHealthCollector;
import com.ai.cloud.skywalking.reciever.selfexamination.ServerHeathReading;
import java.util.List;
@ -15,7 +17,15 @@ public class Chain {
public void doChain(List<Span> spans) {
if (index < chains.size()) {
chains.get(index++).doChain(spans, this);
while (true) {
try {
chains.get(index++).doChain(spans, this);
break;
} catch (Throwable e) {
ServerHealthCollector.getCurrentHeathReading("storage-chain").updateData(ServerHeathReading.ERROR,
"Failed to do chain action.Cause:" + e.getMessage());
}
}
}
}