consensus/ai/mlx_bench_test.go

// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package ai

import (
	"fmt"
	"testing"
)

// BenchmarkMLXBatchProcessing benchmarks GPU batch vote processing
func BenchmarkMLXBatchProcessing(b *testing.B) {
	backend, err := NewMLXBackend(1000)
	if err != nil {
		b.Skip("accel backend not available")
	}

	// Create test votes
	votes := make([]Vote, 1000)
	for i := range votes {
		votes[i] = Vote{
			VoterID:      [32]byte{byte(i), byte(i >> 8)},
			BlockID:      [32]byte{byte(i >> 16), byte(i >> 24)},
			IsPreference: i%2 == 0,
		}
	}

	b.ResetTimer()
	b.ReportAllocs()

	var totalProcessed int
	for i := 0; i < b.N; i++ {
		processed, _ := backend.ProcessVotesBatch(votes)
		totalProcessed += processed
	}

	b.StopTimer()
	throughput := backend.GetThroughput()
	b.ReportMetric(throughput, "votes/sec")
	b.ReportMetric(float64(totalProcessed)/b.Elapsed().Seconds(), "avg-votes/sec")
}

// BenchmarkMLXBatchProcessing100 benchmarks smaller batches
func BenchmarkMLXBatchProcessing100(b *testing.B) {
	backend, err := NewMLXBackend(100)
	if err != nil {
		b.Skip("accel backend not available")
	}

	votes := make([]Vote, 100)
	for i := range votes {
		votes[i] = Vote{
			VoterID:      [32]byte{byte(i), byte(i + 1)},
			BlockID:      [32]byte{byte(i * 2), byte(i*2 + 1)},
			IsPreference: i%2 == 0,
		}
	}

	b.ResetTimer()
	b.ReportAllocs()

	var totalProcessed int
	for i := 0; i < b.N; i++ {
		processed, _ := backend.ProcessVotesBatch(votes)
		totalProcessed += processed
	}

	b.StopTimer()
	throughput := backend.GetThroughput()
	b.ReportMetric(throughput, "votes/sec")
	b.ReportMetric(float64(totalProcessed)/b.Elapsed().Seconds(), "avg-votes/sec")
}

// BenchmarkMLXBatchProcessing10000 benchmarks large batches
func BenchmarkMLXBatchProcessing10000(b *testing.B) {
	backend, err := NewMLXBackend(10000)
	if err != nil {
		b.Skip("accel backend not available")
	}

	votes := make([]Vote, 10000)
	for i := range votes {
		votes[i] = Vote{
			VoterID:      [32]byte{byte(i), byte(i >> 8), byte(i >> 16), byte(i >> 24)},
			BlockID:      [32]byte{byte(i * 2), byte((i * 2) >> 8), byte((i * 2) >> 16), byte((i * 2) >> 24)},
			IsPreference: i%2 == 0,
		}
	}

	b.ResetTimer()
	b.ReportAllocs()

	var totalProcessed int
	for i := 0; i < b.N; i++ {
		processed, _ := backend.ProcessVotesBatch(votes)
		totalProcessed += processed
	}

	b.StopTimer()
	throughput := backend.GetThroughput()
	b.ReportMetric(throughput, "votes/sec")
	b.ReportMetric(float64(totalProcessed)/b.Elapsed().Seconds(), "avg-votes/sec")
}

// BenchmarkMLXVaryingBatchSizes benchmarks different batch sizes
func BenchmarkMLXVaryingBatchSizes(b *testing.B) {
	batchSizes := []int{10, 50, 100, 500, 1000, 5000, 10000}

	for _, size := range batchSizes {
		b.Run(fmt.Sprintf("batch_%d", size), func(b *testing.B) {
			backend, err := NewMLXBackend(size)
			if err != nil {
				b.Skip("accel backend not available")
			}

			votes := make([]Vote, size)
			for i := range votes {
				votes[i] = Vote{
					VoterID:      [32]byte{byte(i), byte(i >> 8)},
					BlockID:      [32]byte{byte(i * 2), byte((i * 2) >> 8)},
					IsPreference: i%2 == 0,
				}
			}

			b.ResetTimer()
			b.ReportAllocs()

			var totalProcessed int
			for i := 0; i < b.N; i++ {
				processed, _ := backend.ProcessVotesBatch(votes)
				totalProcessed += processed
			}

			b.StopTimer()
			throughput := backend.GetThroughput()
			b.ReportMetric(throughput, "votes/sec")
			b.ReportMetric(float64(size), "batch-size")
			b.ReportMetric(float64(totalProcessed)/b.Elapsed().Seconds(), "avg-votes/sec")
		})
	}
}

// BenchmarkAccelBatchProcessing benchmarks AccelBackend directly
func BenchmarkAccelBatchProcessing(b *testing.B) {
	backend, err := NewAccelBackend(1000)
	if err != nil {
		b.Skip("accel backend not available")
	}

	votes := make([]Vote, 1000)
	for i := range votes {
		votes[i] = Vote{
			VoterID:      [32]byte{byte(i), byte(i >> 8)},
			BlockID:      [32]byte{byte(i >> 16), byte(i >> 24)},
			IsPreference: i%2 == 0,
		}
	}

	b.ResetTimer()
	b.ReportAllocs()

	var totalProcessed int
	for i := 0; i < b.N; i++ {
		processed, _ := backend.ProcessVotesBatch(votes)
		totalProcessed += processed
	}

	b.StopTimer()
	throughput := backend.GetThroughput()
	b.ReportMetric(throughput, "votes/sec")
	b.ReportMetric(float64(totalProcessed)/b.Elapsed().Seconds(), "avg-votes/sec")
}