- Sort Score
- Result 10 results
- Languages All
Results 841 - 850 of 1,214 for dead (0.02 sec)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
// A happens-before edge between the writes of these fields and their reads exists, because // in order to read these fields, the corresponding write to incompleteOutputCount must have // been read. private boolean wasCancelled = false; private boolean shouldInterrupt = true; private final AtomicInteger incompleteOutputCount;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/Invokable.java
import java.util.Arrays; import org.jspecify.annotations.Nullable; /** * Wrapper around either a {@link Method} or a {@link Constructor}. Convenience API is provided to * make common reflective operation easier to deal with, such as {@link #isPublic}, {@link * #getParameters} etc. * * <p>In addition to convenience methods, {@link TypeToken#method} and {@link TypeToken#constructor}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 18.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/InputStreamThreadTest.java
} public void test_run_withIOException() throws InterruptedException { InputStream faultyStream = new InputStream() { @Override public int read() throws IOException { throw new IOException("Test exception"); } }; InputStreamThread thread = new InputStreamThread(faultyStream, StandardCharsets.UTF_8, 10, null);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 11.7K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/CurlResponseTest.java
response.setContentCache(cache); try (InputStream stream = response.getContentAsStream()) { assertNotNull(stream); byte[] buffer = new byte[1024]; int bytesRead = stream.read(buffer); assertEquals(data.length, bytesRead); assertArrayEquals(data, Arrays.copyOf(buffer, bytesRead)); } } @Test public void testGetContentAsStreamWithoutCache() {
Registered: Thu Sep 04 15:34:10 UTC 2025 - Last Modified: Thu Jul 31 01:01:12 UTC 2025 - 11.5K bytes - Viewed (0) -
cmd/batch-job-common-types.go
// compress: true # S2/Snappy compressed archive // smallerThan: 5MiB # create archive for all objects smaller than 5MiB // skipErrs: false # skips any source side read() errors // BatchJobSnowball describes the snowball feature when replicating objects from a local source to a remote target type BatchJobSnowball struct { line, col int
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 7.9K bytes - Viewed (0) -
ci/devinfra/docker/windows/Dockerfile
# This should only be necessary when running on A GCP VM, on a default # network, which has the MTU of 1460, # due to 40 bytes being reserved for GCP's internal usage. # Note, an invalid sub-interface name will lead to an obscure error, e.g.: # "The filename, directory name, or volume label syntax is incorrect." # In such cases, check that the name of the sub-interface is valid: # `netsh interface show interface`
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Jan 17 16:35:57 UTC 2025 - 8.4K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
val connectTimeout: Int by option( "--connect-timeout", ).help( "Maximum time allowed for connection (seconds)", ).int() .default(DEFAULT_TIMEOUT) val readTimeout: Int by option("--read-timeout") .help("Maximum time allowed for reading data (seconds)") .int() .default(DEFAULT_TIMEOUT) val callTimeout: Int by option( "--call-timeout", ).help(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NbtSocket.java
log.println("session established ok with " + address); } return; case SessionServicePacket.NEGATIVE_SESSION_RESPONSE: final int errorCode = in.read() & 0xFF; close(); throw new NbtException(NbtException.ERR_SSN_SRVC, errorCode); case -1: throw new NbtException(NbtException.ERR_SSN_SRVC, NbtException.CONNECTION_REFUSED);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6.1K bytes - Viewed (0) -
src/test/java/jcifs/smb1/dcerpc/DcerpcMessageTest.java
m.ptype = 0; m.flags = 0x05; m.call_id = 0x123; NdrBuffer buf = new NdrBuffer(new byte[1024], 0); m.encode(buf); // Reset to read what was written buf.setIndex(0); // Verify header was written correctly assertEquals(5, buf.dec_ndr_small()); // RPC version assertEquals(0, buf.dec_ndr_small()); // minor version
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/CustomTrust.java
+ "-----END CERTIFICATE-----"); private final OkHttpClient client; public CustomTrust() { // This implementation just embeds the PEM files in Java strings; most applications will // instead read this from a resource file that gets bundled with the application. HandshakeCertificates certificates = new HandshakeCertificates.Builder() .addTrustedCertificate(letsEncryptCertificateAuthority)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 9.3K bytes - Viewed (0)