- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for Geresh (0.22 sec)
-
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 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* acquire(10) request arriving. We serve the request partly from storedPermits, using all the * remaining 7.0 permits, and the remaining 3.0, we serve them by fresh permits produced by the * rate limiter. * * We already know how much time it takes to serve 3 fresh permits: if the rate is * "1 token per second", then this will take 3 seconds. But what does it mean to serve 7 stored
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 19.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/search/SearchApiTests.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.6K bytes - Viewed (1) -
internal/kms/kes.go
if err != nil { logger.LogOnceIf(ctx, fmt.Errorf("%s, using default of 10s", err.Error()), "refresh-kms-master-key") cacheDuration = defaultCacheDuration } if cacheDuration < time.Second { logger.LogOnceIf(ctx, errors.New("cache duration is less than 1s, using default of 10s"), "refresh-kms-master-key") cacheDuration = defaultCacheDuration } timer := time.NewTimer(cacheDuration) defer timer.Stop()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
assertThat(client.connectionPool.connectionCount()).isEqualTo(2) assertThat(server.takeRequest().sequenceNumber) .isEqualTo(0) // Fresh connection. assertThat(server.takeRequest().sequenceNumber) .isEqualTo(0) // Fresh connection. } /** * Check we would use an existing connection to a later DNS result instead of connecting to the * first DNS result for the first time.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
import org.codelibs.fess.thumbnail.ThumbnailManager; import org.codelibs.fess.util.ComponentUtil; import org.codelibs.fess.util.DocList; import org.codelibs.fess.util.MemoryUtil; import org.opensearch.action.admin.indices.refresh.RefreshResponse; import org.opensearch.action.search.SearchResponse; import org.opensearch.index.query.QueryBuilder; import org.opensearch.index.query.QueryBuilders; public class IndexingHelper {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 15.6K bytes - Viewed (1) -
docs/metrics/prometheus/grafana/node/minio-node.json
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 15:14:26 GMT 2024 - 23.1K bytes - Viewed (0) -
src/test/java/jcifs/tests/KerberosTest.java
super(subject, domain, username, password); } @Override public void refresh () throws CIFSException { try { System.out.println("Refreshing"); setSubject(getInitiatorSubject(getTestUser(), getTestUserPassword(), getTestUserDomainRequired(), null));
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Mar 01 09:46:04 GMT 2020 - 11.5K bytes - Viewed (0) -
internal/dsync/dsync_test.go
dm2 := NewDRWMutex(ds, "noot") dm1.Lock(id, source) dm2.Lock(id, source) dm1.Unlock(context.Background()) dm2.Unlock(context.Background()) } // Test refreshing lock - refresh should always return true func TestSuccessfulLockRefresh(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") } dm := NewDRWMutex(ds, "aap")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0)