Skip to content

Commit d767e30

Browse files
authored
Merge pull request #11 from travisperson/fix/node-connection-issues
fix: node connection issues
2 parents a66499b + 4882a12 commit d767e30

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

cmd/filsnap/cmds/create.go

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,11 @@ package cmds
22

33
import (
44
"context"
5+
"errors"
56
"fmt"
67
"io"
78
"io/ioutil"
9+
"syscall"
810
"time"
911

1012
"github.com/filecoin-project/go-state-types/abi"
@@ -153,6 +155,11 @@ var cmdCreate = &cli.Command{
153155
for _, addr := range addrs {
154156
node, closer, err := CreateLotusClient(ctx, addr)
155157
if err != nil {
158+
if errors.Is(err, syscall.ECONNREFUSED) {
159+
logger.Warnw("failed to dial node", "err", err)
160+
continue
161+
}
162+
156163
return err
157164
}
158165

@@ -161,6 +168,10 @@ var cmdCreate = &cli.Command{
161168
nodes = append(nodes, node)
162169
}
163170

171+
if len(nodes) == 0 {
172+
return xerrors.Errorf("no nodes")
173+
}
174+
164175
cm := consensus.NewConsensusManager(nodes)
165176

166177
same, err := cm.CheckGenesis(ctx)

pkg/export/export.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,7 @@ func (e *Export) done() {
128128
}
129129

130130
func (e *Export) Export(ctx context.Context) error {
131+
defer e.done()
131132
if err := e.node.Shutdown(ctx); err != nil {
132133
return err
133134
}
@@ -145,8 +146,6 @@ func (e *Export) Export(ctx context.Context) error {
145146
return err
146147
}
147148

148-
defer e.done()
149-
150149
var last bool
151150
for b := range stream {
152151
last = e.update(len(b)) == 0

0 commit comments

Comments
 (0)