- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for waitms (0.18 sec)
-
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
narrow, to be sure; but I THINK I can kick a little!' She drew her foot as far down the chimney as she could, and waited till she heard a little animal (she couldn't guess of what sort it was) scratching and scrambling about in the chimney close above her: then, saying to herself `This is Bill,' she gave one sharp kick, and waited to see what would happen next. The first thing she heard was a general chorus of `There goes
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 145.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
List<ReferenceEntry<Object, Object>> writes = new ArrayList<>(); Iterator<ReferenceEntry<Object, Object>> i = writeOrder.iterator(); while (i.hasNext()) { ReferenceEntry<Object, Object> entry = i.next(); if (random.nextBoolean()) { segment.recordWrite(entry, 1, map.ticker.read()); writes.add(entry); i.remove(); } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 110.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.4.md
* Cherrypick [#34851](https://github.com/kubernetes/kubernetes/pull/34851) "Only wait for cache syncs once in NodeController" ([#34861](https://github.com/kubernetes/kubernetes/pull/34861), [@jessfraz](https://github.com/jessfraz)) * NodeController waits for informer sync before doing anything ([#34809](https://github.com/kubernetes/kubernetes/pull/34809), [@gmarek](https://github.com/gmarek))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.5.md
* Only wait for cache syncs once in NodeController ([#34851](https://github.com/kubernetes/kubernetes/pull/34851), [@ncdc](https://github.com/ncdc)) * NodeController waits for informer sync before doing anything ([#34809](https://github.com/kubernetes/kubernetes/pull/34809), [@gmarek](https://github.com/gmarek))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 136.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
cmd/bucket-replication.go
p.mu.Lock() defer p.mu.Unlock() if (checkOld > 0 && len(p.lrgworkers) != checkOld) || n == len(p.lrgworkers) || n < 1 { // Either already satisfied or worker count changed while we waited for the lock. return } for len(p.lrgworkers) < n { input := make(chan ReplicationWorkerOperation, 100000) p.lrgworkers = append(p.lrgworkers, input)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
.build(), ) server.enqueue( MockResponse .Builder() .body("B") .build(), ) // A cache miss writes the cache. val t0 = System.currentTimeMillis() val response1 = get(server.url("/a")) assertThat(response1.body.string()).isEqualTo("A") assertThat(response1.header("Allow")).isNull()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 113.6K bytes - Viewed (0) -
cmd/metrics-v2.go
Namespace: minioNamespace, Subsystem: "locks", Name: "write_total", Help: "Number of current WRITE locks on this peer", Type: gaugeMetric, }, Value: float64(st.Writes), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{ Namespace: minioNamespace, Subsystem: "locks", Name: "read_total",
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
src/main/webapp/js/jquery-3.7.1.min.map
GAAO0T,UAAY1T,GAAO0T,SAASD,KAC9C,OAAOA,GAAQA,EAAKlT,MAAO,KAAQmD,EAAK8J,IAGzCmG,KAAM,SAAUjQ,GACf,OAAOA,IAASsD,GAGjB4M,MAAO,SAAUlQ,GAChB,OAAOA,IA5oCV,WACC,IACC,OAAO7D,EAASgU,cACf,MAAQC,KAyoCQC,IACflU,EAASmU,eACLtQ,EAAK9B,MAAQ8B,EAAKuQ,OAASvQ,EAAKwQ,WAItCC,QAASrF,GAAsB,GAC/BtC,SAAUsC,GAAsB,GAEhCsF,QAAS,SAAU1Q,GAIlB,OAASD,GAAUC,EAAM,YAAeA,EAAK0Q,SAC1C3Q,GAAUC,EAAM,aAAgBA,EAAK2Q,UAGzCA,SAAU,SAAU3Q,GAWnB,OALKA,EAAKb,YAETa,EAAKb,WAAWyR,eAGQ,IAAlB5Q,EAAK2Q,UAIbE,MAAO,SAAU7Q,GAMhB,IAAMA,EAAOA,EAAKiP,WAAY...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 131.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
} /** Confirm that an unacknowledged write times out. */ @Test fun writeTimeouts() { val server = MockWebServer() // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. val socketBufferSize = 4 * 1024 server.serverSocketFactory =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0)