mirror of
https://github.com/terorie/od-database-crawler.git
synced 2025-04-18 01:46:43 +00:00
Make resume work
This commit is contained in:
parent
f3be76e001
commit
24d9d1fd42
@ -245,14 +245,6 @@ func readPauseFile(od *OD, r io.Reader) (err error) {
|
|||||||
if err != nil { return err }
|
if err != nil { return err }
|
||||||
atomic.StoreInt64(&od.InProgress, paused.InProgress)
|
atomic.StoreInt64(&od.InProgress, paused.InProgress)
|
||||||
|
|
||||||
// Check mark
|
|
||||||
var mark [8]byte
|
|
||||||
_, err = io.ReadFull(r, mark[:])
|
|
||||||
if err != nil { return err }
|
|
||||||
if !bytes.Equal(mark[:], []byte("--------")) {
|
|
||||||
return fmt.Errorf("corrupt pause file")
|
|
||||||
}
|
|
||||||
|
|
||||||
err = readPauseStateTree(od, r)
|
err = readPauseStateTree(od, r)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to read state tree: %s", err)
|
return fmt.Errorf("failed to read state tree: %s", err)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user