tcjlj/nezha
1
0
Fork 0
mirror of https://github.com/nezhahq/nezha.git synced 2025-02-02 09:38:13 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

🐛 领取任务超时

Browse Source
This commit is contained in:
naiba 2021-06-12 11:51:26 +08:00
parent 373b95a144
commit 2057922783
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/agent/main.go
View File

@ -134,15 +134,12 @@ func run() {
} }
cancel() cancel()
// 执行 Task // 执行 Task
timeOutCtx, cancel = context.WithTimeout(context.Background(), networkTimeOut) tasks, err := client.RequestTask(context.Background(), monitor.GetHost().PB())
tasks, err := client.RequestTask(timeOutCtx, monitor.GetHost().PB())
if err != nil { if err != nil {
println("client.RequestTask err: ", err) println("client.RequestTask err: ", err)
cancel()
retry() retry()
continue continue
} }
cancel()
err = receiveTasks(tasks) err = receiveTasks(tasks)
println("receiveTasks exit to main: ", err) println("receiveTasks exit to main: ", err)
retry() retry()