MiscMirror/gossa
1
0
Fork 0
mirror of https://github.com/pldubouilh/gossa.git synced 2026-09-03 15:47:45 -04:00
Code Issues Packages Projects Releases Wiki Activity

lock global

Browse Source
This commit is contained in:
Pierre Dubouilh
2019-09-12 21:23:06 +02:00
parent 39d2d4b13f
commit da7f60d5fc
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/gossa.go
+7
View File
@@ -17,6 +17,7 @@ import (
"path/filepath" "path/filepath"
"strconv" "strconv"
"strings" "strings"
"sync"
) )
var host = flag.String("h", "127.0.0.1", "host to listen to") var host = flag.String("h", "127.0.0.1", "host to listen to")
@@ -29,6 +30,8 @@ var skipHidden = flag.Bool("k", true, "skip hidden files")
var initPath = "." var initPath = "."
var historyPath = "" var historyPath = ""
var state = make(map[string]string) var state = make(map[string]string)
var stateLock = sync.RWMutex{}
var fs http.Handler var fs http.Handler
var page, _ = template.New("pageTemplate").Parse(`template_will_be_here`) var page, _ = template.New("pageTemplate").Parse(`template_will_be_here`)
@@ -97,7 +100,9 @@ func replyList(w http.ResponseWriter, r *http.Request, fullPath string, path str
} }
p.ExtraPath = template.HTML(html.EscapeString(*extraPath)) p.ExtraPath = template.HTML(html.EscapeString(*extraPath))
p.Title = template.HTML(html.EscapeString(title)) p.Title = template.HTML(html.EscapeString(title))
stateLock.Lock()
loc := state[hash(r.Header.Get("Authorization")+path)] loc := state[hash(r.Header.Get("Authorization")+path)]
stateLock.Unlock()
for _, el := range _files { for _, el := range _files {
if *skipHidden && strings.HasPrefix(el.Name(), ".") { if *skipHidden && strings.HasPrefix(el.Name(), ".") {
@@ -155,6 +160,8 @@ func rpc(w http.ResponseWriter, r *http.Request) {
json.Unmarshal(bodyBytes, &rpc) json.Unmarshal(bodyBytes, &rpc)
defer exitPath(w, "rpc", rpc) defer exitPath(w, "rpc", rpc)
ret := "ok" ret := "ok"
stateLock.Lock()
defer stateLock.Unlock()
if rpc.Call == "mkdirp" { if rpc.Call == "mkdirp" {
err = os.MkdirAll(checkPath(rpc.Args[0]), os.ModePerm) err = os.MkdirAll(checkPath(rpc.Args[0]), os.ModePerm)