Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 64 for Rescheduler (0.07 seconds)

  1. 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)
  2. 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 {
    
        @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 13K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top