lion/storageNode
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复检查下载状态之后使用错误的移除方法导致异常

Browse Source
This commit is contained in:
chuzhongzai 2025-03-24 22:08:10 +08:00
parent c3b96414e9
commit a8e61cba8f
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/lion/storageNode.java
View File

@ -109,10 +109,7 @@ public class storageNode {
downloadStatusMessage.setGalleryTasks(queue.values().toArray(GalleryTask[]::new)); downloadStatusMessage.setGalleryTasks(queue.values().toArray(GalleryTask[]::new));
server.writeAndFlush(downloadStatusMessage); server.writeAndFlush(downloadStatusMessage);
queue.forEach((gid, galleryTask) -> { queue.entrySet().removeIf(entry -> entry.getValue().is_compress_complete());
if (galleryTask.is_compress_complete())
queue.remove(gid);
});
log.info("任务状态发送完成"); log.info("任务状态发送完成");