Search Options

Results per page
Sort
Preferred Languages
Advance

Results 841 - 850 of 1,214 for dead (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top