fix tests
This commit is contained in:
parent
f81196eb98
commit
3ed9d6180a
@ -321,6 +321,34 @@ func (mr *MockObjectTreeMockRecorder) Storage() *gomock.Call {
|
|||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Storage", reflect.TypeOf((*MockObjectTree)(nil).Storage))
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Storage", reflect.TypeOf((*MockObjectTree)(nil).Storage))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TryLock mocks base method.
|
||||||
|
func (m *MockObjectTree) TryLock() bool {
|
||||||
|
m.ctrl.T.Helper()
|
||||||
|
ret := m.ctrl.Call(m, "TryLock")
|
||||||
|
ret0, _ := ret[0].(bool)
|
||||||
|
return ret0
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryLock indicates an expected call of TryLock.
|
||||||
|
func (mr *MockObjectTreeMockRecorder) TryLock() *gomock.Call {
|
||||||
|
mr.mock.ctrl.T.Helper()
|
||||||
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TryLock", reflect.TypeOf((*MockObjectTree)(nil).TryLock))
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryRLock mocks base method.
|
||||||
|
func (m *MockObjectTree) TryRLock() bool {
|
||||||
|
m.ctrl.T.Helper()
|
||||||
|
ret := m.ctrl.Call(m, "TryRLock")
|
||||||
|
ret0, _ := ret[0].(bool)
|
||||||
|
return ret0
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryRLock indicates an expected call of TryRLock.
|
||||||
|
func (mr *MockObjectTreeMockRecorder) TryRLock() *gomock.Call {
|
||||||
|
mr.mock.ctrl.T.Helper()
|
||||||
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TryRLock", reflect.TypeOf((*MockObjectTree)(nil).TryRLock))
|
||||||
|
}
|
||||||
|
|
||||||
// Unlock mocks base method.
|
// Unlock mocks base method.
|
||||||
func (m *MockObjectTree) Unlock() {
|
func (m *MockObjectTree) Unlock() {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
|
|||||||
@ -472,6 +472,34 @@ func (mr *MockSyncTreeMockRecorder) SyncWithPeer(arg0, arg1 interface{}) *gomock
|
|||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncWithPeer", reflect.TypeOf((*MockSyncTree)(nil).SyncWithPeer), arg0, arg1)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncWithPeer", reflect.TypeOf((*MockSyncTree)(nil).SyncWithPeer), arg0, arg1)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TryLock mocks base method.
|
||||||
|
func (m *MockSyncTree) TryLock() bool {
|
||||||
|
m.ctrl.T.Helper()
|
||||||
|
ret := m.ctrl.Call(m, "TryLock")
|
||||||
|
ret0, _ := ret[0].(bool)
|
||||||
|
return ret0
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryLock indicates an expected call of TryLock.
|
||||||
|
func (mr *MockSyncTreeMockRecorder) TryLock() *gomock.Call {
|
||||||
|
mr.mock.ctrl.T.Helper()
|
||||||
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TryLock", reflect.TypeOf((*MockSyncTree)(nil).TryLock))
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryRLock mocks base method.
|
||||||
|
func (m *MockSyncTree) TryRLock() bool {
|
||||||
|
m.ctrl.T.Helper()
|
||||||
|
ret := m.ctrl.Call(m, "TryRLock")
|
||||||
|
ret0, _ := ret[0].(bool)
|
||||||
|
return ret0
|
||||||
|
}
|
||||||
|
|
||||||
|
// TryRLock indicates an expected call of TryRLock.
|
||||||
|
func (mr *MockSyncTreeMockRecorder) TryRLock() *gomock.Call {
|
||||||
|
mr.mock.ctrl.T.Helper()
|
||||||
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TryRLock", reflect.TypeOf((*MockSyncTree)(nil).TryRLock))
|
||||||
|
}
|
||||||
|
|
||||||
// Unlock mocks base method.
|
// Unlock mocks base method.
|
||||||
func (m *MockSyncTree) Unlock() {
|
func (m *MockSyncTree) Unlock() {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
|
|||||||
@ -3,6 +3,9 @@ package synctree
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"sync"
|
||||||
|
"testing"
|
||||||
|
|
||||||
"github.com/anytypeio/any-sync/app/logger"
|
"github.com/anytypeio/any-sync/app/logger"
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree"
|
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree"
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree/mock_objecttree"
|
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree/mock_objecttree"
|
||||||
@ -12,13 +15,11 @@ import (
|
|||||||
"github.com/golang/mock/gomock"
|
"github.com/golang/mock/gomock"
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"sync"
|
|
||||||
"testing"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type testObjTreeMock struct {
|
type testObjTreeMock struct {
|
||||||
*mock_objecttree.MockObjectTree
|
*mock_objecttree.MockObjectTree
|
||||||
m sync.Mutex
|
m sync.RWMutex
|
||||||
}
|
}
|
||||||
|
|
||||||
func newTestObjMock(mockTree *mock_objecttree.MockObjectTree) *testObjTreeMock {
|
func newTestObjMock(mockTree *mock_objecttree.MockObjectTree) *testObjTreeMock {
|
||||||
@ -31,10 +32,26 @@ func (t *testObjTreeMock) Lock() {
|
|||||||
t.m.Lock()
|
t.m.Lock()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (t *testObjTreeMock) RLock() {
|
||||||
|
t.m.RLock()
|
||||||
|
}
|
||||||
|
|
||||||
func (t *testObjTreeMock) Unlock() {
|
func (t *testObjTreeMock) Unlock() {
|
||||||
t.m.Unlock()
|
t.m.Unlock()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (t *testObjTreeMock) RUnlock() {
|
||||||
|
t.m.RUnlock()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *testObjTreeMock) TryLock() bool {
|
||||||
|
return t.m.TryLock()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *testObjTreeMock) TryRLock() bool {
|
||||||
|
return t.m.TryRLock()
|
||||||
|
}
|
||||||
|
|
||||||
type syncHandlerFixture struct {
|
type syncHandlerFixture struct {
|
||||||
ctrl *gomock.Controller
|
ctrl *gomock.Controller
|
||||||
syncClientMock *mock_synctree.MockSyncClient
|
syncClientMock *mock_synctree.MockSyncClient
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user