mirror of
https://github.com/stashapp/stash.git
synced 2025-12-18 12:54:38 +03:00
Fix gallery zip scan context (#3433)
* fix zip scan context * move ValueOnlyContext to utils, use it for zipCtx
This commit is contained in:
@@ -14,6 +14,7 @@ import (
|
|||||||
"github.com/remeh/sizedwaitgroup"
|
"github.com/remeh/sizedwaitgroup"
|
||||||
"github.com/stashapp/stash/pkg/logger"
|
"github.com/stashapp/stash/pkg/logger"
|
||||||
"github.com/stashapp/stash/pkg/txn"
|
"github.com/stashapp/stash/pkg/txn"
|
||||||
|
"github.com/stashapp/stash/pkg/utils"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@@ -574,7 +575,7 @@ func (s *scanJob) handleFile(ctx context.Context, f scanFile) error {
|
|||||||
// scan zip files with a different context that is not cancellable
|
// scan zip files with a different context that is not cancellable
|
||||||
// cancelling while scanning zip file contents results in the scan
|
// cancelling while scanning zip file contents results in the scan
|
||||||
// contents being partially completed
|
// contents being partially completed
|
||||||
zipCtx := context.Background()
|
zipCtx := utils.ValueOnlyContext{Context: ctx}
|
||||||
|
|
||||||
if err := s.scanZipFile(zipCtx, f); err != nil {
|
if err := s.scanZipFile(zipCtx, f); err != nil {
|
||||||
logger.Errorf("Error scanning zip file %q: %v", f.Path, err)
|
logger.Errorf("Error scanning zip file %q: %v", f.Path, err)
|
||||||
|
|||||||
@@ -1,22 +0,0 @@
|
|||||||
package job
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
type valueOnlyContext struct {
|
|
||||||
context.Context
|
|
||||||
}
|
|
||||||
|
|
||||||
func (valueOnlyContext) Deadline() (deadline time.Time, ok bool) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (valueOnlyContext) Done() <-chan struct{} {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (valueOnlyContext) Err() error {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
@@ -7,6 +7,7 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/stashapp/stash/pkg/logger"
|
"github.com/stashapp/stash/pkg/logger"
|
||||||
|
"github.com/stashapp/stash/pkg/utils"
|
||||||
)
|
)
|
||||||
|
|
||||||
const maxGraveyardSize = 10
|
const maxGraveyardSize = 10
|
||||||
@@ -178,7 +179,7 @@ func (m *Manager) dispatch(ctx context.Context, j *Job) (done chan struct{}) {
|
|||||||
j.StartTime = &t
|
j.StartTime = &t
|
||||||
j.Status = StatusRunning
|
j.Status = StatusRunning
|
||||||
|
|
||||||
ctx, cancelFunc := context.WithCancel(valueOnlyContext{ctx})
|
ctx, cancelFunc := context.WithCancel(utils.ValueOnlyContext{Context: ctx})
|
||||||
j.cancelFunc = cancelFunc
|
j.cancelFunc = cancelFunc
|
||||||
|
|
||||||
done = make(chan struct{})
|
done = make(chan struct{})
|
||||||
|
|||||||
22
pkg/utils/context.go
Normal file
22
pkg/utils/context.go
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
package utils
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ValueOnlyContext struct {
|
||||||
|
context.Context
|
||||||
|
}
|
||||||
|
|
||||||
|
func (ValueOnlyContext) Deadline() (deadline time.Time, ok bool) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (ValueOnlyContext) Done() <-chan struct{} {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (ValueOnlyContext) Err() error {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user