Skip to content

Commit

Permalink
fix benchmarks_test.go
Browse files Browse the repository at this point in the history
  • Loading branch information
fionera committed Oct 16, 2023
1 parent 0015f9f commit 5ed2a0e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions spop/benchmarks/benchmarks_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ func (d *Dispatcher) ServeCriteo(messages *criteo.MessageIterator) ([]criteo.Act
return nil, nil
}

func (d *Dispatcher) Servedropmorepackets(w *encoding.ActionWriter, m *encoding.Message) {
func (d *Dispatcher) ServeDropMorePacket(w *encoding.ActionWriter, m *encoding.Message) {
k := encoding.AcquireKVEntry()
defer encoding.ReleaseKVEntry(k)

Expand Down Expand Up @@ -78,7 +78,7 @@ func BenchmarkNegasus(b *testing.B) {
})
}

func Benchmarkdropmorepackets(b *testing.B) {
func BenchmarkDropMorePackets(b *testing.B) {
b.RunParallel(func(pb *testing.PB) {
// I am unfair against myself as these structures aren't always
// reacquired, but let's do it anyway.
Expand All @@ -89,7 +89,7 @@ func Benchmarkdropmorepackets(b *testing.B) {
s := encoding.AcquireMessageScanner(msgInput)

for s.Next(m) {
dis.Servedropmorepackets(w, m)
dis.ServeDropMorePacket(w, m)
}

if err := s.Error(); err != nil {
Expand Down

0 comments on commit 5ed2a0e

Please sign in to comment.