- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 338 for happen (0.23 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
*/ abstract <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException; /** Marks the given step final, cancels it, and waits for the cancellation to happen. */ abstract void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture); /** * Marks the given step final and waits for it to fail. Expects the failure exception to match
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
hack/local-up-cluster.sh
CONTROLPLANE_SUDO=$(test -w "${CERT_DIR}" || echo "sudo -E") function test_apiserver_off { # For the common local scenario, fail fast if server is already running. # this can happen if you run local-up-cluster.sh twice and kill etcd in between. if [[ "${API_PORT}" -gt "0" ]]; then if ! curl --silent -g "${API_HOST}:${API_PORT}" ; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 25 02:33:52 UTC 2024 - 53.3K bytes - Viewed (0) -
tests/query_test.go
*GetUser("find", Config{}), } if err := DB.Create(&users).Error; err != nil { t.Fatalf("errors happened when create users: %v", err) } t.Run("First", func(t *testing.T) { var first User if err := DB.Where("name = ?", "find").First(&first).Error; err != nil { t.Errorf("errors happened when query first: %v", err) } else { CheckUser(t, first, users[0]) } })
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed May 08 04:07:58 UTC 2024 - 49.8K bytes - Viewed (0) -
cmd/iam-store.go
if _, ok := cache.iamUsersMap[u]; !ok { // This case can happen when a temporary account is // deleted or expired - remove it from userPolicyMap. cache.iamUserPolicyMap.Delete(u) return true } } if pset.Contains(policy) { users = append(users, u) } return true })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
*/ abstract <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException; /** Marks the given step final, cancels it, and waits for the cancellation to happen. */ abstract void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture); /** * Marks the given step final and waits for it to fail. Expects the failure exception to match
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go
// this should never happen allErrs = append(allErrs, field.Invalid(fldPath.Child("openAPIV3Schema"), "", err.Error())) } else if len(validationErrors) > 0 { allErrs = append(allErrs, validationErrors...) } else { // Only initialize CEL rule validation context if the structural schemas are valid.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 82.6K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc
plugins { id("ear") } ear { deploymentDescriptor { version = "1.3" withXml { asElement() } } } ---- ====== ===== If you happen to use `asNode()` instead of `asElement()` then nothing changes given `asNode()` simply ignores external DTDs. You can work around this by running your build with the `javax.xml.accessExternalDTD` system property set to `http`.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 17:01:07 UTC 2024 - 90.7K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
} updatedNodes = append(updatedNodes, updatedNode) } // Create a few pods for tests. var pods []*v1.Pod for i := 0; i < 20; i++ { pod := st.MakePod().Name(fmt.Sprintf("test-pod%v", i)).Namespace("test-ns").UID(fmt.Sprintf("test-puid%v", i)). Node(fmt.Sprintf("test-node%v", i%10)).Obj() pods = append(pods, pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
var result []*v1.Pod for _, pInfo := range p.activeQ.List() { result = append(result, pInfo.(*framework.QueuedPodInfo).Pod) } for _, pInfo := range p.podBackoffQ.List() { result = append(result, pInfo.(*framework.QueuedPodInfo).Pod) } for _, pInfo := range p.unschedulablePods.podInfoMap { result = append(result, pInfo.Pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
close(reqInFlight) // cause the client to cancel its request select { case <-time.After(10 * time.Second): // Note: this should only happen in broken implementations, and the // closenotify case should be instantaneous. t.Error("Handler never saw CloseNotify") return case <-w.(http.CloseNotifier).CloseNotify(): }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0)