diff --git a/blockbook.go b/blockbook.go index cffe57fa..9d62cd89 100644 --- a/blockbook.go +++ b/blockbook.go @@ -140,7 +140,7 @@ func main() { 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 { glog.Fatalf("NewSyncWorker %v", err) } diff --git a/db/sync.go b/db/sync.go index b96cb572..6b96962b 100644 --- a/db/sync.go +++ b/db/sync.go @@ -21,14 +21,17 @@ type SyncWorker struct { } // 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{ db: db, chain: chain, syncWorkers: syncWorkers, syncChunk: syncChunk, dryRun: dryRun, - startHeight: minStartHeight, + startHeight: uint32(minStartHeight), chanOsSignal: chanOsSignal, }, nil }