- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 993 for bosh (0.81 sec)
-
docs/en/docs/async.md
### Concurrency and Burgers { #concurrency-and-burgers } This idea of **asynchronous** code described above is also sometimes called **"concurrency"**. It is different from **"parallelism"**. **Concurrency** and **parallelism** both relate to "different things happening more or less at the same time". But the details between *concurrency* and *parallelism* are quite different. To see the difference, imagine the following story about burgers:Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 24K bytes - Viewed (0) -
docs/bucket/lifecycle/setup_ilm_transition.sh
#!/usr/bin/env bash set -x trap 'catch $LINENO' ERR # shellcheck disable=SC2120 catch() { if [ $# -ne 0 ]; then echo "error on line $1" for site in sitea siteb; do echo "$site server logs =========" cat "/tmp/${site}_1.log" echo "===========================" cat "/tmp/${site}_2.log" done fi echo "Cleaning up instances of MinIO" pkill minio pkill -9 minio rm -rf /tmp/multisiteaRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 2.8K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/rules/IncubatingInternalInterfaceAddedRuleTest.groovy
where: type | result 'internal' | "\"${replaceAsInternal(InternalInterface.name)}\"" 'incubating' | "\"${IncubatingInterface.name}\"" } def "do not report if they are both incubating"() { given: apiClass.newClass >> Optional.of(newIncubatingBase) newSuper.addInterface(incubatingInterface) expect: noViolation(rule) }Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Dec 24 14:15:15 UTC 2025 - 4K bytes - Viewed (0) -
src/test/java/jcifs/ntlmssp/av/AvTargetNameTest.java
assertEquals(originalString, avTargetName.getTargetName(), "Retrieved target name should correctly decode raw bytes"); } /** * Test with an empty string for both constructors. */ @Test void testEmptyString() { String emptyString = ""; AvTargetName avTargetNameFromString = new AvTargetName(emptyString);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.1K bytes - Viewed (0) -
src/test/java/jcifs/CIFSUnsupportedCryptoExceptionTest.java
assertEquals(cause.toString(), exception.getMessage(), "Message should be cause.toString() when only cause is provided"); } @Test @DisplayName("Message and cause constructor should preserve both crypto parameters") void testMessageAndCauseConstructor() { // Given NoSuchAlgorithmException cause = new NoSuchAlgorithmException("Algorithm not found"); // When
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.1K bytes - Viewed (0) -
okhttp/src/jvmMain/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
} } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is org.openjsse.javax.net.ssl.SSLSocket) { when (val protocol = sslSocket.applicationProtocol) { // Handles both un-configured and none selected. null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object { val isSupported: Boolean =
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/math/BigDecimalMath.java
* default rounding mode: if the two nearest representable values are equally near, the one with * the least significant bit zero is chosen. (In such cases, both of the nearest representable * values are even integers; this method returns the one that is a multiple of a greater power of * two.) *
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
*/ protected byte[] gzipCompress(final byte[] data) { try (final ByteArrayOutputStream bos = new ByteArrayOutputStream()) { try (final GZIPOutputStream gzipOut = new GZIPOutputStream(bos)) { gzipOut.write(data); } return bos.toByteArray(); } catch (final IOException e) { throw new IORuntimeException(e); } }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 05:56:45 UTC 2025 - 36.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// // So that is why we cancel only in the case of CAS success. taskFuture.cancel(false); } }; // Adding the listener to both futures guarantees that newFuture will always be set. Adding to // taskFuture guarantees completion if the callable is invoked, and adding to outputFuture // propagates cancellation if the callable has not yet been invoked.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/DirectedGraphConnections.java
* @author Jens Nyman * @param <N> Node parameter type * @param <V> Value parameter type */ final class DirectedGraphConnections<N, V> implements GraphConnections<N, V> { /** * A wrapper class to indicate a node is both a predecessor and successor while still providing * the successor value. */ private static final class PredAndSucc { private final Object successorValue; PredAndSucc(Object successorValue) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 17.8K bytes - Viewed (0)