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