Method PostUpgrade

rest/server_context.go:488–550

PostUpgrade performs post-upgrade processing for each database

(ctx context.Context, preview bool)

// PostUpgrade performs post-upgrade processing for each database
func (sc *ServerContext) PostUpgrade(ctx context.Context, preview bool) (postUpgradeResults PostUpgradeResult, err error) {
	sc._databasesLock.RLock()
	defer sc._databasesLock.RUnlock()

	var errs *base.MultiError
	buckets := make(map[string]base.Bucket)                       // map of bucket name to bucket object
	dbs := make(map[string]string, len(sc._databases))            // map of db name to bucket name
	dbDesignDocs := make(map[string][]string, len(sc._databases)) // map of db name to removed design docs
	bucketInUseIndexes := make(map[string]db.CollectionIndexes)   // map of buckets to in use index names
	bucketRemovedIndexes := make(map[string][]string)             // map of bucket name to removed index names
	for dbName, database := range sc._databases {
		bucketName := database.Bucket.GetName()
		dbs[dbName] = bucketName
		buckets[bucketName] = database.Bucket
		// View cleanup
		removedDDocs, err := database.RemoveObsoleteDesignDocs(ctx, preview)
		if err != nil {
			errs = errs.Append(fmt.Errorf("Error removing obsolete design docs for database %q: %v", dbName, err))
			continue
		}
		dbDesignDocs[dbName] = removedDDocs

		// Index cleanup
		inUseIndexes := database.GetInUseIndexes()
		if _, ok := bucketInUseIndexes[database.Bucket.GetName()]; !ok {
			bucketInUseIndexes[database.Bucket.GetName()] = make(db.CollectionIndexes)
		}
		for dsName, indexes := range inUseIndexes {
			if _, ok := bucketInUseIndexes[database.Bucket.GetName()][dsName]; !ok {
				bucketInUseIndexes[database.Bucket.GetName()][dsName] = make(map[string]struct{})
			}
			for indexName := range indexes {
				bucketInUseIndexes[database.Bucket.GetName()][dsName][indexName] = struct{}{}
			}
		}
	}

	for bucketName, indexes := range bucketInUseIndexes {
		bucket, ok := buckets[bucketName]
		if !ok {
			errs = errs.Append(fmt.Errorf("Error getting bucket %q for index cleanup: %v", bucketName, err))
			continue
		}
		if !bucket.IsSupported(sgbucket.BucketStoreFeatureN1ql) {
			continue
		}
		removedIndexes, err := db.RemoveUnusedIndexes(ctx, bucket, indexes, preview)
		if err != nil {
			errs = errs.Append(fmt.Errorf("Error removing obsolete indexes for bucket %q: %v", bucketName, err))
			continue
		}
		bucketRemovedIndexes[bucketName] = removedIndexes
	}
	postUpgradeResults = make(map[string]PostUpgradeDatabaseResult, len(sc._databases))
	for dbName, database := range sc._databases {
		postUpgradeResults[dbName] = PostUpgradeDatabaseResult{
			RemovedDDocs:   dbDesignDocs[dbName],
			RemovedIndexes: bucketRemovedIndexes[database.Bucket.GetName()],