Backup_Repos/stash
1
0
Fork 0
mirror of https://github.com/stashapp/stash.git synced 2026-05-09 05:05:29 +02:00
Code Issues Projects Releases Wiki Activity

Use mutex for batch fingerprint submissions

Browse source
This commit is contained in:
InfiniteStash 2026-05-02 09:35:56 +02:00
parent afd2a5d5b8
commit 9690928b76
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
internal/api/resolver_mutation_stash_box.go
View file

@ -4,6 +4,7 @@ import (
"context"
"fmt"
"strconv"
"sync"
"time"
"github.com/stashapp/stash/internal/manager"
@ -14,6 +15,8 @@ import (
"github.com/stashapp/stash/pkg/stashbox"
)
var fingerprintSubmissionMu sync.Mutex
func (r *mutationResolver) SubmitStashBoxFingerprints(ctx context.Context, input StashBoxFingerprintSubmissionInput) (bool, error) {
b, err := resolveStashBox(input.StashBoxIndex, input.StashBoxEndpoint) //nolint:staticcheck
if err != nil {
@ -303,7 +306,13 @@ func (r *mutationResolver) SubmitFingerprintSubmissions(ctx context.Context, sta
if len(submissions) > 40 {
// Submit async to avoid timeouts for large batches
go r.submitFingerprintBatch(client, submissions, sceneMap)
if !fingerprintSubmissionMu.TryLock() {
return false, fmt.Errorf("fingerprint submission already in progress")
}
go func() {
defer fingerprintSubmissionMu.Unlock()
r.submitFingerprintBatch(client, submissions, sceneMap)
}()
} else {
r.submitFingerprintBatch(client, submissions, sceneMap)
}