- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for remSign (0.64 sec)
-
src/net/http/server.go
for cr.inRead { cr.cond.Wait() } cr.conn.rwc.SetReadDeadline(time.Time{}) } func (cr *connReader) setReadLimit(remain int64) { cr.remain = remain } func (cr *connReader) setInfiniteReadLimit() { cr.remain = maxInt64 } func (cr *connReader) hitReadLimit() bool { return cr.remain <= 0 } // handleReadError is called whenever a Read from the client returns a // non-nil error. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
}, }), // 18,19: observe delete of pod2 from step 14 // final state: virtual parent for inaccessible apiVersion and child of that parent remain in graph, queued for delete attempts with backoff processEvent(makeDeleteEvent(pod2ns1)), assertState(state{ graphNodes: []*node{ makeNode(deployment1extensions, virtual),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
src/database/sql/sql.go
panic(fmt.Sprintf("unpaired removeDep: no %T dep on %T", dep, x)) case 0: // No more dependencies. delete(db.dep, x) return x.finalClose default: // Dependencies remain. return func() error { return nil } } } // This is the size of the connectionOpener request chan (DB.openerCh). // This value should be larger than the maximum typical value
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
src/crypto/sha512/sha512_test.go
}, { "6ec2cb2ecafc1a9bddaf4caf57344d853e6ded398927d5694fd7714f", "Nepal premier won't resign.",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 03 21:17:08 UTC 2023 - 105.6K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
fp.servicesSynced = true // first, add multi-port service1 fp.OnServiceAdd(service1) fp.syncProxyRules() remainingAddrs, _ := fp.netlinkHandle.ListBindAddress(defaultDummyDevice) // should only remain address "172.16.55.4" if len(remainingAddrs) != 1 { t.Errorf("Expected number of remaining bound addrs after cleanup to be %v. Got %v", 1, len(remainingAddrs)) } if remainingAddrs[0] != "172.16.55.4" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_ops_n_z.cc
"{0}, but got {1}", shape_ty_size, tensor_ty_size)); // Set the unknown dimension such that total number of elements remain // constant. output_ty_shape[unknown_index] = missing_dim; } output_ty = tensorflow::GetTypeFromTFTensorShape(output_ty_shape, element_ty); return success(); } } // namespace
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 09 22:07:10 UTC 2024 - 170.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
return highPriorityPodInfo.Pod, highPriNominatedPodInfo.Pod }, schedulingHintsEnablement: []bool{false, true}, }, { name: "When updating a pod that is already in activeQ, the pod should remain in activeQ after Update()", wantQ: activeQ, prepareFunc: func(t *testing.T, logger klog.Logger, q *PriorityQueue) (oldPod, newPod *v1.Pod) { err := q.Update(logger, nil, highPriorityPodInfo.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json
}, "stdinOnce": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 229.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
expectedPodReadyToStartContainersCondition: v1.PodCondition{ Type: v1.PodReadyToStartContainers, Status: v1.ConditionFalse, }, }, { name: "terminal phase from previous status must remain terminal, restartAlways", pod: &v1.Pod{ Spec: desiredState, Status: v1.PodStatus{ Phase: v1.PodRunning, ContainerStatuses: []v1.ContainerStatus{ runningState("containerA"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
server.enqueue( MockResponse.Builder() .body("a") .build(), ) val url = server.url("/a") assertThat(get(url).body.string()).isEqualTo("a") // The URL will remain available if hasNext() returned true... val i = cache.urls() assertThat(i.hasNext()).isTrue() // ...so even when we evict the element, we still get something back. cache.evictAll()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 108.6K bytes - Viewed (0)