diff --git a/.dockerignore b/.dockerignore index 2fbde460..3253b19e 100644 --- a/.dockerignore +++ b/.dockerignore @@ -1,2 +1 @@ -Dockerfile -Dockerfile-* +Dockerfile* diff --git a/api/rest/restapi.go b/api/rest/restapi.go index c76f89bc..bcab9b27 100644 --- a/api/rest/restapi.go +++ b/api/rest/restapi.go @@ -378,22 +378,22 @@ func (api *API) peerRemoveHandler(w http.ResponseWriter, r *http.Request) { } func (api *API) pinHandler(w http.ResponseWriter, r *http.Request) { - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { err := api.rpcClient.Call("", "Cluster", "Pin", - c, + ps, &struct{}{}) sendAcceptedResponse(w, err) } } func (api *API) unpinHandler(w http.ResponseWriter, r *http.Request) { - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { err := api.rpcClient.Call("", "Cluster", "Unpin", - c, + ps, &struct{}{}) sendAcceptedResponse(w, err) } @@ -410,12 +410,12 @@ func (api *API) allocationsHandler(w http.ResponseWriter, r *http.Request) { } func (api *API) allocationHandler(w http.ResponseWriter, r *http.Request) { - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { var pin types.PinSerial err := api.rpcClient.Call("", "Cluster", "PinGet", - c, + ps, &pin) if err != nil { // errors here are 404s sendErrorResponse(w, 404, err.Error()) @@ -452,13 +452,13 @@ func (api *API) statusHandler(w http.ResponseWriter, r *http.Request) { queryValues := r.URL.Query() local := queryValues.Get("local") - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { if local == "true" { var pinInfo types.PinInfoSerial err := api.rpcClient.Call("", "Cluster", "StatusLocal", - c, + ps, &pinInfo) sendResponse(w, err, pinInfoToGlobal(pinInfo)) } else { @@ -466,7 +466,7 @@ func (api *API) statusHandler(w http.ResponseWriter, r *http.Request) { err := api.rpcClient.Call("", "Cluster", "Status", - c, + ps, &pinInfo) sendResponse(w, err, pinInfo) } @@ -500,13 +500,13 @@ func (api *API) syncHandler(w http.ResponseWriter, r *http.Request) { queryValues := r.URL.Query() local := queryValues.Get("local") - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { if local == "true" { var pinInfo types.PinInfoSerial err := api.rpcClient.Call("", "Cluster", "SyncLocal", - c, + ps, &pinInfo) sendResponse(w, err, pinInfoToGlobal(pinInfo)) } else { @@ -514,7 +514,7 @@ func (api *API) syncHandler(w http.ResponseWriter, r *http.Request) { err := api.rpcClient.Call("", "Cluster", "Sync", - c, + ps, &pinInfo) sendResponse(w, err, pinInfo) } @@ -541,13 +541,13 @@ func (api *API) recoverHandler(w http.ResponseWriter, r *http.Request) { queryValues := r.URL.Query() local := queryValues.Get("local") - if c := parseCidOrError(w, r); c.Cid != "" { + if ps := parseCidOrError(w, r); ps.Cid != "" { if local == "true" { var pinInfo types.PinInfoSerial err := api.rpcClient.Call("", "Cluster", "RecoverLocal", - c, + ps, &pinInfo) sendResponse(w, err, pinInfoToGlobal(pinInfo)) } else { @@ -555,7 +555,7 @@ func (api *API) recoverHandler(w http.ResponseWriter, r *http.Request) { err := api.rpcClient.Call("", "Cluster", "Recover", - c, + ps, &pinInfo) sendResponse(w, err, pinInfo) } diff --git a/cluster.go b/cluster.go index 4be78b46..baf34fbb 100644 --- a/cluster.go +++ b/cluster.go @@ -883,7 +883,7 @@ func (c *Cluster) SyncAllLocal() ([]api.PinInfo, error) { return syncedItems, err } -// Sync triggers a LocalSyncCid() operation for a given Cid +// Sync triggers a SyncLocal() operation for a given Cid. // in all cluster peers. func (c *Cluster) Sync(h *cid.Cid) (api.GlobalPinInfo, error) { return c.globalPinInfoCid("SyncLocal", h) diff --git a/ipfs-cluster-ctl/main.go b/ipfs-cluster-ctl/main.go index 9340afe8..0decc3c7 100644 --- a/ipfs-cluster-ctl/main.go +++ b/ipfs-cluster-ctl/main.go @@ -402,7 +402,7 @@ error state, usually because the IPFS pin or unpin operation has failed. The command will wait for any operations to succeed and will return the status of the item upon completion. Note that, when running on the full sets of tracked -CIDs (without argument), it may take considerable long time. +CIDs (without argument), it may take a considerably long time. When the --local flag is passed, it will only trigger recover operations on the contacted peer (as opposed to on every peer).