debug(bugcollect): 添加 flush 日志排查上传流程
这个提交包含在:
父节点
3f03f5c1de
当前提交
64580b4b9e
@ -111,7 +111,10 @@ internal class LogQueue(
|
|||||||
|
|
||||||
private fun flush() {
|
private fun flush() {
|
||||||
// URL 未就绪时跳过,等下次定时 flush
|
// URL 未就绪时跳过,等下次定时 flush
|
||||||
if (logApiUrl.isBlank()) return
|
if (logApiUrl.isBlank()) {
|
||||||
|
Log.d(TAG, "flush: URL blank, skipping")
|
||||||
|
return
|
||||||
|
}
|
||||||
val issues: List<IssueEvent>
|
val issues: List<IssueEvent>
|
||||||
val events: List<LogEvent>
|
val events: List<LogEvent>
|
||||||
synchronized(lock) {
|
synchronized(lock) {
|
||||||
@ -121,6 +124,7 @@ internal class LogQueue(
|
|||||||
pendingIssues.clear()
|
pendingIssues.clear()
|
||||||
pendingEvents.clear()
|
pendingEvents.clear()
|
||||||
}
|
}
|
||||||
|
Log.d(TAG, "flush: uploading ${issues.size} issues, ${events.size} events, url=$logApiUrl")
|
||||||
if (issues.isNotEmpty()) {
|
if (issues.isNotEmpty()) {
|
||||||
scope.launch {
|
scope.launch {
|
||||||
runCatching { LogUploader.uploadIssues(logApiUrl, issues) }
|
runCatching { LogUploader.uploadIssues(logApiUrl, issues) }
|
||||||
|
|||||||
正在加载...
在新工单中引用
屏蔽一个用户