Function proxyListSortHandler

dsort/handler.go:137–183

GET /v1/sort?regex=...

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

// GET /v1/sort?regex=...
func proxyListSortHandler(w http.ResponseWriter, r *http.Request) {
	var (
		query    = r.URL.Query()
		regexStr = query.Get(apc.QparamRegex)
	)
	if _, err := regexp.CompilePOSIX(regexStr); err != nil {
		cmn.WriteErr(w, r, err)
		return
	}

	path := apc.URLPathdSortList.S
	responses := broadcastTargets(http.MethodGet, path, query, nil, ctx.smapOwner.Get())

	resultList := make([]*JobInfo, 0)
	for _, r := range responses {
		if r.err != nil {
			glog.Error(r.err)
			continue
		}
		var newMetrics []*JobInfo
		err := jsoniter.Unmarshal(r.res, &newMetrics)
		cos.AssertNoErr(err)

		for _, v := range newMetrics {
			found := false
			for _, oldMetric := range resultList {
				if oldMetric.ID == v.ID {
					oldMetric.Aggregate(v)
					found = true
					break
				}
			}

			if !found {
				resultList = append(resultList, v)
			}
		}
	}

	body := cos.MustMarshal(resultList)
	if _, err := w.Write(body); err != nil {
		glog.Error(err)
		// When we fail write we cannot call InvalidHandler since it will be
		// double header write.
		return
	}
}

// GET /v1/sort?id=...
func proxyMetricsSortHandler(w http.ResponseWriter, r *http.Request) {