poodlE - Code Search

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 Dec 28 19:28:13 GMT 2025

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

- 45.7K 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 Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Jul 08 18:32:10 GMT 2025

- 19.5K 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 Dec 28 09:35:17 GMT 2025

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

- 8K 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 Dec 30 12:39:10 GMT 2025

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

- 2.3K 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: Sat Dec 20 13:44:44 GMT 2025

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

- 3K bytes

- Click Count (0)

github.com/minio/minio

docs/logging/README.md

NOTE:

- `timeToFirstByte` and `timeToResponse` will be expressed in Nanoseconds.
- Additionally in the case of the erasure coded setup `tags.objectLocation` provides per object details about
  - Pool number the object operation was performed on.
  - Set number the object operation was performed on.
  - The list of drives participating in this operation belong to the set.

```json
{
  "version": "1",

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 10.5K bytes

- Click Count (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/RobotsTxtHelper.java

     *
     * <p>This method is designed to be resilient to malformed robots.txt files.
     * It will parse valid directives and ignore invalid ones, ensuring that partial
     * content can be extracted even from poorly formatted files.</p>
     *
     * <p>The following errors are handled gracefully (line is skipped, parsing continues):</p>
     * <ul>
     * <li>Invalid directive formats</li>
     * <li>Unknown directives</li>

Created: Sat Dec 20 11:21:39 GMT 2025

- Last Modified: Fri Nov 14 12:52:01 GMT 2025

- 11.4K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

    )

    taskFaker.assertNoMoreTasks()
  }

  /**
   * This test causes two connections to become available simultaneously, one from a TCP connect and
   * one from the pool. We must take the pooled connection because by taking it from the pool, we've
   * fully acquired it.
   *
   * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
   * particular, we set up this sequence of events:

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Fri Dec 27 13:39:56 GMT 2024

- 20.9K bytes

- Click Count (0)

github.com/minio/minio

helm/minio/templates/statefulset.yaml

{{- if eq .Values.mode "distributed" }}
{{ $poolCount := .Values.pools | int }}
{{ $nodeCount := .Values.replicas | int }}
{{ $replicas := mul $poolCount $nodeCount }}
{{ $drivesPerNode := .Values.drivesPerNode | int }}
{{ $scheme := .Values.tls.enabled | ternary "https" "http" }}
{{ $mountPath := .Values.mountPath }}
{{ $bucketRoot := or ($.Values.bucketRoot) ($.Values.mountPath) }}
{{ $subPath := .Values.persistence.subPath }}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Oct 11 12:21:05 GMT 2024

- 10.4K bytes

- Click Count (0)

github.com/google/guava

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 Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Jul 08 18:32:10 GMT 2025

- 20.9K bytes

- Click Count (0)

Search Options