- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 228 for Pairing (0.23 sec)
-
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards"; private static final String TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS = "task_max_waiting_in_queue_millis"; private static final String ACTIVE_SHARDS_PERCENT_AS_NUMBER = "active_shards_percent_as_number"; private static final String ACTIVE_PRIMARY_SHARDS = "active_primary_shards";
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) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
// actual response status. code == 100 -> true // Handle Processing (102) & Early Hints (103) and any new codes without failing // 100 and 101 are the exceptions with different meanings // But Early Hints not currently exposed code in (102 until 200) -> true else -> false }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0) -
cmd/leak-detect_test.go
} // DetectLeak - Creates a snapshot of runtime stack and compares it with the initial stack snapshot. func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) { if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
.github/workflows/multipart/migrate.sh
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 15:54:24 GMT 2024 - 4.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} } private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycles.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * @since 3.0 */ // TODO The configuration for the lifecycle needs to be externalized so that I can use the annotations properly for the // wiring and reference and external source for the lifecycle configuration. @Named @Singleton public class DefaultLifecycles { public static final String[] STANDARD_LIFECYCLES = {"clean", "default", "site", "wrapper"};
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* stored bytes exceeds the limit, the cache will remove entries in the background until the limit * is satisfied. The limit is not strict: the cache may temporarily exceed it while waiting for * files to be deleted. The limit does not include filesystem overhead or the cache journal so * space-sensitive applications should set a conservative limit. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* is used to calculate this value. It also doesn't include any bytes buffered by the operating * system or network intermediaries. This method returns 0 if no messages are waiting in the * queue. If may return a nonzero value after the web socket has been canceled; this indicates * that enqueued messages were not transmitted. */ fun queueSize(): Long /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocketChannelTest.kt
assumeFalse( socketMode is TlsInstance && socketMode.socketMode == Channel && socketMode.protocol == HTTP_2 && socketMode.tlsExtensionMode == STANDARD, "failing for channel and h2", ) if (socketMode is TlsInstance) { assumeTrue((socketMode.provider == CONSCRYPT) == platform.isConscrypt()) } val client =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8K bytes - Viewed (0)