fix: stream接口上传小文件，文件内容错误 TencentBlueKing#2835

yaoxuwan · Dec 9, 2024 · 11cc2e0 · 11cc2e0
1 parent f22d686
commit 11cc2e0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/.../boot-fs-server/src/main/kotlin/com/tencent/bkrepo/fs/server/config/RouteConfiguration.kt b/.../boot-fs-server/src/main/kotlin/com/tencent/bkrepo/fs/server/config/RouteConfiguration.kt
@@ -112,7 +112,6 @@ class RouteConfiguration(
         }
 
         "/stream".nest{
-            filter(artifactFileCleanupFilterFunction::filter)
             PUT(DEFAULT_MAPPING_URI, fileOperationsHandler::stream)
             addMetrics(serverMetrics.uploadingCount)
         }

diff --git a/.../src/main/kotlin/com/tencent/bkrepo/fs/server/filter/ArtifactFileCleanupFilterFunction.kt b/.../src/main/kotlin/com/tencent/bkrepo/fs/server/filter/ArtifactFileCleanupFilterFunction.kt
@@ -43,7 +43,6 @@ class ArtifactFileCleanupFilterFunction : CoHandlerFilterFunction {
         try {
             return next(request)
         } finally {
-            logger.info("start clean up")
             cleanup(request)
         }
     }

diff --git a/...ot-fs-server/src/main/kotlin/com/tencent/bkrepo/fs/server/service/FileOperationService.kt b/...ot-fs-server/src/main/kotlin/com/tencent/bkrepo/fs/server/service/FileOperationService.kt
@@ -138,6 +138,9 @@ class FileOperationService(
                 size = reactiveArtifactFile.getSize()
             )
             storageManager.storeBlock(reactiveArtifactFile, blockNode)
+            if (!reactiveArtifactFile.isInMemory()) {
+                reactiveArtifactFile.getFile()?.deleteOnExit()
+            }
             offset.addAndGet(blockSize)
             true
         } else {