poodlE - Code Search

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/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)

github.com/minio/minio

cmd/bucket-replication.go

		priority:        priority,
		maxWorkers:      maxWorkers,
		maxLWorkers:     maxLWorkers,
	}

	pool.ResizeLrgWorkers(maxLWorkers, 0)
	pool.ResizeWorkers(workers, 0)
	pool.ResizeFailedWorkers(failedWorkers)
	go pool.resyncer.PersistToDisk(ctx, o)
	go pool.processMRF()
	go pool.persistMRF()
	return pool
}

// AddMRFWorker adds a pending/failed replication worker to handle requests that could not be queued

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

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 118.2K bytes

- Click Count (0)

github.com/square/okhttp

docs/changelogs/changelog_4x.md

    of unacknowledged data per stream and no per-connection limit.

 *  Fix: Don't operate on a connection after it's been returned to the pool. This race occurred
    on failed web socket connection attempts.

 *  Upgrade: [Okio 3.6.0][okio_3_6_0].

 *  Upgrade: [Kotlin 1.8.21][kotlin_1_8_21].


## Version 4.11.0

_2023-04-22_

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

- Last Modified: Wed Apr 17 13:25:31 GMT 2024

- 25.2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbTreeHandleInternal.java

 * SMB tree connections and their lifecycle.
 *
 * @author mbechler
 */
public interface SmbTreeHandleInternal extends SmbTreeHandle {

    /**
     * Releases this tree handle back to the pool for reuse
     */
    void release();

    /**
     * Ensures that DFS referrals have been resolved for this tree
     * @throws SmbException if an SMB-specific error occurs

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 3K bytes

- Click Count (0)

Search Options