refresh - Code Search

android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

    assertEquals(2, stats.missCount());
    assertEquals(2, stats.loadSuccessCount());
    assertEquals(0, stats.loadExceptionCount());
    assertEquals(0, stats.hitCount());

    key = new Object();
    cache.refresh(key);
    checkNothingLogged();
    stats = cache.stats();
    assertEquals(2, stats.missCount());
    assertEquals(3, stats.loadSuccessCount());
    assertEquals(0, stats.loadExceptionCount());

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 86.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java

        createWebConfig();
        logger.info("WebConfig is created");
        refresh();
        webConfigId = getWebConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created: {}", webConfigId);
        refresh();

        startJob(NAME_PREFIX);

        waitJob(NAME_PREFIX);
        refresh();

        ThreadUtil.sleep(3000);
    }

    @BeforeEach

Java

- Registered: Mon Apr 22 08:04:10 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 9.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/SuggestHelper.java

        }
        refresh();
    }

    public void addBadWord(final String badWord, final boolean apply) {
        suggester.indexer().addBadWord(badWord, apply);
        refresh();
    }

    public void deleteBadWord(final String badWord) {
        suggester.indexer().deleteBadWord(badWord);
        refresh();
    }

    public synchronized void refresh() {

Java

- Registered: Mon Apr 22 08:04:10 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 18K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/cache/CacheBuilderFactory.java

    }
    if (expireAfterAccess != null) {
      builder.expireAfterAccess(expireAfterAccess.duration, expireAfterAccess.unit);
    }
    if (refresh != null) {
      builder.refreshAfterWrite(refresh.duration, refresh.unit);
    }
    if (keyStrength != null) {
      builder.setKeyStrength(keyStrength);
    }
    if (valueStrength != null) {
      builder.setValueStrength(valueStrength);

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 8.1K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/drwmutex.go

				log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c)
			} else {
				ch <- refreshResult{refreshed: refreshed}
				log("dsync: Refresh returned false for %#v at %s\n", args, c)
			}
		}(index, c)
	}

	// Wait until we have either
	//
	// a) received all refresh responses
	// b) received too many refreshed for quorum to be still possible
	// c) timed out
	//

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Thu Feb 22 06:26:06 GMT 2024

- 19.7K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/cache/CacheLoadingTest.java

    assertEquals(2, stats.missCount());
    assertEquals(2, stats.loadSuccessCount());
    assertEquals(0, stats.loadExceptionCount());
    assertEquals(0, stats.hitCount());

    key = new Object();
    cache.refresh(key);
    checkNothingLogged();
    stats = cache.stats();
    assertEquals(2, stats.missCount());
    assertEquals(3, stats.loadSuccessCount());
    assertEquals(0, stats.loadExceptionCount());

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 86.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/cache/CacheBuilderFactory.java

    }
    if (expireAfterAccess != null) {
      builder.expireAfterAccess(expireAfterAccess.duration, expireAfterAccess.unit);
    }
    if (refresh != null) {
      builder.refreshAfterWrite(refresh.duration, refresh.unit);
    }
    if (keyStrength != null) {
      builder.setKeyStrength(keyStrength);
    }
    if (valueStrength != null) {
      builder.setValueStrength(valueStrength);

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 8.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/cache/CacheRefreshTest.java

    assertEquals(Integer.valueOf(2), cache.getUnchecked(2));
    assertEquals(expectedLoads, loader.getLoadCount());
    assertEquals(expectedReloads, loader.getReloadCount());

    // refresh 0
    ticker.advance(1, MILLISECONDS);
    assertEquals(Integer.valueOf(1), cache.getUnchecked(0));
    expectedReloads++;
    assertEquals(Integer.valueOf(1), cache.getUnchecked(1));

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Dec 04 17:37:03 GMT 2017

- 3.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/cache/CacheRefreshTest.java

    assertEquals(Integer.valueOf(2), cache.getUnchecked(2));
    assertEquals(expectedLoads, loader.getLoadCount());
    assertEquals(expectedReloads, loader.getReloadCount());

    // refresh 0
    ticker.advance(1, MILLISECONDS);
    assertEquals(Integer.valueOf(1), cache.getUnchecked(0));
    expectedReloads++;
    assertEquals(Integer.valueOf(1), cache.getUnchecked(1));

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Dec 04 17:37:03 GMT 2017

- 3.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/warm-backend-azure.go

	if err != nil {
		return nil, err
	}

	// Refresh obtains a fresh token
	err = spt.Refresh()
	if err != nil {
		return nil, err
	}

	tc := azblob.NewTokenCredential(spt.Token().AccessToken, func(tc azblob.TokenCredential) time.Duration {
		err := spt.Refresh()
		if err != nil {
			return 0
		}
		// set the new token value

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Tue Mar 05 16:44:08 GMT 2024

- 7.8K bytes

- Viewed (1)

Search Options