coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-03-12 19:57:55 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

fix prioritization of stream muxers

Browse Source
This commit is contained in:
Marten Seemann 2022-02-25 11:44:47 +04:00
parent 3ea5631f9a
commit ec46f1e6e4
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/node/libp2p/libp2p.go
View File

@ -58,7 +58,7 @@ type priorityOption struct {
func prioritizeOptions(opts []priorityOption) libp2p.Option {
type popt struct {
priority int64
priority int64 // lower priority values mean higher priority
opt libp2p.Option
}
enabledOptions := make([]popt, 0, len(opts))
@ -71,7 +71,7 @@ func prioritizeOptions(opts []priorityOption) libp2p.Option {
}
}
sort.Slice(enabledOptions, func(i, j int) bool {
return enabledOptions[i].priority > enabledOptions[j].priority
return enabledOptions[i].priority < enabledOptions[j].priority
})
p2pOpts := make([]libp2p.Option, len(enabledOptions))
for i, opt := range enabledOptions {

4
core/node/libp2p/sec.go
View File

@ -30,11 +30,11 @@ func Security(enabled bool, tptConfig config.Transports) interface{} {
return func() (opts Libp2pOpts) {
opts.Opts = append(opts.Opts, prioritizeOptions([]priorityOption{{
priority: tptConfig.Security.TLS,
defaultPriority: 100,
defaultPriority: 200,
opt: libp2p.Security(tls.ID, tls.New),
}, {
priority: tptConfig.Security.Noise,
defaultPriority: 300,
defaultPriority: 100,
opt: libp2p.Security(noise.ID, noise.New),
}}))
return opts