Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for peek (0.08 sec)

  1. 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());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 110.5K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        val requestFinished = CountDownLatch(2)
        val dispatcher: QueueDispatcher =
          object : QueueDispatcher() {
            override fun dispatch(request: RecordedRequest): MockResponse {
              if (peek().onResponseStart is CloseSocket) {
                requestFinished.await()
              }
              return super.dispatch(request)
            }
          }
        dispatcher.enqueue(MockResponse(body = "seed connection pool"))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  3. 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)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (1)
  4. 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,
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    				}
    			}
    		}
    	}()
    
    	// Collect from matching peers
    	for _, peer := range peers {
    		if peer == nil {
    			continue
    		}
    		if node == "" || strings.EqualFold(peer.host.Name, node) {
    			peer.ConsoleLog(ctx, logKind, encodedCh)
    		}
    	}
    
    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  6. okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list

    is-a-chef.org
    is-a-conservative.com
    is-a-cpa.com
    is-a-cubicle-slave.com
    is-a-democrat.com
    is-a-designer.com
    is-a-doctor.com
    is-a-financialadvisor.com
    is-a-fullstack.dev
    is-a-geek.com
    is-a-geek.net
    is-a-geek.org
    is-a-good.dev
    is-a-green.com
    is-a-guru.com
    is-a-hard-worker.com
    is-a-hunter.com
    is-a-knight.org
    is-a-landscaper.com
    is-a-lawyer.com
    is-a-liberal.com
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 22:00:49 UTC 2025
    - 129.6K bytes
    - Viewed (3)
  7. 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() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  8. okhttp/src/androidMain/assets/PublicSuffixDatabase.list

    is-a-chef.org
    is-a-conservative.com
    is-a-cpa.com
    is-a-cubicle-slave.com
    is-a-democrat.com
    is-a-designer.com
    is-a-doctor.com
    is-a-financialadvisor.com
    is-a-fullstack.dev
    is-a-geek.com
    is-a-geek.net
    is-a-geek.org
    is-a-good.dev
    is-a-green.com
    is-a-guru.com
    is-a-hard-worker.com
    is-a-hunter.com
    is-a-knight.org
    is-a-landscaper.com
    is-a-lawyer.com
    is-a-liberal.com
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Dec 31 14:50:53 UTC 2024
    - 129.6K bytes
    - Viewed (2)
  9. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      `Well, there was Mystery,' the Mock Turtle replied, counting
    off the subjects on his flappers, `--Mystery, ancient and modern,
    with Seaography:  then Drawling--the Drawling-master was an old
    conger-eel, that used to come once a week:  HE taught us
    Drawling, Stretching, and Fainting in Coils.'
    
      `What was THAT like?' said Alice.
    
      `Well, I can't show it you myself,' the Mock Turtle said:  `I'm
    too stiff.  And the Gryphon never learnt it.'
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/mylasta/action/FessLabels.java

        /** The key of the message: Within 24 hours */
        public static final String LABELS_facet_timestamp_1day = "{labels.facet_timestamp_1day}";
    
        /** The key of the message: Within a week */
        public static final String LABELS_facet_timestamp_1week = "{labels.facet_timestamp_1week}";
    
        /** The key of the message: Within a month */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 05 02:36:47 UTC 2025
    - 146.4K bytes
    - Viewed (0)
Back to top