- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for tryStartOperation (0.06 seconds)
-
src/test/java/org/codelibs/fess/helper/CoordinatorHelperTest.java
public void test_tryStartOperation_singleArg_delegatesToTwoArg() { // tryStartOperation(name) should delegate to tryStartOperation(name, null) final AtomicReference<String> passedData = new AtomicReference<>("NOT_NULL"); final CoordinatorHelper helper = new CoordinatorHelper() { @Override public boolean tryStartOperation(final String operationName, final String data) { passedData.set(data);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 58.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
* * @param operationName the operation name used as the lock document ID. * @return {@code true} if the lock was acquired. */ public boolean tryStartOperation(final String operationName) { return tryStartOperation(operationName, null); } /** * Attempts to acquire a distributed lock for the specified operation with optional data. *Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
validate(form, messages -> {}, this::asIndexHtml); verifyToken(this::asIndexHtml); final CoordinatorHelper coordinator = ComponentUtil.getCoordinatorHelper(); if (!coordinator.tryStartOperation("reload_doc_index")) { saveError(messages -> messages.addErrorsOperationAlreadyRunning(GLOBAL, coordinator.getOperationInfo("reload_doc_index").map(o -> o.hostname).orElse("unknown")));
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 23K bytes - Click Count (0)