From 10432160d5a04c4ce2d777577fa5e9a9e4802260 Mon Sep 17 00:00:00 2001
From: Olaoluwa Osuntokun <laolu32@gmail.com>
Date: Fri, 17 Nov 2017 15:51:08 -0800
Subject: [PATCH] multi: rebase to upstream, update API's

---
 blockchain/indexers/cfindex.go |  4 ++--
 btcd.go                        |  2 +-
 netsync/interface.go           | 14 +++++++-------
 rpcadapters.go                 |  2 +-
 server.go                      |  8 ++++----
 5 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/blockchain/indexers/cfindex.go b/blockchain/indexers/cfindex.go
index fd53ece0..bd152711 100644
--- a/blockchain/indexers/cfindex.go
+++ b/blockchain/indexers/cfindex.go
@@ -299,6 +299,6 @@ func NewCfIndex(db database.DB, chainParams *chaincfg.Params) *CfIndex {
 }
 
 // DropCfIndex drops the CF index from the provided database if exists.
-func DropCfIndex(db database.DB) error {
-	return dropIndex(db, cfIndexParentBucketKey, cfIndexName)
+func DropCfIndex(db database.DB, interrupt <-chan struct{}) error {
+	return dropIndex(db, cfIndexParentBucketKey, cfIndexName, interrupt)
 }
diff --git a/btcd.go b/btcd.go
index fdcebed3..a0ccb3ea 100644
--- a/btcd.go
+++ b/btcd.go
@@ -136,7 +136,7 @@ func btcdMain(serverChan chan<- *server) error {
 		return nil
 	}
 	if cfg.DropCfIndex {
-		if err := indexers.DropCfIndex(db); err != nil {
+		if err := indexers.DropCfIndex(db, interrupt); err != nil {
 			btcdLog.Errorf("%v", err)
 			return err
 		}
diff --git a/netsync/interface.go b/netsync/interface.go
index 61a230ac..a177cb96 100644
--- a/netsync/interface.go
+++ b/netsync/interface.go
@@ -5,13 +5,13 @@
 package netsync
 
 import (
-	"github.com/btcsuite/btcd/blockchain"
-	"github.com/btcsuite/btcd/chaincfg"
-	"github.com/btcsuite/btcd/chaincfg/chainhash"
-	"github.com/btcsuite/btcd/mempool"
-	"github.com/btcsuite/btcd/peer"
-	"github.com/btcsuite/btcd/wire"
-	"github.com/btcsuite/btcutil"
+	"github.com/roasbeef/btcd/blockchain"
+	"github.com/roasbeef/btcd/chaincfg"
+	"github.com/roasbeef/btcd/chaincfg/chainhash"
+	"github.com/roasbeef/btcd/mempool"
+	"github.com/roasbeef/btcd/peer"
+	"github.com/roasbeef/btcd/wire"
+	"github.com/roasbeef/btcutil"
 )
 
 // PeerNotifier exposes methods to notify peers of status changes to
diff --git a/rpcadapters.go b/rpcadapters.go
index e0af0b09..aee62d13 100644
--- a/rpcadapters.go
+++ b/rpcadapters.go
@@ -7,10 +7,10 @@ package main
 import (
 	"sync/atomic"
 
-	"github.com/Roasbeef/btcd/netsync"
 	"github.com/roasbeef/btcd/blockchain"
 	"github.com/roasbeef/btcd/chaincfg/chainhash"
 	"github.com/roasbeef/btcd/mempool"
+	"github.com/roasbeef/btcd/netsync"
 	"github.com/roasbeef/btcd/peer"
 	"github.com/roasbeef/btcd/wire"
 	"github.com/roasbeef/btcutil"
diff --git a/server.go b/server.go
index 92a3a6ff..b1249148 100644
--- a/server.go
+++ b/server.go
@@ -742,7 +742,7 @@ func (sp *serverPeer) OnGetHeaders(_ *peer.Peer, msg *wire.MsgGetHeaders) {
 // OnGetCFilter is invoked when a peer receives a getcfilter bitcoin message.
 func (sp *serverPeer) OnGetCFilter(_ *peer.Peer, msg *wire.MsgGetCFilter) {
 	// Ignore getcfilter requests if not in sync.
-	if !sp.server.blockManager.IsCurrent() {
+	if !sp.server.syncManager.IsCurrent() {
 		return
 	}
 
@@ -764,12 +764,12 @@ func (sp *serverPeer) OnGetCFilter(_ *peer.Peer, msg *wire.MsgGetCFilter) {
 // OnGetCFHeaders is invoked when a peer receives a getcfheader bitcoin message.
 func (sp *serverPeer) OnGetCFHeaders(_ *peer.Peer, msg *wire.MsgGetCFHeaders) {
 	// Ignore getcfilterheader requests if not in sync.
-	if !sp.server.blockManager.IsCurrent() {
+	if !sp.server.syncManager.IsCurrent() {
 		return
 	}
 
 	// Attempt to look up the height of the provided stop hash.
-	chain := sp.server.blockManager.chain
+	chain := sp.server.chain
 	endIdx := int32(math.MaxInt32)
 	height, err := chain.BlockHeightByHash(&msg.HashStop)
 	if err == nil {
@@ -877,7 +877,7 @@ func (sp *serverPeer) OnGetCFHeaders(_ *peer.Peer, msg *wire.MsgGetCFHeaders) {
 func (sp *serverPeer) OnGetCFTypes(_ *peer.Peer, msg *wire.MsgGetCFTypes) {
 	// Ignore getcftypes requests if cfg.NoCFilters is set or we're not in
 	// sync.
-	if cfg.NoCFilters || !sp.server.blockManager.IsCurrent() {
+	if cfg.NoCFilters || !sp.server.syncManager.IsCurrent() {
 		return
 	}