Skip to content

Commit 85a1376

Browse files
committed
fix post-rebase
1 parent 1b42fc2 commit 85a1376

File tree

3 files changed

+3
-17
lines changed

3 files changed

+3
-17
lines changed

db/hybrid_logical_vector.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ func (hlv *HybridLogicalVector) InvalidateMV() {
273273
if source == hlv.SourceID {
274274
continue
275275
}
276-
hlv.setPreviousVersion(source, value)
276+
hlv.SetPreviousVersion(source, value)
277277
}
278278
hlv.MergeVersions = nil
279279
}

topologytest/hlv_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ func waitForTombstoneVersion(t *testing.T, dsName base.ScopeAndCollectionName, p
6969
}
7070

7171
// waitForConvergingVersion waits for the same document version to reach all peers.
72-
func waitForConvergingVersion(t *testing.T, dsName base.ScopeAndCollectionName, peers Peers, docID string) {
72+
func waitForConvergingVersion(t *testing.T, dsName base.ScopeAndCollectionName, peers Peers, replications Replications, docID string) {
7373
t.Logf("waiting for converged doc versions across all peers")
7474
if !assert.EventuallyWithT(t, func(c *assert.CollectT) {
7575
for peerAid, peerA := range peers.SortedPeers() {
@@ -86,7 +86,7 @@ func waitForConvergingVersion(t *testing.T, dsName base.ScopeAndCollectionName,
8686
}
8787
}, totalWaitTime, pollInterval) {
8888
// do if !assert->require pattern so we can delay PrintGlobalDocState evaluation
89-
require.FailNowf(t, "Peers did not converge on version", "Global state for doc %q on all peers:\n%s", docID, peers.PrintGlobalDocState(t, dsName, docID))
89+
require.FailNowf(t, "Peers did not converge on version", "Global state for doc %q on all peers:\n%s\nReplications: %s", docID, peers.PrintGlobalDocState(t, dsName, docID), replications)
9090
}
9191
}
9292

topologytest/multi_actor_conflict_test.go

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -70,13 +70,6 @@ func TestMultiActorConflictUpdate(t *testing.T) {
7070
func TestMultiActorConflictDelete(t *testing.T) {
7171
for _, topology := range append(simpleTopologies, Topologies...) {
7272
t.Run(topology.description, func(t *testing.T) {
73-
switch topology.description {
74-
case "2x CBL<->SG<->CBS XDCR only 1.3",
75-
"CBL<->SG<->CBS1 CBS1<->CBS2 1.2":
76-
// FIXME: CBG-4458
77-
t.Skip("CBG-4458")
78-
}
79-
8073
collectionName, peers, replications := setupTests(t, topology)
8174
replications.Stop()
8275

@@ -110,13 +103,6 @@ func TestMultiActorConflictDelete(t *testing.T) {
110103
func TestMultiActorConflictResurrect(t *testing.T) {
111104
for _, topology := range append(simpleTopologies, Topologies...) {
112105
t.Run(topology.description, func(t *testing.T) {
113-
switch topology.description {
114-
case "2x CBL<->SG<->CBS XDCR only 1.3",
115-
"CBL<->SG<->CBS1 CBS1<->CBS2 1.2":
116-
// FIXME: CBG-4458
117-
t.Skip("CBG-4458")
118-
}
119-
120106
collectionName, peers, replications := setupTests(t, topology)
121107
replications.Stop()
122108

0 commit comments

Comments
 (0)