Skip to content

Commit fe0c122

Browse files
Merge remote-tracking branch 'couchbase/morpheus'
Change-Id: I5d5e823f460d4020e43aa2255f7634e7bc90ed5c
2 parents e990ce9 + 52efa01 commit fe0c122

1 file changed

Lines changed: 16 additions & 2 deletions

File tree

datastore/couchbase/couchbase.go

Lines changed: 16 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3856,7 +3856,21 @@ func (s *store) CheckSystemCollection(bucketName, requestId string, forceIndex b
38563856
return false, errors.NewInvalidGSIIndexerError("Cannot get primary index on system collection")
38573857
}
38583858

3859-
sysIndex, er := indexer3.IndexByName(_BUCKET_SYSTEM_PRIM_INDEX)
3859+
sysIndexName := _BUCKET_SYSTEM_PRIM_INDEX
3860+
3861+
primaryIndexes, err := indexer3.PrimaryIndexes()
3862+
if err != nil {
3863+
return false, err
3864+
}
3865+
3866+
for _, index := range primaryIndexes {
3867+
if index != nil && index.IsPrimary() {
3868+
sysIndexName = index.Name()
3869+
break
3870+
}
3871+
}
3872+
3873+
sysIndex, er := indexer3.IndexByName(sysIndexName)
38603874
if er != nil {
38613875
if !errors.IsIndexNotFoundError(er) {
38623876
// only ignore index not found error
@@ -3899,7 +3913,7 @@ func (s *store) CheckSystemCollection(bucketName, requestId string, forceIndex b
38993913
return false, er
39003914
}
39013915

3902-
sysIndex, er = indexer3.IndexByName(_BUCKET_SYSTEM_PRIM_INDEX)
3916+
sysIndex, er = indexer3.IndexByName(sysIndexName)
39033917
if er != nil {
39043918
return false, er
39053919
}

0 commit comments

Comments
 (0)