pool - Code Search

guava-tests/test/com/google/common/graph/GraphMutationTest.java

@RunWith(JUnit4.class)

public final class GraphMutationTest {
  private static final int NUM_TRIALS = 50;
  private static final int NUM_NODES = 100;
  private static final int NUM_EDGES = 1000;
  private static final int NODE_POOL_SIZE = 1000; // must be >> NUM_NODES

  @Test
  public void directedGraph() {
    testGraphMutation(GraphBuilder.directed());
  }

  @Test
  public void undirectedGraph() {

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Fri Aug 18 16:17:46 GMT 2017

- 4.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/graph/NetworkMutationTest.java

@RunWith(JUnit4.class)

public final class NetworkMutationTest {
  private static final int NUM_TRIALS = 5;
  private static final int NUM_NODES = 20;
  private static final int NUM_EDGES = 100;
  private static final int NODE_POOL_SIZE = 1000; // must be >> NUM_NODES

  @Test
  public void directedNetwork() {
    testNetworkMutation(NetworkBuilder.directed());
  }

  @Test
  public void undirectedNetwork() {

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Apr 10 19:42:18 GMT 2024

- 4.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

    val id: Int,
  ) : RoutePlanner.Plan {
    var planningThrowable: Throwable? = null
    var canceled = false
    var connectState = ConnectState.READY
    val connection =
      factory.newConnection(
        pool = pool,
        route = factory.newRoute(address),
        idleAtNanos = defaultConnectionIdleAtNanos,
      )
    var retry: FakePlan? = null
    var retryTaken = false
    var yieldBeforePlanReturns = false

Plain Text

- Registered: Fri Apr 26 11:42:10 GMT 2024

- Last Modified: Wed Apr 24 04:40:49 GMT 2024

- 6.2K bytes

- Viewed (0)

github.com/minio/minio

docs/distributed/README.md

> **NOTE:** **Each pool you add must have the same erasure coding parity configuration as the original pool, so the same data redundancy SLA is maintained.**

Plain Text

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Jan 18 07:03:17 GMT 2024

- 8.8K bytes

- Viewed (0)

github.com/istio/istio

common/scripts/metallb-native.yaml

                  allocation for a pool.
                type: boolean
              avoidBuggyIPs:
                default: false
                description: AvoidBuggyIPs prevents addresses ending with .0 and .255
                  to be used by a pool.
                type: boolean
              serviceAllocation:
                description: AllocateTo makes ip pool allocation to specific namespace

Others

- Registered: Wed Apr 24 22:53:08 GMT 2024

- Last Modified: Fri Feb 23 23:56:31 GMT 2024

- 63.9K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go

			args:             strings.Split("log ztunnel-9v7nw --level ztunnel:::pool:debug", " "),
			expectedString:   "unrecognized logging level: pool:debug",
			wantException:    true,
		},
		{ // logger name valid and logging level valid
			execClientConfig: loggingConfig,
			args:             strings.Split("log ztunnel-9v7nw --level ztunnel::pool:debug", " "),
			expectedString:   "",
			wantException:    false,
		},

Go

- Registered: Wed Apr 24 22:53:08 GMT 2024

- Last Modified: Wed Apr 10 21:51:29 GMT 2024

- 3.8K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/json/preader.go

	queue       chan *queueItem // output from workers in order
	err         error           // global error state, only touched by Reader.Read
	bufferPool  sync.Pool       // pool of []byte objects for input
	kvDstPool   sync.Pool       // pool of []jstream.KV used for output
	close       chan struct{}   // used for shutting down the splitter before end of stream
	readerWg    sync.WaitGroup  // used to keep track of async reader.
}

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Sun Mar 05 04:57:35 GMT 2023

- 6.4K bytes

- Viewed (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>
<li>Pull Request Number, if any: ${KOKORO_GITHUB_PULL_REQUEST_NUMBER_tensorflow:- none}</li>

Shell Script

- Registered: Tue Apr 23 12:39:09 GMT 2024

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

- 2.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

    expectedEvents += "ResponseBodyEnd"
    expectedEvents += "ConnectionReleased"
    expectedEvents += "CallEnd"
    assertThat(listener.recordedEventTypes()).isEqualTo(expectedEvents)

    // Confirm that the connection pool was not corrupted by making another call.
    makeSimpleCall()
  }

  /**
   * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset.

Plain Text

- Registered: Fri Apr 26 11:42:10 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 9.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/handler-api.go

	// total drives per erasure set across pools.
	totalDriveCount       int
	replicationPriority   string
	replicationMaxWorkers int
	transitionWorkers     int

	staleUploadsExpiry          time.Duration
	staleUploadsCleanupInterval time.Duration
	deleteCleanupInterval       time.Duration
	enableODirect               bool
	gzipObjects                 bool
	rootAccess                  bool
	syncEvents                  bool

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Mon Apr 08 09:22:27 GMT 2024

- 10K bytes

- Viewed (0)

Search Options