poodlE - Code Search

src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

        append(buf, "committed", () -> mem.getNonHeapCommitted().getBytes());
        buf.append('}');
        buf.append("},");
        final List<BufferPool> bufferPools = jvmStats.getBufferPools();
        buf.append("\"pools\":{");
        buf.append(bufferPools.stream().map(p -> {
            final StringBuilder b = new StringBuilder();
            b.append('"').append(StringEscapeUtils.escapeJson(p.getName())).append("\":{");

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 7.8K bytes

- Click Count (0)

github.com/minio/minio

internal/grid/grid.go

	// Used if no deadline is provided on context.
	defaultSingleRequestTimeout = time.Minute
)

var internalByteBuffer = bpool.Pool[*[]byte]{
	New: func() *[]byte {
		m := make([]byte, 0, defaultBufferSize)
		return &m
	},
}

var internal32KByteBuffer = bpool.Pool[*[]byte]{
	New: func() *[]byte {
		m := make([]byte, 0, biggerBufMin)
		return &m
	},
}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Mar 30 00:56:02 GMT 2025

- 7K bytes

- Click Count (0)

github.com/go-gorm/gorm

tests/prepared_stmt_test.go

		t.Fatalf("Failed, got error: %v, rows affected: %v", result.Error, result.RowsAffected)
	}

	tx2.Commit()
	// Attempt to convert the connection pool of tx to the *gorm.PreparedStmtDB type.
	// If the conversion is successful, ok will be true and conn will be the converted object;
	// otherwise, ok will be false and conn will be nil.

Created: Sun Apr 05 09:35:12 GMT 2026

- Last Modified: Fri Apr 25 08:22:26 GMT 2025

- 8K bytes

- Click Count (0)

github.com/square/okhttp

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

      .build()
    assertThat(original.interceptors.size).isEqualTo(0)
    assertThat(original.networkInterceptors.size).isEqualTo(0)
  }

  /**
   * When copying the client, stateful things like the connection pool are shared across all
   * clients.
   */
  @Test fun cloneSharesStatefulInstances() {
    val client = clientTestRule.newClient()

    // Values should be non-null.
    val a = client.newBuilder().build()

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Feb 03 22:17:59 GMT 2026

- 13.4K bytes

- Click Count (1)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

     * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
     *
     * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
     * pool thread, the thread pool will reset it for us. Otherwise, the interrupted bit may have
     * been intended for something else, so don't clear it.
     */
    boolean restoreInterruptedBit = false;
    int spinCount = 0;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jan 28 22:39:02 GMT 2026

- 10K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/CurlRequest.java

            throw new CurlException("Invalid encoding: " + encoding, e);
        }
    }

    /**
     * Sets the thread pool for executing the request.
     *
     * @param threadPool the thread pool
     * @return this CurlRequest instance
     */
    public CurlRequest threadPool(final ForkJoinPool threadPool) {
        this.threadPool = threadPool;
        return this;

Created: Thu Apr 02 15:34:12 GMT 2026

- Last Modified: Sat Mar 21 09:11:12 GMT 2026

- 19.7K bytes

- Click Count (0)

github.com/square/okhttp

maven-tests/mvnw

die() {
  printf %s\\n "$1" >&2
  exit 1
}

trim() {
  # MWRAPPER-139:
  #   Trims trailing and leading whitespace, carriage returns, tabs, and linefeeds.
  #   Needed for removing poorly interpreted newline sequences when running in more
  #   exotic environments such as mingw bash on Windows.
  printf "%s" "${1}" | tr -d '[:space:]'
}

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Thu Sep 25 18:22:49 GMT 2025

- 10.4K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/Multiset.java

   * element). Note that for an {@link Object#equals}-based multiset, this gives the same result as
   * {@link Collections#frequency} (which would presumably perform more poorly).
   *
   * <p><b>Note:</b> the utility method {@link Iterables#frequency} generalizes this operation; it
   * correctly delegates to this method when dealing with a multiset, but it can also accept any

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Feb 23 19:19:10 GMT 2026

- 19.5K bytes

- Click Count (0)

github.com/minio/minio

cmd/storage-rest-server.go

	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
	for pool := range globalLocalSetDrives {
		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
		for set := range globalLocalSetDrives[pool] {
			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
		}
	}
	for _, serverPool := range endpointServerPools {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 45.7K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

ci/official/utilities/generate_index_html.sh

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>
<body>
<h1>TensorFlow Job Logs and Links</h1>
<h2>Job Details</h2>
<ul>
<li>Job name: $KOKORO_JOB_NAME</li>
<li>Job pool: $KOKORO_JOB_POOL</li>
<li>Job ID: $KOKORO_BUILD_ID</li>
<li>Current HEAD Piper Changelist, if any: cl/${KOKORO_PIPER_CHANGELIST:-not available}</li>

Created: Tue Apr 07 12:39:13 GMT 2026

- Last Modified: Fri Sep 29 20:26:13 GMT 2023

- 2.3K bytes

- Click Count (0)

Search Options