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

Connect to newAddress

Browse Source 
Connect to newAddress
This commit is contained in:
Phi 2023-09-23 09:38:53 +02:00
parent b9c29d6ee5
commit 65638ae0c1
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cmd/lotus-worker/main.go
View File

@ -627,7 +627,7 @@ var runCmd = &cli.Command{
Storage: lr, Storage: lr,
} }
log.Info("Setting up control endpoint at " + address) log.Info("Setting up control endpoint at " + newAddress)
timeout, err := time.ParseDuration(cctx.String("http-server-timeout")) timeout, err := time.ParseDuration(cctx.String("http-server-timeout"))
if err != nil { if err != nil {
@ -652,13 +652,13 @@ var runCmd = &cli.Command{
log.Warn("Graceful shutdown successful") log.Warn("Graceful shutdown successful")
}() }()
nl, err := net.Listen("tcp", address) nl, err := net.Listen("tcp", newAddress)
if err != nil { if err != nil {
return err return err
} }
{ {
a, err := net.ResolveTCPAddr("tcp", address) a, err := net.ResolveTCPAddr("tcp", newAddress)
if err != nil { if err != nil {
return xerrors.Errorf("parsing address: %w", err) return xerrors.Errorf("parsing address: %w", err)
} }
@ -739,7 +739,7 @@ var runCmd = &cli.Command{
select { select {
case <-readyCh: case <-readyCh:
if err := nodeApi.WorkerConnect(ctx, "http://"+address+"/rpc/v0"); err != nil { if err := nodeApi.WorkerConnect(ctx, "http://"+newAddress+"/rpc/v0"); err != nil {
log.Errorf("Registering worker failed: %+v", err) log.Errorf("Registering worker failed: %+v", err)
cancel() cancel()
return return
@ -801,6 +801,9 @@ func extractRoutableIP(timeout time.Duration) (string, error) {
} }
minerIP, _ := maddr.ValueForProtocol(multiaddr.P_IP6) minerIP, _ := maddr.ValueForProtocol(multiaddr.P_IP6)
if minerIP == "" {
minerIP, _ = maddr.ValueForProtocol(multiaddr.P_IP4)
}
minerPort, _ := maddr.ValueForProtocol(multiaddr.P_TCP) minerPort, _ := maddr.ValueForProtocol(multiaddr.P_TCP)
// Check if the IP is IPv6 and format the address appropriately // Check if the IP is IPv6 and format the address appropriately