- Sort Score
- Num 10 results
- Language All
Results 761 - 770 of 816 for Gevent (0.14 seconds)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java
// destroyObject should continue and close the resource even if listener throws factoryWithListener.destroyObject(pooledObject); // Resource should still be closed despite listener exception assertTrue("Component should be closed even if listener throws", component.isClosed()); } /** * Test destroyObject with AutoCloseable componentCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 13:07:01 GMT 2025 - 36.7K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* listeners can harm responsiveness, slow the system as a whole, or worse. (See also the * note about locking below.) * <li>If many tasks will be triggered by the same event, one heavyweight task may delay other * tasks -- even tasks that are not themselves {@code directExecutor} tasks. * <li>If many such tasks are chained together (such as with {@code
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 45.2K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Converter.java
* Function<A, B> or who call convertAll (and for any checkers that apply @PolyNull-like semantics * to Converter.convert). So maybe we don't want to think too hard about how to prevent our * checkers from issuing errors related to LegacyConverter, since it turns out that * LegacyConverter does violate the assumptions we make elsewhere. */ private @Nullable B unsafeDoForward(@Nullable A a) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jun 18 21:43:06 GMT 2025 - 22.8K bytes - Click Count (0) -
cmd/erasure-healing.go
func (er *erasureObjects) auditHealObject(ctx context.Context, bucket, object, versionID string, result madmin.HealResultItem, err error) { if len(logger.AuditTargets()) == 0 { return } opts := AuditLogOptions{ Event: "HealObject", Bucket: bucket, Object: decodeDirObject(object), VersionID: versionID, } if err != nil { opts.Error = err.Error() } b, a := result.GetCorruptedCounts()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
assertThat(response.body.string()).isNotEmpty() } if (!platform.isJdk8()) { val connectCount = eventRecorder.eventSequence .stream() .filter { event: CallEvent? -> event is ConnectStart } .count() assertThat(connectCount).isEqualTo(1) } } /** Test which headers are sent unencrypted to the HTTP proxy. */ @Test
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 147.4K bytes - Click Count (0) -
scripts/translate.py
interpret literally. The `«` and the `»` are not part of the literal text, they are the meta characters denoting it. 2) Furthermore, text surrounded by `«««` and `»»»` is a BLOCK OF LITERAL TEXT which spans multiple lines. To get its content, dedent all lines of the block until the `«««` and `»»»` are at column zero, then remove the newline (`\n`) after the `«««` and the newline before the `»»»`. The `«««` and the `»»»` are not part of the literal text block, they are the meta characters denoting...
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 27 19:05:53 GMT 2025 - 34.1K bytes - Click Count (0) -
LICENSE
IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF ALL NECESSARY SERVICING, REPAIR OR CORRECTION. 16. Limitation of Liability. IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 33.7K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteSource.java
* bytes of the source as they are read from it. A source that provides such streams will not * be reusable, and operations that read from the stream (including {@link #size()}, in some * implementations) will prevent further operations from completing as expected. * </ul> * * @since 14.0 * @author Colin Decker */ @J2ktIncompatible @GwtIncompatible public abstract class ByteSource {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.7K bytes - Click Count (0) -
cmd/xl-storage-disk-id-check.go
continue } err = p.storage.Delete(context.Background(), minioMetaTmpBucket, fn, DeleteOptions{ Recursive: false, Immediate: false, }) if err == nil { logger.Event(context.Background(), "healthcheck", "node(%s): Read/Write/Delete successful, bringing drive %s online", globalLocalNodeName, p.storage.String()) p.health.status.Store(diskHealthOK) p.health.waiting.Add(-1) return
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/Constants.java
* <li>Authentication type identifiers</li> * <li>Reserved words and regex patterns for query processing</li> * </ul> */ public class Constants extends CoreLibConstants { /** * Private constructor to prevent instantiation of this utility class. * This class contains only static constants and should not be instantiated. */ private Constants() { // Utility class - no instantiation }
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Dec 13 02:21:17 GMT 2025 - 35.2K bytes - Click Count (0)