- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 64 for Rescheduler (0.07 seconds)
-
src/main/java/org/codelibs/fess/helper/JobHelper.java
jobManager.schedule(cron -> register(cron, scheduledJob)); } /** * Registers a scheduled job with the specified cron scheduler. * * @param cron the cron scheduler to use * @param scheduledJob the scheduled job to register */ public void register(final LaCron cron, final ScheduledJob scheduledJob) { if (scheduledJob == null) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerActionTest.java
import org.lastaflute.job.subsidiary.LaunchNowOption; import org.lastaflute.job.subsidiary.LaunchedProcess; import org.lastaflute.web.response.JsonResponse; /** * Tests for the scheduler start API endpoint contract. * Verifies that {@code PUT /api/admin/scheduler/{id}/start} returns the correct * {@code jobLogId} based on the job's logging configuration. */ public class ApiAdminSchedulerActionTest extends UnitFessTestCase { @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 11:55:54 GMT 2026 - 13K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
} }; TestCustomScheduler scheduler = new TestCustomScheduler(); Cancellable future = scheduler.schedule(null, newScheduledThreadPool(10), task); firstBarrier.await(); assertEquals(1, scheduler.scheduleCounter.get()); secondBarrier.await(); firstBarrier.await(); assertEquals(2, scheduler.scheduleCounter.get()); shouldWait.set(false); secondBarrier.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
} }; TestCustomScheduler scheduler = new TestCustomScheduler(); Cancellable future = scheduler.schedule(null, newScheduledThreadPool(10), task); firstBarrier.await(); assertEquals(1, scheduler.scheduleCounter.get()); secondBarrier.await(); firstBarrier.await(); assertEquals(2, scheduler.scheduleCounter.get()); shouldWait.set(false); secondBarrier.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
} /** * Retrieves scheduler settings with pagination. * * @param body the search parameters for filtering and pagination * @return JSON response containing scheduler settings list */ // GET /api/admin/scheduler // PUT /api/admin/scheduler @Execute public JsonResponse<ApiResult> settings(final SearchBody body) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 11:55:54 GMT 2026 - 10.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
while (count < 1500 && !isRunning) { ThreadUtil.sleep(sleepTime); count++; final Map<String, Object> scheduler = getSchedulerItem(namePrefix); assertTrue(scheduler.containsKey("running")); isRunning = (Boolean) scheduler.get("running"); // Exponential backoff: gradually increase sleep time up to 300ms if (count % 5 == 0 && sleepTime < 300) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 10.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/app/job/AllJobSchedulerTest.java
final AllJobScheduler scheduler = new AllJobScheduler(); assertTrue(scheduler instanceof LaJobScheduler); } public void test_AllJobScheduler_creation() { final AllJobScheduler scheduler = new AllJobScheduler(); assertNotNull(scheduler); } public void test_setJobClass() { final AllJobScheduler scheduler = new AllJobScheduler();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 12:58:11 GMT 2026 - 1.6K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.31.md
/docker/k8s-artifacts-prod/southamerica-east1/images/kube-scheduler) | [amd64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/kube-scheduler-amd64), [arm64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/kube-scheduler-arm64), [ppc64le](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/kube-scheduler-ppc64le), [s390x](https://console.cloud.google.com/artifa...
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Wed Nov 12 11:33:21 GMT 2025 - 451.9K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/admin/scheduler/admin_scheduler.jsp
<jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp"> <jsp:param name="menuCategoryType" value="system"/> <jsp:param name="menuType" value="scheduler"/> </jsp:include> <main class="content-wrapper"> <div class="content-header"> <div class="container-fluid"> <div class="row mb-2"> <div class="col-sm-6">
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 6.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
@Resource private SystemHelper systemHelper; @Resource private JobHelper jobHelper; /** The job class to be executed by this scheduler */ protected Class<? extends LaJob> jobClass = ScriptExecutorJob.class; /** The timestamp when the scheduler was last updated */ protected long schedulerTime; @Override public void schedule(final LaCron cron) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 4.3K bytes - Click Count (0)