Method waitForStoppedInLogFile

xdcr/cbs_xdcr.go:344–367

waitForStoppedInLogFile waits for the replication to stop by checking the log file.

(ctx context.Context)

// waitForStoppedInLogFile waits for the replication to stop by checking the log file.
func (x *couchbaseServerManager) waitForStoppedInLogFile(ctx context.Context) error {
	// magic string to indicate that the replication has stopped
	grepStr := fmt.Sprintf("%s status is finished shutting down", x.replicationID)
	logFile := x.xdcrLogFilePath()
	// look for log files that are goxcdr.log[.[0-9]][.gz], the message may be in a rotated log
	cmdLine := fmt.Sprintf(`zgrep --no-filename "%s" "%s"*`, grepStr, logFile)
	err, _ := base.RetryLoop(ctx, "ReadLogFileUntilStopped", func() (shouldRetry bool, err error, value any) {
		output, err := x.runCommandOnCBS(cmdLine)
		if err != nil {
			return true, err, nil
		}
		for _, line := range strings.Split(strings.TrimSpace(output), "\n") {
			timestamp := strings.Split(line, " ")[0]
			if timestamp > x.startingTimestamp {
				return false, nil, nil
			}
		}
		return true, fmt.Errorf("Could not find line newer than %s in %s", x.startingTimestamp, output), nil
	}, base.CreateLinearSleeperFunc(5*time.Minute, 1*time.Second))
	if err != nil {
		return fmt.Errorf("Could not find %s in %s. %w", grepStr, logFile, err)
	}
	return nil
}

var _ Manager = &couchbaseServerManager{}