MCPcopy
hub / github.com/NVIDIA/aistore / handleStatus

Method handleStatus

downloader/dispatcher.go:451–484  ·  view source on GitHub ↗
(req *request)

Source from the content-addressed store, hash-verified

449}
450
451func (d *dispatcher) handleStatus(req *request) {
452 var (
453 finishedTasks []TaskDlInfo
454 dlErrors []TaskErrInfo
455 )
456
457 jInfo, err := d.parent.checkJob(req)
458 if err != nil {
459 return
460 }
461
462 currentTasks := d.activeTasks(req.id)
463 if !req.onlyActive {
464 finishedTasks, err = dlStore.getTasks(req.id)
465 if err != nil {
466 req.writeErrResp(err, http.StatusInternalServerError)
467 return
468 }
469
470 dlErrors, err = dlStore.getErrors(req.id)
471 if err != nil {
472 req.writeErrResp(err, http.StatusInternalServerError)
473 return
474 }
475 sort.Sort(TaskErrByName(dlErrors))
476 }
477
478 req.writeResp(&DlStatusResp{
479 DlJobInfo: jInfo.ToDlJobInfo(),
480 CurrentTasks: currentTasks,
481 FinishedTasks: finishedTasks,
482 Errs: dlErrors,
483 })
484}
485
486func _handleList(req *request) {
487 records := dlStore.getList(req.regex)

Callers 1

dispatchAdminReqMethod · 0.95

Calls 8

activeTasksMethod · 0.95
TaskErrByNameTypeAlias · 0.85
checkJobMethod · 0.80
getTasksMethod · 0.80
writeErrRespMethod · 0.80
getErrorsMethod · 0.80
writeRespMethod · 0.80
ToDlJobInfoMethod · 0.80

Tested by

no test coverage detected