mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
zeekay
8feb24ea1f
The server module named github.com/hanzoai/team/server/v8 — a path that resolves to the retired workspace's repository, not this one — while server/public still published github.com/mattermost/mattermost/server/public. Both are github.com/hanzoteam/server/... now, which is where this code actually lives. That second half is what made the binary unbootable. Upstream's public path stayed claimed by upstream, mattermost-plugin-ai imported it, and the build linked public/model twice; public/plugin's gob.Register then ran twice under one name and panicked at init, before main. Reverting the rename traded the brand for a working binary. Rebranding the plugin alongside it needs no such trade: the agents fork is github.com/hanzoteam/agents/v2 against our public module, so no module named mattermost/mattermost is in the graph at all. Measured: `go list -deps ./cmd/mattermost` names exactly one public/model, and it is ours.
93 lines
2.0 KiB
Go
93 lines
2.0 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package cache_test
|
|
|
|
import (
|
|
"fmt"
|
|
"runtime"
|
|
"sync"
|
|
"testing"
|
|
|
|
"github.com/cespare/xxhash/v2"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/hanzoteam/server/server/v8/platform/services/cache"
|
|
)
|
|
|
|
const (
|
|
m = 500_000
|
|
)
|
|
|
|
func BenchmarkLRUStriped(b *testing.B) {
|
|
opts := cache.CacheOptions{
|
|
Name: "",
|
|
Size: 128,
|
|
DefaultExpiry: 0,
|
|
InvalidateClusterEvent: "",
|
|
StripedBuckets: runtime.NumCPU() - 1,
|
|
}
|
|
|
|
cache, err := cache.NewLRUStriped(&opts)
|
|
require.NoError(b, err)
|
|
|
|
// prepare keys and initial cache values and set routine
|
|
keys := make([]string, 0, m)
|
|
// bucketKeys is to demonstrate that splitted locks is working correctly
|
|
// by assigning one sequence of key for each bucket.
|
|
bucketKeys := make([][]string, opts.StripedBuckets)
|
|
for i := range m {
|
|
key := fmt.Sprintf("%d-key-%d", i, i)
|
|
keys = append(keys, key)
|
|
bucketKey := xxhash.Sum64String(key) % uint64(opts.StripedBuckets)
|
|
bucketKeys[bucketKey] = append(bucketKeys[bucketKey], key)
|
|
}
|
|
for i := 0; i < opts.Size; i++ {
|
|
cache.SetWithDefaultExpiry(keys[i], "preflight")
|
|
}
|
|
|
|
wgGet := &sync.WaitGroup{}
|
|
wgSet := &sync.WaitGroup{}
|
|
// need buffered chan because if the set routine finished before we write into the chan,
|
|
// we're left without any consumer, making any write to the chan waiting forever.
|
|
stopSet := make(chan bool, 1)
|
|
set := func() {
|
|
defer wgSet.Done()
|
|
for i := range m {
|
|
select {
|
|
case <-stopSet:
|
|
return
|
|
default:
|
|
_ = cache.SetWithDefaultExpiry(keys[i], "ignored")
|
|
}
|
|
}
|
|
}
|
|
|
|
get := func(bucket int) {
|
|
defer wgGet.Done()
|
|
var out string
|
|
for i := range m {
|
|
_ = cache.Get(bucketKeys[bucket][i%opts.Size], &out)
|
|
}
|
|
}
|
|
|
|
for b.Loop() {
|
|
b.StopTimer()
|
|
wgSet.Add(1)
|
|
go set()
|
|
for j := 0; j < opts.StripedBuckets; j++ {
|
|
wgGet.Add(1)
|
|
go get(j)
|
|
}
|
|
|
|
b.StartTimer()
|
|
wgGet.Wait()
|
|
|
|
// Cleanup
|
|
b.StopTimer()
|
|
stopSet <- true
|
|
wgSet.Wait()
|
|
b.StartTimer()
|
|
}
|
|
}
|