unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 281 Wiki Activity

Add acquire/release to http path

Browse Source
This commit is contained in:
Asim Aslam 2019-10-14 21:52:18 +01:00
parent 745299bce5
commit 854b01c20c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sync/lock/http/http.go
View File

@ -23,7 +23,7 @@ type httpLock struct {
opts lock.Options opts lock.Options
} }
func (h *httpLock) url(id string) (string, error) { func (h *httpLock) url(do, id string) (string, error) {
sum := crc32.ChecksumIEEE([]byte(id)) sum := crc32.ChecksumIEEE([]byte(id))
node := h.opts.Nodes[sum%uint32(len(h.opts.Nodes))] node := h.opts.Nodes[sum%uint32(len(h.opts.Nodes))]
@ -39,7 +39,7 @@ func (h *httpLock) url(id string) (string, error) {
// set path // set path
// build path // build path
path := filepath.Join(DefaultPath, h.opts.Prefix, id) path := filepath.Join(DefaultPath, do, h.opts.Prefix, id)
uri.Path = path uri.Path = path
// return url // return url
@ -52,7 +52,7 @@ func (h *httpLock) Acquire(id string, opts ...lock.AcquireOption) error {
o(&options) o(&options)
} }
uri, err := h.url(id) uri, err := h.url("acquire", id)
if err != nil { if err != nil {
return err return err
} }
@ -85,7 +85,7 @@ func (h *httpLock) Acquire(id string, opts ...lock.AcquireOption) error {
} }
func (h *httpLock) Release(id string) error { func (h *httpLock) Release(id string) error {
uri, err := h.url(id) uri, err := h.url("release", id)
if err != nil { if err != nil {
return err return err
} }