cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

worker: Better miner connectivity check on startup

Browse Source
This commit is contained in:
Łukasz Magiera 2020-10-18 19:53:23 +02:00
parent 8c86ea6b75
commit 1a10f95973
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/lotus-seal-worker/main.go
View File

@ -172,13 +172,18 @@ var runCmd = &cli.Command{
} }
// Connect to storage-miner // Connect to storage-miner
ctx := lcli.ReqContext(cctx)
var nodeApi api.StorageMiner var nodeApi api.StorageMiner
var closer func() var closer func()
var err error var err error
for { for {
nodeApi, closer, err = lcli.GetStorageMinerAPI(cctx, lcli.StorageMinerUseHttp) nodeApi, closer, err = lcli.GetStorageMinerAPI(cctx, lcli.StorageMinerUseHttp)
if err == nil { if err == nil {
break _, err = nodeApi.Version(ctx)
if err == nil {
break
}
} }
fmt.Printf("\r\x1b[0KConnecting to miner API... (%s)", err) fmt.Printf("\r\x1b[0KConnecting to miner API... (%s)", err)
time.Sleep(time.Second) time.Sleep(time.Second)
@ -186,7 +191,6 @@ var runCmd = &cli.Command{
} }
defer closer() defer closer()
ctx := lcli.ReqContext(cctx)
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(ctx)
defer cancel() defer cancel()