Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 1,639 for dead (0.03 sec)

  2. github.com/minio/minio

    internal/s3select/json/preader.go 

    	dst   chan []jstream.KVS // result of block decode
	err   error              // any error encountered will be set here
}

// Read - reads single record.
// Once Read is called the previous record should no longer be referenced.
func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
	// If we have have any records left, return these before any error.
	for len(r.current) <= r.recordsRead {
		if r.err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. github.com/codelibs/fess

    src/main/webapp/WEB-INF/view/admin/sereq/admin_sereq.jsp 

    <%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
	<head>
	<meta charset="UTF-8">
	<title><la:message key="labels.admin_brand_title" /> | <la:message
			key="labels.sereq_configuration" /></title>
	<jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
	<div class="wrapper">
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 13 05:54:52 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  4. github.com/google/guava

    android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java 

          if (i == 0) {
        head = chain;
      }
    }
  }

  @SuppressWarnings("GuardedBy")
  @Benchmark
  int time(int reps) {
    int dummy = 0;
    for (int i = 0; i < reps; i++) {
      // TODO(b/145386688): This access should be guarded by 'this.segment', which is not currently
      // held
      segment.removeEntryFromChain(chain, head);
      dummy += segment.count;
    }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. github.com/square/okhttp

    okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt 

    ) {
  private val countingSource: CountingSource = CountingSource(source)
  private val source: BufferedSource = countingSource.buffer()

  /** Total bytes read thus far. */
  private val byteCount: Long
    get() = countingSource.bytesRead - source.buffer.size

  /** How many bytes to read before [peekHeader] should return false, or -1L for no limit. */
  private var limit = -1L
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  6. github.com/codelibs/curl4j

    src/main/java/org/codelibs/curl/io/ContentCache.java 

            }
    }

    /**
     * Returns an InputStream to read the content from the cache.
     * If the content is stored in a file, a FileInputStream is returned.
     * Otherwise, a ByteArrayInputStream is returned to read the data from memory.
     *
     * @return an InputStream to read the cached content
     * @throws IOException if an I/O error occurs while creating the InputStream
     */
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  7. github.com/google/guava

    guava-tests/test/com/google/common/io/MultiInputStreamTest.java 

        ByteStreams.skipFully(multi, 20);
    assertEquals(20, multi.read());
  }

  public void testReadSingle_noStackOverflow() throws IOException {
    // https://github.com/google/guava/issues/2996
    // no data, just testing that there's no StackOverflowException
    assertEquals(-1, tenMillionEmptySources().read());
  }

  public void testReadArray_noStackOverflow() throws IOException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  8. github.com/google/guava

    android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java 

        ByteStreams.skipFully(multi, 20);
    assertEquals(20, multi.read());
  }

  public void testReadSingle_noStackOverflow() throws IOException {
    // https://github.com/google/guava/issues/2996
    // no data, just testing that there's no StackOverflowException
    assertEquals(-1, tenMillionEmptySources().read());
  }

  public void testReadArray_noStackOverflow() throws IOException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  9. github.com/golang/go

    src/bufio/net_test.go 

    	if err != nil {
		t.Skipf("skipping test because opening a unixpacket socket failed: %v", err)
	}

	// Start a goroutine for the server to accept one connection
	// and read all the data sent on the connection,
	// reporting the number of bytes read on ch.
	ch := make(chan int, 1)
	var wg sync.WaitGroup
	wg.Add(1)
	go func() {
		defer wg.Done()

		tot := 0
		defer func() {
			ch <- tot
		}()
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Feb 07 19:37:07 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  10. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt 

        val body = body("")
    val bytes = body.byteStream()
    assertThat(bytes.read()).isEqualTo(-1)
  }

  @Test
  fun byteStreamSeesBom() {
    val body = body("efbbbf68656c6c6f")
    val bytes = body.byteStream()
    assertThat(bytes.read()).isEqualTo(0xef)
    assertThat(bytes.read()).isEqualTo(0xbb)
    assertThat(bytes.read()).isEqualTo(0xbf)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  11. github.com/codelibs/fess-crawler

    fess-crawler/src/test/resources/extractor/test_entity.xml 

    <?xml version="1.0"?>
<html>
<head>
<title>&#12479;&#12452;&#12488;&#12523;</title>
</head>
<body>
<div>&#12486;&#12473;&#12488;</div>
</body>
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Oct 11 02:16:55 UTC 2015
    - 151 bytes
    - Viewed (0)
Back to top