release_handler.go 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package v2
  2. import (
  3. "path"
  4. "net/http"
  5. "github.com/gorilla/mux"
  6. )
  7. // releaseLockHandler deletes the lock.
  8. func (h *handler) releaseLockHandler(w http.ResponseWriter, req *http.Request) {
  9. h.client.SyncCluster()
  10. vars := mux.Vars(req)
  11. keypath := path.Join(prefix, vars["key"])
  12. // Read index and value parameters.
  13. index := req.FormValue("index")
  14. value := req.FormValue("value")
  15. if len(index) == 0 && len(value) == 0 {
  16. http.Error(w, "release lock error: index or value required", http.StatusInternalServerError)
  17. return
  18. } else if len(index) != 0 && len(value) != 0 {
  19. http.Error(w, "release lock error: index and value cannot both be specified", http.StatusInternalServerError)
  20. return
  21. }
  22. // Look up index by value if index is missing.
  23. if len(index) == 0 {
  24. resp, err := h.client.Get(keypath, true, true)
  25. if err != nil {
  26. http.Error(w, "release lock index error: " + err.Error(), http.StatusInternalServerError)
  27. return
  28. }
  29. nodes := lockNodes{resp.Node.Nodes}
  30. node := nodes.FindByValue(value)
  31. if node == nil {
  32. http.Error(w, "release lock error: cannot find: " + value, http.StatusInternalServerError)
  33. return
  34. }
  35. index = path.Base(node.Key)
  36. }
  37. // Delete the lock.
  38. _, err := h.client.Delete(path.Join(keypath, index), false)
  39. if err != nil {
  40. http.Error(w, "release lock error: " + err.Error(), http.StatusInternalServerError)
  41. return
  42. }
  43. }