Fix minimum sync height

This commit is contained in:
Martin Boehm 2018-03-01 20:20:50 +01:00
parent 9bdb83deff
commit b3d1d449fd
2 changed files with 6 additions and 3 deletions

View File

@ -140,7 +140,7 @@ func main() {
return return
} }
syncWorker, err = db.NewSyncWorker(index, chain, *syncWorkers, *syncChunk, uint32(*blockFrom), *dryRun, chanOsSignal) syncWorker, err = db.NewSyncWorker(index, chain, *syncWorkers, *syncChunk, *blockFrom, *dryRun, chanOsSignal)
if err != nil { if err != nil {
glog.Fatalf("NewSyncWorker %v", err) glog.Fatalf("NewSyncWorker %v", err)
} }

View File

@ -21,14 +21,17 @@ type SyncWorker struct {
} }
// NewSyncWorker creates new SyncWorker and returns its handle // NewSyncWorker creates new SyncWorker and returns its handle
func NewSyncWorker(db *RocksDB, chain *bchain.BitcoinRPC, syncWorkers, syncChunk int, minStartHeight uint32, dryRun bool, chanOsSignal chan os.Signal) (*SyncWorker, error) { func NewSyncWorker(db *RocksDB, chain *bchain.BitcoinRPC, syncWorkers, syncChunk int, minStartHeight int, dryRun bool, chanOsSignal chan os.Signal) (*SyncWorker, error) {
if minStartHeight < 0 {
minStartHeight = 0
}
return &SyncWorker{ return &SyncWorker{
db: db, db: db,
chain: chain, chain: chain,
syncWorkers: syncWorkers, syncWorkers: syncWorkers,
syncChunk: syncChunk, syncChunk: syncChunk,
dryRun: dryRun, dryRun: dryRun,
startHeight: minStartHeight, startHeight: uint32(minStartHeight),
chanOsSignal: chanOsSignal, chanOsSignal: chanOsSignal,
}, nil }, nil
} }