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

删除任务时清理节点下载队列

Browse Source
This commit is contained in:
root 2026-07-11 13:31:14 +08:00
parent 6447a74e0c
commit 3ab82509a0
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -171,7 +171,16 @@ public class storageNode {
} }
case AbstractMessage.DELETE_GALLERY_MESSAGE -> { case AbstractMessage.DELETE_GALLERY_MESSAGE -> {
DeleteGalleryMessage deleteGalleryMessage = (DeleteGalleryMessage) abstractMessage; DeleteGalleryMessage deleteGalleryMessage = (DeleteGalleryMessage) abstractMessage;
byte result = DeleteService.deleteAll(storagePath + deleteGalleryMessage.getGalleryName()); String galleryName = deleteGalleryMessage.getGalleryName();
lock.lock();
try {
// 删除任务时也要从待下载队列移除，避免继续向主站上报已经删除的任务状态。
storageNode.this.queue.entrySet().removeIf(entry -> galleryName.equals(entry.getValue().getName()));
queue.entrySet().removeIf(entry -> galleryName.equals(entry.getValue().getName()));
} finally {
lock.unlock();
}
byte result = DeleteService.deleteAll(storagePath + galleryName);
ResponseMessage responseMessage = new ResponseMessage(deleteGalleryMessage.messageId, result); ResponseMessage responseMessage = new ResponseMessage(deleteGalleryMessage.messageId, result);
ctx.writeAndFlush(responseMessage); ctx.writeAndFlush(responseMessage);
} }