- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for star (0.13 sec)
-
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
protected long schedulerTime; @Override public void schedule(final LaCron cron) { schedulerTime = systemHelper.getCurrentTimeAsLong(); scheduledJobService.start(cron); final String myName = fessConfig.getSchedulerTargetName(); if (StringUtil.isNotBlank(myName)) { ComponentUtil.getComponent(JobLogBhv.class).queryDelete(cb -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
environment.put("OPENSEARCH_URL", SystemUtil.getSearchEngineHttpAddress()); }); final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/searchlist/ListForm.java
public Map<String, String[]> getConditions() { return as; } @Override public int getStartPosition() { if (start == null) { start = ComponentUtil.getFessConfig().getPagingSearchPageStartAsInteger(); } return start; } @Override public int getOffset() { if (offset == null) { offset = 0; } return offset;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
@Execute public HtmlResponse index() { throw new UnsupportedOperationException(); } // POST /api/admin/scheduler/{id}/start @Execute(urlPattern = "{}/@word") public JsonResponse<ApiResult> post$start(final String id) { scheduledJobService.getScheduledJob(id).ifPresent(entity -> { if (!entity.isEnabled() || entity.isRunning()) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/QueryResponseList.java
protected long queryTime; // for testing protected QueryResponseList(final List<Map<String, Object>> documentList, final int start, final int pageSize, final int offset) { this.parent = documentList; this.offset = offset; this.start = start; this.pageSize = pageSize; }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
final ProcessBuilder pb = new ProcessBuilder(cmdList); pbCall.accept(pb); destroyProcess(sessionId); JobProcess jobProcess; try { jobProcess = new JobProcess(pb.start(), bufferSize, outputCallback); destroyProcess(sessionId, runningProcessMap.putIfAbsent(sessionId, jobProcess)); return jobProcess; } catch (final IOException e) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java
void jobLogTest() { logger.info("start jobLogTest"); testReadJobLog(); testDeleteJobLog(); } @Test void crawlingInfoTest() { logger.info("start crawlingInfoTest"); testReadCrawlingInfo(); testDeleteCrawlingInfo(); } @Test void failureUrlTest() { logger.info("start failureUrlTest"); testReadFailureUrl();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/SearchForm.java
@ValidateTypeFailure public Integer start; @ValidateTypeFailure public Integer offset; @ValidateTypeFailure public Integer pn; @Size(max = 1000) public String sdh; @Size(max = 100) public String track_total_hits; // advance @Override public int getStartPosition() { if (start == null) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
MonitorThread mt = null; try { currentProcess = pb.start(); // monitoring mt = new MonitorThread(currentProcess, executionTimeout); mt.start(); final InputStreamThread it = new InputStreamThread(currentProcess.getInputStream(), commandOutputEncoding, maxOutputLine); it.start(); currentProcess.waitFor(); it.join(5000);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java
cb.query().addOrderBy_SortOrder_Asc(); cb.query().addOrderBy_Name_Asc(); cb.fetchFirst(fessConfig.getPageScheduledJobMaxFetchSizeAsInteger()); }); } public void start(final LaCron cron) { scheduledJobBhv.selectCursor(cb -> { cb.query().setAvailable_Equal(Constants.T); cb.query().addOrderBy_SortOrder_Asc(); cb.query().addOrderBy_Name_Asc();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.7K bytes - Viewed (0)