append_entries_response_test.go 711 B

12345678910111213141516171819202122232425262728293031323334
  1. package raft
  2. import (
  3. "bytes"
  4. "testing"
  5. )
  6. func BenchmarkAppendEntriesResponseEncoding(b *testing.B) {
  7. req, tmp := createTestAppendEntriesResponse(2000)
  8. b.ResetTimer()
  9. for i := 0; i < b.N; i++ {
  10. var buf bytes.Buffer
  11. req.encode(&buf)
  12. }
  13. b.SetBytes(int64(len(tmp)))
  14. }
  15. func BenchmarkAppendEntriesResponseDecoding(b *testing.B) {
  16. req, buf := createTestAppendEntriesResponse(2000)
  17. b.ResetTimer()
  18. for i := 0; i < b.N; i++ {
  19. req.decode(bytes.NewReader(buf))
  20. }
  21. b.SetBytes(int64(len(buf)))
  22. }
  23. func createTestAppendEntriesResponse(entryCount int) (*AppendEntriesResponse, []byte) {
  24. resp := newAppendEntriesResponse(1, true, 1, 1)
  25. var buf bytes.Buffer
  26. resp.encode(&buf)
  27. return resp, buf.Bytes()
  28. }