LamGC/scext-onedrive-transfer
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: 为回调增加异常捕获, 以避免因回调抛出异常而打断上传任务.

Browse Source
This commit is contained in:
LamGC 2024-01-11 00:48:44 +08:00
parent 43b9d5f182
commit 98e256f4db
Signed by: LamGC
GPG Key ID: 6C5AE2A913941E1D
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/kotlin/OneDriveTransferCenter.kt
View File

@ -131,9 +131,18 @@ class OneDriveTransferTaskExecutor(
threadStatusMap[id] = progress threadStatusMap[id] = progress
try { try {
callback.onTransferStart(progress) callback.onTransferStart(progress)
} catch (e: Exception) {
logger.warn(e) { "OneDrive 中转任务开始回调失败: ${e.message}" }
}
try {
doTransferFile(task, progress) doTransferFile(task, progress)
logger.info { "OneDrive 中转任务执行成功: ${task.document.fileName}" } logger.info { "OneDrive 中转任务执行成功: ${task.document.fileName}" }
callback.onTransferSuccess(task, progress) try {
callback.onTransferSuccess(task, progress)
} catch (e: Exception) {
logger.warn(e) { "OneDrive 中转任务成功回调失败: ${e.message}" }
}
} catch (e: Exception) { } catch (e: Exception) {
logger.warn(e) { "OneDrive 中转任务执行失败: ${e.message}" } logger.warn(e) { "OneDrive 中转任务执行失败: ${e.message}" }
callback.onTransferFailure(task, progress.apply { callback.onTransferFailure(task, progress.apply {