9
9
package topologytest
10
10
11
11
import (
12
- "strings"
13
12
"testing"
14
-
15
- "github.com/couchbase/sync_gateway/base"
16
13
)
17
14
18
15
// TestMultiActorConflictCreate
19
16
// 1. create document on each peer with different contents
20
17
// 2. start replications
21
18
// 3. wait for documents to exist with hlv sources equal to the number of active peers
22
19
func TestMultiActorConflictCreate (t * testing.T ) {
23
- if ! base .UnitTestUrlIsWalrus () {
24
- t .Skip ("Flakey failures on multi actor conflicting writes, CBG-4379" )
25
- }
26
20
for _ , topology := range append (simpleTopologies , Topologies ... ) {
27
21
t .Run (topology .description , func (t * testing.T ) {
28
22
collectionName , peers , replications := setupTests (t , topology )
@@ -46,13 +40,7 @@ func TestMultiActorConflictCreate(t *testing.T) {
46
40
// 6. start replications
47
41
// 7. assert that the documents are deleted on all peers and have hlv sources equal to the number of active peers
48
42
func TestMultiActorConflictUpdate (t * testing.T ) {
49
- if ! base .UnitTestUrlIsWalrus () {
50
- t .Skip ("Flakey failures on multi actor conflicting writes, CBG-4379" )
51
- }
52
43
for _ , topology := range append (simpleTopologies , Topologies ... ) {
53
- if strings .Contains (topology .description , "CBL" ) {
54
- t .Skip ("CBL actor can generate conflicts and push replication fails with conflict for doc in blip tester CBL-4267" )
55
- }
56
44
t .Run (topology .description , func (t * testing.T ) {
57
45
collectionName , peers , replications := setupTests (t , topology )
58
46
replications .Stop ()
@@ -82,9 +70,6 @@ func TestMultiActorConflictUpdate(t *testing.T) {
82
70
// 7. assert that the documents are deleted on all peers and have hlv sources equal to the number of active peers
83
71
func TestMultiActorConflictDelete (t * testing.T ) {
84
72
for _ , topology := range append (simpleTopologies , Topologies ... ) {
85
- if strings .Contains (topology .description , "CBL" ) {
86
- t .Skip ("CBL actor can generate conflicts and push replication fails with conflict for doc in blip tester CBL-4267" )
87
- }
88
73
t .Run (topology .description , func (t * testing.T ) {
89
74
collectionName , peers , replications := setupTests (t , topology )
90
75
replications .Stop ()
@@ -117,13 +102,7 @@ func TestMultiActorConflictDelete(t *testing.T) {
117
102
// 10. start replications
118
103
// 11. assert that the documents are resurrected on all peers and have hlv sources equal to the number of active peers and the document body is equivalent to the last write
119
104
func TestMultiActorConflictResurrect (t * testing.T ) {
120
- if ! base .UnitTestUrlIsWalrus () {
121
- t .Skip ("Flakey failures on multi actor conflicting writes, CBG-4379" )
122
- }
123
105
for _ , topology := range append (simpleTopologies , Topologies ... ) {
124
- if strings .Contains (topology .description , "CBL" ) {
125
- t .Skip ("CBL actor can generate conflicts and push replication fails with conflict for doc in blip tester CBL-4267" )
126
- }
127
106
t .Run (topology .description , func (t * testing.T ) {
128
107
collectionName , peers , replications := setupTests (t , topology )
129
108
replications .Stop ()
0 commit comments