func (s *replicationResyncer) PersistToDisk(ctx context.Context, objectAPI ObjectLayer) {
	resyncTimer := time.NewTimer(resyncTimeInterval)
	defer resyncTimer.Stop()

	// For each bucket name, store the last timestamp of the
	// successful save of replication status in the backend disks.
	lastResyncStatusSave := make(map[string]time.Time)

	for {
		select {

				WithWaitingPods(NewWaitingPodsMap()),
			)
			if err != nil {
				cancel()
				t.Fatalf("Failed to create framework for testing: %v", err)
			}

			tt.action(f)

			// Stop the goroutine which records metrics and ensure it's stopped.
			cancel()
			<-recorder.IsStoppedCh
			// Try to clean up the metrics buffer again in case it's not empty.
			recorder.FlushMetrics()

void initializeContext(); public synchronized void start(org.codehaus.classworlds.ClassWorld) throws org.codehaus.plexus.PlexusContainerExcep; public synchronized void start() throws org.codehaus.plexus.PlexusContainerExcep; public synchronized void stop(); } org/codehaus/plexus/embed/EmbedderException.class package org.codehaus.plexus.embed; public synchronized class EmbedderException extends Exception { public void EmbedderException(String); public void EmbedderException(String, Throwable); public...

    /** The key of the message: Failed to start job {0}. */
    public static final String ERRORS_failed_to_start_job = "{errors.failed_to_start_job}";

    /** The key of the message: Failed to stop job {0}. */
    public static final String ERRORS_failed_to_stop_job = "{errors.failed_to_stop_job}";

    /** The key of the message: Failed to download the Synonym file. */

void initializeContext(); public synchronized void start(org.codehaus.classworlds.ClassWorld) throws org.codehaus.plexus.PlexusContainerExcep; public synchronized void start() throws org.codehaus.plexus.PlexusContainerExcep; public synchronized void stop(); } org/codehaus/plexus/embed/EmbedderException.class package org.codehaus.plexus.embed; public synchronized class EmbedderException extends Exception { public void EmbedderException(String); public void EmbedderException(String, Throwable); public...

   *
   * <p><b>Warning:</b> If the function rejects {@code null}, caution is required to make sure the
   * set does not contain {@code null}, because the view cannot stop {@code null} from being added
   * to the set.
   *
   * <p><b>Warning:</b> This method assumes that for any instance {@code k} of key type {@code K},

   *
   * <p><b>Warning:</b> If the function rejects {@code null}, caution is required to make sure the
   * set does not contain {@code null}, because the view cannot stop {@code null} from being added
   * to the set.
   *
   * <p><b>Warning:</b> This method assumes that for any instance {@code k} of key type {@code K},

	cl := testingclock.NewFakeClock(time.Now())
	logger, ctx := ktesting.NewTestContext(t)
	ctx, cancel := context.WithCancel(ctx)
	defer cancel()
	q := NewTestQueue(ctx, newDefaultQueueSort(), WithClock(cl))
	steps := []struct {
		wantBackoff time.Duration
	}{
		{wantBackoff: time.Second},
		{wantBackoff: 2 * time.Second},
		{wantBackoff: 4 * time.Second},
		{wantBackoff: 8 * time.Second},

AppType = TypeVar("AppType", bound="FastAPI")


class FastAPI(Starlette):
    """
    `FastAPI` app class, the main entrypoint to use FastAPI.

    Read more in the
    [FastAPI docs for First Steps](https://fastapi.tiangolo.com/tutorial/first-steps/).

    ## Example

    ```python
    from fastapi import FastAPI

    app = FastAPI()
    ```
    """

    def __init__(
        self: AppType,
        *,

private final transient SweeperPool pool; private transient boolean service; private final transient int sweepInterval; public void SweeperPool$Sweeper(SweeperPool, int); public void run(); public synchronized void start(); public synchronized void stop(); private final void debug(String); private void runSweep(); } org/codehaus/plexus/util/SweeperPool.class package org.codehaus.plexus.util; public synchronized class SweeperPool { private static final boolean DEBUG = 0; private transient SweeperPool$Sweeper...