pool - Code Search

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 May 03 11:42:14 GMT 2024

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

- 6.2K 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 May 05 19:28:20 GMT 2024

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

- 6.4K bytes

- Viewed (0)

github.com/google/guava

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

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Sun Apr 28 17:53:50 GMT 2024

- 44.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/rebalstatus_string.go

// Code generated by "stringer -type=rebalStatus -trimprefix=rebal erasure-server-pool-rebalance.go"; DO NOT EDIT.

package cmd

import "strconv"

func _() {
	// An "invalid array index" compiler error signifies that the constant values have changed.
	// Re-run the stringer command to generate them again.
	var x [1]struct{}
	_ = x[rebalNone-0]
	_ = x[rebalStarted-1]
	_ = x[rebalCompleted-2]
	_ = x[rebalStopped-3]
	_ = x[rebalFailed-4]
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Oct 25 19:36:57 GMT 2022

- 795 bytes

- Viewed (0)

github.com/go-gorm/gorm

schema/interfaces.go

	Build() (sql string, vars []interface{})
}

// GormDataTypeInterface gorm data type interface
type GormDataTypeInterface interface {
	GormDataType() string
}

// FieldNewValuePool field new scan value pool
type FieldNewValuePool interface {
	Get() interface{}
	Put(interface{})
}

// CreateClausesInterface create clauses interface
type CreateClausesInterface interface {
	CreateClauses(*Field) []clause.Interface
}

Go

- Registered: Sun May 05 09:35:13 GMT 2024

- Last Modified: Sun Feb 04 07:49:19 GMT 2024

- 980 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 30 12:39:09 GMT 2024

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

- 2.3K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

   * simulate late connection pool failures.
   */
  object DisconnectAfterRequest : SocketPolicy

  /**
   * Half close connection (InputStream for client) after reading the request but before
   * writing the response. Use this to simulate late connection pool failures.
   */
  object HalfCloseAfterRequest : SocketPolicy

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Tue Jan 23 14:31:42 GMT 2024

- 4.6K bytes

- Viewed (0)

github.com/square/okhttp

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

          },
        )
        .build()
    dns["san.com"] = Dns.SYSTEM.lookup(server.hostName).subList(0, 1)
    assert200Http2Response(execute(url), server.hostName)

    // Simulate a stale connection in the pool.
    connection.get()!!.socket().close()
    val sanUrl = url.newBuilder().host("san.com").build()
    assert200Http2Response(execute(sanUrl), "san.com")
    assertThat(client.connectionPool.connectionCount()).isEqualTo(1)

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sat Jan 20 10:30:28 GMT 2024

- 18.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/object-api-interface.go

	// SkipDecommissioned set to 'true' if the call requires skipping the pool being decommissioned.
	// mainly set for certain WRITE operations.
	SkipDecommissioned bool
	// SkipRebalancing should be set to 'true' if the call should skip pools
	// participating in a rebalance operation. Typically set for 'write' operations.
	SkipRebalancing bool

	DataMovement bool // indicates an going decommisionning or rebalacing

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri May 03 20:08:20 GMT 2024

- 17K bytes

- Viewed (0)

Search Options