func (rtr *router) handleBlockWrite(w http.ResponseWriter, req *http.Request) {
dataSize, _ := strconv.Atoi(req.Header.Get("Content-Length"))
- replicas, _ := strconv.Atoi(req.Header.Get("X-Arvados-Desired-Replicas"))
+ replicas, _ := strconv.Atoi(req.Header.Get(keepclient.XKeepDesiredReplicas))
resp, err := rtr.keepstore.BlockWrite(req.Context(), arvados.BlockWriteOptions{
Hash: mux.Vars(req)["locator"],
Reader: req.Body,
router, cancel := testRouter(c, s.cluster, nil)
defer cancel()
- resp := call(router, "PUT", "http://example/"+fooHash, arvadostest.ActiveTokenV2, []byte("foo"), http.Header{"X-Arvados-Desired-Replicas": []string{"2"}})
+ resp := call(router, "PUT", "http://example/"+fooHash, arvadostest.ActiveTokenV2, []byte("foo"), http.Header{"X-Keep-Desired-Replicas": []string{"2"}})
c.Check(resp.Code, Equals, http.StatusOK)
c.Check(resp.Header().Get("X-Keep-Replicas-Stored"), Equals, "1")
c.Check(sortCommaSeparated(resp.Header().Get("X-Keep-Storage-Classes-Confirmed")), Equals, "testclass1=1")