- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for agrave (0.21 sec)
-
pkg/kubelet/pod_workers_test.go
syncPodRecords := processed[uid] var match bool grace := int64(30) for _, possible := range [][]syncPodRecord{ {{name: string(uid), updateType: kubetypes.SyncPodKill, gracePeriod: &grace}, {name: string(uid), terminated: true}}, {{name: string(uid), updateType: kubetypes.SyncPodCreate}, {name: string(uid), updateType: kubetypes.SyncPodKill, gracePeriod: &grace}, {name: string(uid), terminated: true}}, } {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/cmd/internal/obj/loong64/asm.go
case -AMOVF: return 0x0ac << 22 case -AMOVD: return 0x0ae << 22 case ASLLV, -ASLLV: return 0x0041 << 16 case ASRLV, -ASRLV: return 0x0045 << 16 case ASRAV, -ASRAV: return 0x0049 << 16 case AROTRV, -AROTRV: return 0x004d << 16 case -ALL: return 0x020 << 24 case -ALLV: return 0x022 << 24 case ASC: return 0x021 << 24
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 02:04:54 UTC 2024 - 61.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(connection.isHealthy(System.nanoTime())).isTrue() // But if the ping doesn't arrive, the connection goes unhealthy. Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong())) assertThat(connection.isHealthy(System.nanoTime())).isFalse() // When a pong does arrive, the connection becomes healthy again. connection.writePingAndAwaitPong()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
auto a = ops::Placeholder(root.WithOpName("A"), DT_FLOAT); auto b = ops::Placeholder(root.WithOpName("B"), DT_FLOAT); auto c = ops::Add(root.WithOpName("C"), a, b); auto enter = ops::internal::Enter(root, c, "aframe"); auto next_iter = ops::NextIteration(root, enter); auto exit = ops::internal::Exit(root, next_iter); auto d = ops::Add(root.WithOpName("D"), c, exit);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
gcPercentGoal := uint64(float64(memstats.lastHeapInUse) * goalRatio) // Add retainExtraPercent overhead to retainedGoal. This calculation // looks strange but the purpose is to arrive at an integer division // (e.g. if retainExtraPercent = 12.5, then we get a divisor of 8) // that also avoids the overflow from a multiplication. gcPercentGoal += gcPercentGoal / (1.0 / (retainExtraPercent / 100.0))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
err = cacher.storage.RequestWatchProgress(metadata.NewOutgoingContext(context.Background(), contextMetadata)) if err != nil { t.Fatal(err) } // Give time for bookmark to arrive time.Sleep(time.Second) etcdWatchResourceVersion := waitForEtcdBookmark() gotEtcdWatchBookmark := etcdWatchResourceVersion == lastResourceVersion if gotEtcdWatchBookmark != tc.expectBookmarkOnEtcd {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
src/math/big/int_test.go
for _, a := range prodZZ { arg := a testFunZZ(t, "MulZZ", MulZZ, arg) arg = argZZ{a.z, a.y, a.x} testFunZZ(t, "MulZZ symmetric", MulZZ, arg) } } // mulBytes returns x*y via grade school multiplication. Both inputs // and the result are assumed to be in big-endian representation (to // match the semantics of Int.Bytes and Int.SetBytes). func mulBytes(x, y []byte) []byte {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 58.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// NodeAdd QueueingHint isn't always called because of the internal feature called preCheck. // As a common problematic scenario, // when a node is added but not ready, NodeAdd event is filtered out by preCheck and doesn't arrive. // In such cases, this plugin may miss some events that actually make pods schedulable. // As a workaround, we add UpdateNodeTaint event to catch the case.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
t.Errorf("validate callback returned error: %s", err) } } // If the server sent us an alert after our last flight, give it a // chance to arrive. if write && test.renegotiationExpectedToFail == 0 { if err := peekError(client); err != nil { t.Errorf("final Read returned an error: %s", err) } } }() if !write {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
* case, we take a 2KiB body and throttle it to 1KiB/second. We set the read timeout to half a * second. If our implementation is acting correctly, it will throw, as a byte doesn't arrive in * time. */ @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun readTimeoutOnSlowConnection( protocol: Protocol, mockWebServer: MockWebServer, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0)