libp2p/go-libp2p-peerstore
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-peerstore.git synced 2024-12-27 23:40:16 +08:00
Code Issues Projects Releases Wiki Activity

add benchmark for ClearAddrs.

Browse Source
This commit is contained in:
Raúl Kripalani 2018-09-04 18:02:00 +01:00
parent 9b5c1de960
commit fe732515cd
1 changed files with 21 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
test/benchmarks_suite.go
View File

@ -9,10 +9,10 @@ import (
)
var peerstoreBenchmarks = map[string]func(pstore.Peerstore, chan *peerpair) func(*testing.B){
"AddAddr": benchmarkAddAddr,
"AddAddrs": benchmarkAddAddrs,
"SetAddrs": benchmarkSetAddrs,
"GetAddrs": benchmarkGetAddrs,
"AddAddrs": benchmarkAddAddrs,
"SetAddrs": benchmarkSetAddrs,
"GetAddrs": benchmarkGetAddrs,
"AddAndClearAddrs": benchmarkAddAndClearAddrs,
}
func BenchmarkPeerstore(b *testing.B, factory PeerstoreFactory, variant string) {
@ -51,16 +51,6 @@ func BenchmarkPeerstore(b *testing.B, factory PeerstoreFactory, variant string)
}
}
func benchmarkAddAddr(ps pstore.Peerstore, addrs chan *peerpair) func(*testing.B) {
return func(b *testing.B) {
b.ResetTimer()
for i := 0; i < b.N; i++ {
pp := <-addrs
ps.AddAddr(pp.ID, pp.Addr[0], pstore.PermanentAddrTTL)
}
}
}
func benchmarkAddAddrs(ps pstore.Peerstore, addrs chan *peerpair) func(*testing.B) {
return func(b *testing.B) {
b.ResetTimer()
@ -92,3 +82,20 @@ func benchmarkGetAddrs(ps pstore.Peerstore, addrs chan *peerpair) func(*testing.
}
}
}
func benchmarkAddAndClearAddrs(ps pstore.Peerstore, addrs chan *peerpair) func(*testing.B) {
// 1000 peers.
return func(b *testing.B) {
var peers = make([]*peerpair, 1000)
for i := 0; i < len(peers); peers[i], i = <-addrs, i+1 {
}
b.ResetTimer()
for i := 0; i < b.N; i++ {
for _, pp := range peers {
ps.AddAddrs(pp.ID, pp.Addr, pstore.PermanentAddrTTL)
ps.ClearAddrs(pp.ID)
}
}
}
}