Function proxyMetricsSortHandler

dsort/handler.go:186–227

GET /v1/sort?id=...

(w http.ResponseWriter, r *http.Request)

// GET /v1/sort?id=...
func proxyMetricsSortHandler(w http.ResponseWriter, r *http.Request) {
	var (
		smap        = ctx.smapOwner.Get()
		query       = r.URL.Query()
		managerUUID = query.Get(apc.QparamUUID)
		path        = apc.URLPathdSortMetrics.Join(managerUUID)
		responses   = broadcastTargets(http.MethodGet, path, nil, nil, smap)
	)

	notFound := 0
	allMetrics := make(map[string]*Metrics, smap.CountActiveTargets())
	for _, resp := range responses {
		if resp.statusCode == http.StatusNotFound {
			// Probably new target which does not know anything about this dsort op.
			notFound++
			continue
		}
		if resp.err != nil {
			cmn.WriteErr(w, r, resp.err, resp.statusCode)
			return
		}
		metrics := &Metrics{}
		if err := js.Unmarshal(resp.res, &metrics); err != nil {
			cmn.WriteErr(w, r, err, http.StatusInternalServerError)
			return
		}
		allMetrics[resp.si.ID()] = metrics
	}

	if notFound == len(responses) && notFound > 0 {
		msg := fmt.Sprintf("%s job %q not found", DSortName, managerUUID)
		cmn.WriteErrMsg(w, r, msg, http.StatusNotFound)
		return
	}

	body, err := js.Marshal(allMetrics)
	if err != nil {
		cmn.WriteErr(w, r, err, http.StatusInternalServerError)
		return
	}
	w.Write(body)
}

// DELETE /v1/sort/abort
func ProxyAbortSortHandler(w http.ResponseWriter, r *http.Request) {