peek - Code Search

guava-tests/test/com/google/common/cache/LocalCacheTest.java

    segment.readCount.incrementAndGet();
    segment.count = 1;
    segment.totalWeight = 1;

    assertSame(entry, table.get(0));
    assertSame(entry, segment.accessQueue.peek());
    assertSame(entry, segment.writeQueue.peek());

    segment.clear();
    assertNull(table.get(0));
    assertTrue(segment.accessQueue.isEmpty());
    assertTrue(segment.writeQueue.isEmpty());

Java

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

- Last Modified: Thu Mar 14 23:06:48 GMT 2024

- 112.3K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

    segment.readCount.incrementAndGet();
    segment.count = 1;
    segment.totalWeight = 1;

    assertSame(entry, table.get(0));
    assertSame(entry, segment.accessQueue.peek());
    assertSame(entry, segment.writeQueue.peek());

    segment.clear();
    assertNull(table.get(0));
    assertTrue(segment.accessQueue.isEmpty());
    assertTrue(segment.writeQueue.isEmpty());

Java

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

- Last Modified: Thu Mar 14 23:06:48 GMT 2024

- 110.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/cache/LocalCache.java

      drainRecencyQueue();

      ReferenceEntry<K, V> e;
      while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
          throw new AssertionError();
        }
      }
      while ((e = accessQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {

Java

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

- Last Modified: Thu Feb 22 17:40:56 GMT 2024

- 144.7K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/cache/LocalCache.java

      drainRecencyQueue();

      ReferenceEntry<K, V> e;
      while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
          throw new AssertionError();
        }
      }
      while ((e = accessQueue.peek()) != null && map.isExpired(e, now)) {
        if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {

Java

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

- Last Modified: Thu Feb 22 17:40:56 GMT 2024

- 150.3K bytes

- Viewed (0)

github.com/square/okhttp

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

    val requestFinished = CountDownLatch(2)
    val dispatcher: QueueDispatcher =
      object : QueueDispatcher() {
        override fun dispatch(request: RecordedRequest): MockResponse {
          if (peek().socketPolicy === DisconnectAfterRequest) {
            requestFinished.await()
          }
          return super.dispatch(request)
        }
      }

Plain Text

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

- Last Modified: Wed Apr 10 19:46:48 GMT 2024

- 142.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication.go

	var (
		prevPeerInfo, pi madmin.PeerInfo
	)
	if peer.DeploymentID != "" {
		pi = c.state.Peers[peer.DeploymentID]
		prevPeerInfo = pi
		if !peer.SyncState.Empty() { // update replication to peer to be sync/async
			pi.SyncState = peer.SyncState
			successMsg = fmt.Sprintf("%s\n- sync state %s for peer %s", successMsg, peer.SyncState, peer.Name)
		}

Go

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

- Last Modified: Thu Apr 25 15:50:16 GMT 2024

- 184.1K bytes

- Viewed (1)

github.com/minio/minio

cmd/metrics-v2.go

		Help:      "Total number of bytes sent to the other peer nodes",
		Type:      counterMetric,
	}
}

func getInterNodeReceivedBytesMD() MetricDescription {
	return MetricDescription{
		Namespace: interNodeMetricNamespace,
		Subsystem: trafficSubsystem,
		Name:      receivedBytes,
		Help:      "Total number of bytes received from other peer nodes",
		Type:      counterMetric,
	}
}

Go

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

- Last Modified: Thu Apr 25 22:01:31 GMT 2024

- 132.6K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/authz/testdata/configdump.yaml

          {
           "name": "istio.metadata_exchange",
           "typed_config": {
            "@type": "type.googleapis.com/envoy.tcp.metadataexchange.config.MetadataExchange",
            "protocol": "istio-peer-exchange"
           }
          },
          {
           "name": "istio.stats",
           "typed_config": {
            "@type": "type.googleapis.com/stats.PluginConfig",

Others

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Wed Jun 21 14:20:23 GMT 2023

- 206.7K bytes

- Viewed (2)

github.com/minio/minio

cmd/object-handlers.go

		return
	}

	ot, err := objAPI.GetObjectTags(ctx, bucket, object, opts)
	if err != nil {
		// if object/version is not found locally, but exists on peer site - proxy
		// the tagging request to peer site. The response to client will
		// return tags from peer site.
		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
			proxytgts := getProxyTargets(ctx, bucket, object, opts)
			if !proxytgts.Empty() {

Go

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

- Last Modified: Mon Apr 22 17:49:30 GMT 2024

- 125K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

// seat : 2014-05-22 SEAT, S.A. (Sociedad Unipersonal)
seat

// secure : 2015-08-27 Amazon Registry Services, Inc.
secure

// security : 2015-05-14 XYZ.COM LLC
security

// seek : 2014-12-04 Seek Limited
seek

// select : 2015-10-08 Registry Services, LLC
select

// sener : 2014-10-24 Sener Ingeniería y Sistemas, S.A.
sener

// services : 2014-02-27 Binky Moon, LLC
services

Plain Text

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

- Last Modified: Wed Dec 20 23:27:07 GMT 2023

- 240.3K bytes

- Viewed (3)

Search Options