- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 407 for stopfn (0.04 seconds)
-
android/guava/src/com/google/common/base/Stopwatch.java
startTick = ticker.read(); return this; } /** * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this * point. * * @return this {@code Stopwatch} instance * @throws IllegalStateException if the stopwatch is already stopped. */ @CanIgnoreReturnValue public Stopwatch stop() { long tick = ticker.read();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 9.5K bytes - Click Count (0) -
internal/event/target/elasticsearch.go
} // Close - does nothing and available for interface compatibility. func (target *ElasticsearchTarget) Close() error { close(target.quitCh) if target.client != nil { // Stops the background processes that the client is running. target.client.stop() } return nil } func (target *ElasticsearchTarget) checkAndInitClient(ctx context.Context) error { if target.client != nil { return nil }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
} }, scheduler); asyncNotifyTasks.put(registrationId, asyncTask); log.debug("Started async notification monitoring for {}", registrationId); } /** * Stops asynchronous notification monitoring for a registration. * * @param registrationId the registration ID */ private void stopAsyncNotificationMonitoring(String registrationId) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
return finished; } /** * Stops the crawling operation gracefully. * If a data store is currently active, this method calls * its stop method to halt the crawling process. */ public void stopCrawling() { if (dataStore != null) { dataStore.stop(); } } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 19K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
} } /** * Forces all crawlers to stop immediately. * Sets the force stop flag and stops all active crawler instances. */ private void forceStop() { systemHelper.setForceStop(true); if (crawlerList != null) { for (final Crawler crawler : crawlerList) { crawler.stop(); } } } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 32.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java
}); return redirect(getClass()); } /** * Stops a running scheduled job. * * @param form the edit form containing the ID of the job to stop * @return HTML response redirecting to the list page after stopping */ @Execute @Secured({ ROLE }) public HtmlResponse stop(final EditForm form) { verifyCrudMode(form.crudMode, CrudMode.DETAILS, this::asListHtml);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 13:56:35 GMT 2025 - 21.8K bytes - Click Count (0) -
src/builtin/builtin.go
// // x, ok := <-c // // will also set ok to false for a closed and empty channel. func close(c chan<- Type) // The panic built-in function stops normal execution of the current // goroutine. When a function F calls panic, normal execution of F stops // immediately. Any functions whose execution was deferred by F are run in // the usual way, and then F returns to its caller. To the caller G, the
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Feb 26 17:14:40 GMT 2026 - 13.2K bytes - Click Count (0) -
cmd/admin-heal-ops.go
defer h.mutex.RUnlock() // background heal never ends if h.clientToken == bgHealingUUID { return false } return !h.endTime.IsZero() } // stops the heal sequence - safe to call multiple times. func (h *healSequence) stop() { h.cancelCtx() } // pushHealResultItem - pushes a heal result item for consumption in // the heal-status API. It blocks if there are
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance_gen.go
return } switch msgp.UnsafeString(field) { case "startTs": z.StartTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "StartTime") return } case "stopTs": z.EndTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "EndTime") return } case "status": { var zb0002 uint8 zb0002, err = dc.ReadUint8()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.8K bytes - Click Count (0) -
docs/en/docs/deployment/docker.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 28.3K bytes - Click Count (1)