anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-09 09:35:03 +09:00
Code Activity

Merge branch 'main' into GO-4146-new-spacestore

Browse source 
# Conflicts:
#	commonspace/deletion_test.go
#	commonspace/headsync/headsync.go
#	commonspace/headsync/headsync_test.go
#	commonspace/object/tree/objecttree/objecttree.go
#	commonspace/object/tree/synctree/synctree.go
#	go.mod
#	go.sum
This commit is contained in:
mcrakhman 2024-12-27 19:20:57 +01:00
commit 486c4f4a90
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
28 changed files with 592 additions and 159 deletions
Download patch file Download diff file Expand all files Collapse all files

36
util/periodicsync/periodicsync_test.go
View file

@ -2,11 +2,14 @@ package periodicsync
import (
"context"
"github.com/anyproto/any-sync/app/logger"
"github.com/stretchr/testify/require"
"go.uber.org/mock/gomock"
"sync/atomic"
"testing"
"time"
"github.com/stretchr/testify/require"
"go.uber.org/mock/gomock"
"github.com/anyproto/any-sync/app/logger"
)
func TestPeriodicSync_Run(t *testing.T) {
@ -17,33 +20,32 @@ func TestPeriodicSync_Run(t *testing.T) {
l := logger.NewNamed("sync")
t.Run("loop call 1 time", func(t *testing.T) {
secs := 0
times := 0
times := atomic.Int32{}
diffSyncer := func(ctx context.Context) (err error) {
times += 1
times.Add(1)
return nil
}
pSync := NewPeriodicSync(secs, 0, diffSyncer, l)
pSync := NewPeriodicSyncDuration(time.Second, 0, diffSyncer, l)
pSync.Run()
pSync.Close()
require.Equal(t, 1, times)
require.Equal(t, int32(1), times.Load())
})
t.Run("loop call 2 times", func(t *testing.T) {
secs := 1
times := 0
var neededTimes int32 = 2
times := atomic.Int32{}
ch := make(chan struct{})
diffSyncer := func(ctx context.Context) (err error) {
times += 1
times.Add(1)
if neededTimes == times.Load() {
close(ch)
}
return nil
}
pSync := NewPeriodicSync(secs, 0, diffSyncer, l)
pSync := NewPeriodicSyncDuration(time.Millisecond*100, 0, diffSyncer, l)
pSync.Run()
time.Sleep(time.Second * time.Duration(secs))
<-ch
pSync.Close()
require.Equal(t, 2, times)
})
t.Run("loop close not running", func(t *testing.T) {