LumeWeb
/
portal
1
0
Fork 0
Code Issues 5 Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:775d3f7e6ffc5a55f475a8b86a42db1f27ab81bb
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.1.0-develop.3
LumeWeb:v0.1.0-develop.2
LumeWeb:v0.1.0-develop.1
LumeWeb:v0.0.1
...
compare: LumeWeb:9254dc20c8db6e09cb32025631719277138d2828
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.1.0-develop.3
LumeWeb:v0.1.0-develop.2
LumeWeb:v0.1.0-develop.1
LumeWeb:v0.0.1

2 Commits
775d3f7e6f ... 9254dc20c8

Author SHA1 Message Date
Derrick Hammer 9254dc20c8
fix: use decodedHash.HashBytes() 2024-03-28 21:48:13 -04:00
Derrick Hammer fffe769ccf
fix: use mapKey as a string 2024-03-28 21:47:48 -04:00
1 changed files with 5 additions and 4 deletions
Show Stats Expand all files Collapse all files

9
protocols/s5/tus.go
View File

@ -496,11 +496,12 @@ func (t *TusHandler) worker() {
mapKey := append([]byte{}, decodedHash.HashBytes()...)
mapKey = append(mapKey, []byte(info.Upload.ID)...)
if _, ok := t.uploadMutexMap.Load(mapKey); !ok {
t.uploadMutexMap.Store(mapKey, &sync.Mutex{})
mapKeyStr := string(mapKey)
if _, ok := t.uploadMutexMap.Load(mapKeyStr); !ok {
t.uploadMutexMap.Store(mapKeyStr, &sync.Mutex{})
}
mutex, _ := t.uploadMutexMap.Load(mapKey)
mutex, _ := t.uploadMutexMap.Load(mapKeyStr)
mutex.(*sync.Mutex).Lock()
exists, _ := t.UploadExists(ctx, decodedHash.HashBytes())
@ -511,7 +512,7 @@ func (t *TusHandler) worker() {
continue
}
_, err = t.CreateUpload(ctx, mapKey, info.Upload.ID, uploaderID, uploaderIP, t.storageProtocol.Name())
_, err = t.CreateUpload(ctx, decodedHash.HashBytes(), info.Upload.ID, uploaderID, uploaderIP, t.storageProtocol.Name())
mutex.(*sync.Mutex).Unlock()
if err != nil {
errorResponse.Body = "Could not create tus upload"