coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-02-25 12:27:43 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

fix ipfs swarm peering crash in offline mode (#9261)

Browse Source
This commit is contained in:
Yann Autissier 2022-10-13 14:43:06 +00:00 committed by GitHub
parent 066a0b9cab
commit b5fe824964
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/commands/swarm.go
View File

@ -123,6 +123,9 @@ var swarmPeeringAddCmd = &cmds.Command{
if err != nil {
return err
}
if !node.IsOnline {
return ErrNotOnline
}
for _, addrinfo := range addInfos {
node.Peering.AddPeer(addrinfo)
@ -154,6 +157,10 @@ var swarmPeeringLsCmd = &cmds.Command{
if err != nil {
return err
}
if !node.IsOnline {
return ErrNotOnline
}
peers := node.Peering.ListPeers()
return cmds.EmitOnce(res, addrInfos{Peers: peers})
},
@ -190,6 +197,9 @@ var swarmPeeringRmCmd = &cmds.Command{
if err != nil {
return err
}
if !node.IsOnline {
return ErrNotOnline
}
for _, arg := range req.Arguments {
id, err := peer.Decode(arg)
@ -207,7 +217,7 @@ var swarmPeeringRmCmd = &cmds.Command{
Type: peeringResult{},
Encoders: cmds.EncoderMap{
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, pr *peeringResult) error {
fmt.Fprintf(w, "add %s %s\n", pr.ID.String(), pr.Status)
fmt.Fprintf(w, "remove %s %s\n", pr.ID.String(), pr.Status)
return nil
}),
},
@ -853,7 +863,7 @@ Filters default to those specified under the "Swarm.AddrFilters" config key.
return err
}
if n.PeerHost == nil {
if !n.IsOnline {
return ErrNotOnline
}
@ -889,7 +899,7 @@ var swarmFiltersAddCmd = &cmds.Command{
return err
}
if n.PeerHost == nil {
if !n.IsOnline {
return ErrNotOnline
}
@ -945,7 +955,7 @@ var swarmFiltersRmCmd = &cmds.Command{
return err
}
if n.PeerHost == nil {
if !n.IsOnline {
return ErrNotOnline
}