- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 462 for slop (0.03 sec)
-
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) if opts.UserTimeout > 0 { _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) } if opts.Interface != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
} } public void addExcludeFilter(final String regexp) { if (StringUtil.isNotBlank(regexp)) { urlFilter.addExclude(regexp); } } public void stop() { crawlerContext.setStatus(CrawlerStatus.DONE); try { if (crawlerThreadGroup != null) { crawlerThreadGroup.interrupt(); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 7.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableTableTest.java
assertThat(copy.columnKeySet()).containsExactlyElementsIn(original.columnKeySet()).inOrder(); } @J2ktIncompatible @GwtIncompatible // Mind-bogglingly slow in GWT @AndroidIncompatible // slow public void testOverflowCondition() { // See https://github.com/google/guava/issues/1322 for details. ImmutableTable.Builder<Integer, Integer, String> builder = ImmutableTable.builder();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 18.5K bytes - Viewed (0) -
cmd/admin-router.go
adminAPIVersionPrefix, } for _, adminVersion := range adminVersions { // Restart and stop MinIO service type=2 adminRouter.Methods(http.MethodPost).Path(adminVersion+"/service").HandlerFunc(adminMiddleware(adminAPI.ServiceV2Handler, traceAllFlag)).Queries("action", "{action:.*}", "type", "2") // Deprecated: Restart and stop MinIO service.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 21 11:35:40 UTC 2024 - 26.2K bytes - Viewed (0) -
guava/src/com/google/common/io/LittleEndianDataOutputStream.java
super(new DataOutputStream(Preconditions.checkNotNull(out))); } @Override public void write(byte[] b, int off, int len) throws IOException { // Override slow FilterOutputStream impl out.write(b, off, len); } @Override public void writeBoolean(boolean v) throws IOException { ((DataOutputStream) out).writeBoolean(v); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 12:34:49 UTC 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/AbstractDataStore.java
protected boolean alive = true; public void register() { ComponentUtil.getDataStoreFactory().add(getName(), this); } protected abstract String getName(); @Override public void stop() { alive = false; } @Override public void store(final DataConfig config, final IndexUpdateCallback callback, final DataStoreParams initParamMap) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/Constants.java
public static final String DONE = "done"; public static final String OK = "ok"; public static final String FAIL = "fail"; public static final String STOP = "stop"; public static final String AUTO = "auto"; public static final String NONE = "none"; public static final String ITEM_LABEL = "label"; public static final String ITEM_VALUE = "value";
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Aug 22 12:43:18 UTC 2024 - 16.6K bytes - Viewed (0) -
internal/pubsub/pubsub.go
numSubscribers int32 maxSubscribers int32 // not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
docs/tr/docs/async.md
Böylece, bu süreçte bilgisayar "slow-file" 📝 tamamlanırken gidip başka işler yapabilir. Sonra bilgisayar / program 🤖 her fırsatı olduğunda o noktada yaptığı tüm işleri 🤖 bitirene kadar geri dönücek. Ve 🤖 yapması gerekeni yaparak, beklediği görevlerden herhangi birinin bitip bitmediğini görecek.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 21.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
* #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the * method to cancel pending work and then call {@link #notifyStopped} to stop the service. * * <p>This method should return promptly; prefer to do work on a different thread where it is * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0)