netsync: add txs msg (#78)

[bytom/vapor.git] / netsync / tx_keeper.go

diff --git a/netsync/tx_keeper.go b/netsync/tx_keeper.go
index 6c4a8bb..5b95ba9 100644 (file)
--- a/netsync/tx_keeper.go
+++ b/netsync/tx_keeper.go
@@ -100,8 +100,8 @@ func (sm *SyncManager) txSyncLoop() {
                }).Debug("txSyncLoop sending transactions")
                sending = true
                go func() {
-                       ok, err := peer.sendTransactions(sendTxs)
-                       if !ok {
+                       err := peer.sendTransactions(sendTxs)
+                       if err != nil {
                                sm.peers.removePeer(msg.peerID)
                        }
                        done <- err