mirror of
https://github.com/ipfs/kubo.git
synced 2026-03-02 23:08:07 +08:00
remove addCloser
This commit is contained in:
parent
dc80116d76
commit
eb228eb615
23
core/core.go
23
core/core.go
@ -295,24 +295,25 @@ func (n *IpfsNode) teardown() error {
|
||||
n.Exchange,
|
||||
n.Repo,
|
||||
}
|
||||
addCloser := func(c io.Closer) { // use when field may be nil
|
||||
if c != nil {
|
||||
closers = append(closers, c)
|
||||
}
|
||||
}
|
||||
|
||||
if n.Blocks != nil {
|
||||
addCloser(n.Blocks)
|
||||
closers = append(closers, n.Blocks)
|
||||
}
|
||||
if n.IpnsFs != nil {
|
||||
addCloser(n.IpnsFs)
|
||||
closers = append(closers, n.IpnsFs)
|
||||
}
|
||||
|
||||
addCloser(n.Bootstrapper)
|
||||
if dht, ok := n.Routing.(*dht.IpfsDHT); ok {
|
||||
addCloser(dht)
|
||||
if n.Bootstrapper != nil {
|
||||
closers = append(closers, n.Bootstrapper)
|
||||
}
|
||||
|
||||
if dht, ok := n.Routing.(*dht.IpfsDHT); ok {
|
||||
closers = append(closers, dht)
|
||||
}
|
||||
|
||||
if n.PeerHost != nil {
|
||||
closers = append(closers, n.PeerHost)
|
||||
}
|
||||
addCloser(n.PeerHost)
|
||||
|
||||
var errs []error
|
||||
for _, closer := range closers {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user