MCPcopy
hub / github.com/ChineseSubFinder/ChineseSubFinder / save

Method save

pkg/task_queue/task_queue.go:391–404  ·  view source on GitHub ↗

save 需要把改变的数据保持到 K/V 数据库中,这个没有锁,所以需要在 Sync 中使用,不对外开放

(taskPriority int)

Source from the content-addressed store, hash-verified

389
390// save 需要把改变的数据保持到 K/V 数据库中,这个没有锁,所以需要在 Sync 中使用,不对外开放
391func (t *TaskQueue) save(taskPriority int) error {
392
393 b, err := t.taskPriorityMapList[taskPriority].ToJSON()
394 if err != nil {
395 return err
396 }
397
398 err = t.center.TaskQueueSave(taskPriority, b)
399 if err != nil {
400 return err
401 }
402
403 return nil
404}
405
406// isExist 是否已经存在,对内,无锁
407func (t *TaskQueue) isExist(jobID string) bool {

Callers 3

AddMethod · 0.95
updateMethod · 0.95
delMethod · 0.95

Calls 1

TaskQueueSaveMethod · 0.80

Tested by

no test coverage detected