Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 252 for refresh (0.04 sec)

  1. src/test/java/org/codelibs/fess/suggest/settings/SuggestSettingsTest.java

        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
        public void test_defaultSettings() throws Exception {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    			delete(l.lockUID, mapID)
    			idx++
    			continue
    		}
    		reply = true
    		l.removeEntry(resource, dsync.LockArgs{UID: args.UID}, &lris)
    		idx++
    	}
    }
    
    func (l *localLocker) Refresh(ctx context.Context, args dsync.LockArgs) (refreshed bool, err error) {
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    
    	defer l.getMutex()()
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

            }
        }
    
        /**
         * Refreshes the OpenSearch index to make recent changes visible for search.
         *
         * @return The RefreshResponse from OpenSearch.
         * @throws OpenSearchAccessException if the refresh operation fails.
         */
        protected RefreshResponse refresh() {
            try {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  4. okhttp-osgi-tests/src/test/kotlin/okhttp3/osgi/OsgiTest.kt

              LocalIndexedRepo::class.java.getName() +
                "; ${LocalIndexedRepo.PROP_NAME} = '$REPO_NAME'" +
                "; ${LocalIndexedRepo.PROP_LOCAL_DIR} = '$repoDir'",
            )
            refresh()
            prepareWorkspace()
          }
      }
    
      private fun Workspace.prepareWorkspace() {
        val repositoryPlugin = getRepository(REPO_NAME)
    
        // Deploy the bundles in the deployments test directory.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/RemovalCause.java

          return false;
        }
      },
    
      /**
       * The entry itself was not actually removed, but its value was replaced by the user. This can
       * result from the user invoking {@link Cache#put}, {@link LoadingCache#refresh}, {@link Map#put},
       * {@link Map#putAll}, {@link ConcurrentMap#replace(Object, Object)}, or {@link
       * ConcurrentMap#replace(Object, Object, Object)}.
       */
      REPLACED {
        @Override
        boolean wasEvicted() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/suggest/settings/ArraySettingsTest.java

        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
        public void test_setAndGetAsArray() {
            String key = "key";
            String value1 = "a";
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/RemovalCause.java

          return false;
        }
      },
    
      /**
       * The entry itself was not actually removed, but its value was replaced by the user. This can
       * result from the user invoking {@link Cache#put}, {@link LoadingCache#refresh}, {@link Map#put},
       * {@link Map#putAll}, {@link ConcurrentMap#replace(Object, Object)}, or {@link
       * ConcurrentMap#replace(Object, Object, Object)}.
       */
      REPLACED {
        @Override
        boolean wasEvicted() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/suggest/settings/ElevateWordSettingsTest.java

        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
        public void test_elevateWordIndexName() {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

        /**
         * Stores (inserts or updates) a crawling information record.
         * Sets up the store conditions including creation time if not already set,
         * then performs an insert or update operation with immediate refresh.
         *
         * @param crawlingInfo the crawling information entity to store
         * @throws FessSystemException if the crawling information is null
         */
        public void store(final CrawlingInfo crawlingInfo) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  10. cmd/common-main.go

    		} else {
    			dnsTTL = 10 * time.Minute
    		}
    	}
    
    	// Call to refresh will refresh names in cache.
    	go func() {
    		// Baremetal setups set DNS refresh window up to dnsTTL duration.
    		t := time.NewTicker(dnsTTL)
    		defer t.Stop()
    		for {
    			select {
    			case <-t.C:
    				globalDNSCache.Refresh()
    
    			case <-GlobalContext.Done():
    				return
    			}
    		}
    	}()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
Back to top