mirror of
https://github.com/charmbracelet/crush.git
synced 2026-05-30 18:47:33 +00:00
Carlos Alexandro BeckerandGitHub
016b3b6ddd
* feat(lsp): remove internal watcher It was only ever useful if the user edits files through their editor, but we don't really need it assuming we only care about edits done by Crush itself. Basically, we lose that functionality, but save a bunch of file descriptors and have improved perf. Damn good deal if you ask me. Signed-off-by: Carlos Alexandro Becker <caarlos0@users.noreply.github.com> * fix: cleanup Signed-off-by: Carlos Alexandro Becker <caarlos0@users.noreply.github.com> * fix: remove rlimit Signed-off-by: Carlos Alexandro Becker <caarlos0@users.noreply.github.com> * fix: more cleanup Signed-off-by: Carlos Alexandro Becker <caarlos0@users.noreply.github.com> --------- Signed-off-by: Carlos Alexandro Becker <caarlos0@users.noreply.github.com>
90 lines
2.1 KiB
Go
90 lines
2.1 KiB
Go
package csync
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestVersionedMap_Set(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
vm := NewVersionedMap[string, int]()
|
|
require.Equal(t, uint64(0), vm.Version())
|
|
|
|
vm.Set("key1", 42)
|
|
require.Equal(t, uint64(1), vm.Version())
|
|
|
|
value, ok := vm.Get("key1")
|
|
require.True(t, ok)
|
|
require.Equal(t, 42, value)
|
|
}
|
|
|
|
func TestVersionedMap_Del(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
vm := NewVersionedMap[string, int]()
|
|
vm.Set("key1", 42)
|
|
initialVersion := vm.Version()
|
|
|
|
vm.Del("key1")
|
|
require.Equal(t, initialVersion+1, vm.Version())
|
|
|
|
_, ok := vm.Get("key1")
|
|
require.False(t, ok)
|
|
}
|
|
|
|
func TestVersionedMap_VersionIncrement(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
vm := NewVersionedMap[string, int]()
|
|
initialVersion := vm.Version()
|
|
|
|
// Setting a value should increment the version
|
|
vm.Set("key1", 42)
|
|
require.Equal(t, initialVersion+1, vm.Version())
|
|
|
|
// Deleting a value should increment the version
|
|
vm.Del("key1")
|
|
require.Equal(t, initialVersion+2, vm.Version())
|
|
|
|
// Deleting a non-existent key should still increment the version
|
|
vm.Del("nonexistent")
|
|
require.Equal(t, initialVersion+3, vm.Version())
|
|
}
|
|
|
|
func TestVersionedMap_ConcurrentAccess(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
vm := NewVersionedMap[int, int]()
|
|
const numGoroutines = 100
|
|
const numOperations = 100
|
|
|
|
// Initial version
|
|
initialVersion := vm.Version()
|
|
|
|
// Perform concurrent Set and Del operations
|
|
for i := range numGoroutines {
|
|
go func(id int) {
|
|
for j := range numOperations {
|
|
key := id*numOperations + j
|
|
vm.Set(key, key*2)
|
|
vm.Del(key)
|
|
}
|
|
}(i)
|
|
}
|
|
|
|
// Wait for operations to complete by checking the version
|
|
// This is a simplified check - in a real test you might want to use sync.WaitGroup
|
|
expectedMinVersion := initialVersion + uint64(numGoroutines*numOperations*2)
|
|
|
|
// Allow some time for operations to complete
|
|
for vm.Version() < expectedMinVersion {
|
|
// Busy wait - in a real test you'd use proper synchronization
|
|
}
|
|
|
|
// Final version should be at least the expected minimum
|
|
require.GreaterOrEqual(t, vm.Version(), expectedMinVersion)
|
|
require.Equal(t, 0, vm.Len())
|
|
}
|