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

解决追加EOF文件有问题

This commit is contained in:
zhangxin10 2015-11-12 07:40:16 +08:00
parent 5caaaf2d66
commit a68d03bc6f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/DataBufferThreadContainer.java
View File

@ -37,15 +37,17 @@ public class DataBufferThreadContainer {
logger.info("Pending file number :" + dataFileList.length);
if (dataFileList.length > 0) {
int step = (int) Math.ceil(dataFileList.length * 1.0 / MAX_APPEND_EOF_FLAGS_THREAD_NUMBER);
int start = 0, end = 0;
while (true) {
if (end + step >= dataFileList.length) {
new AppendEOFFlagThread(Arrays.copyOf(dataFileList, start)).start();
new AppendEOFFlagThread(Arrays.copyOfRange(dataFileList, start, dataFileList.length)).start();
break;
}
end += step;
new AppendEOFFlagThread(Arrays.copyOfRange(dataFileList, start, end)).start();
start = end;
logger.debug("start:" + start + "\tend:" + end);
}
}
logger.info("Data buffer thread size {} begin to init ", MAX_THREAD_NUMBER);
@ -55,5 +57,4 @@ public class DataBufferThreadContainer {
buffers.add(dataBufferThread);
}
}
}