- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 1,377 for waitc (0.09 sec)
-
pkg/test/util/assert/tracker.go
func (t *Tracker[T]) Empty() { t.t.Helper() t.mu.Lock() defer t.mu.Unlock() if len(t.events) != 0 { t.t.Fatalf("unexpected events: %v", t.events) } } // WaitOrdered waits for an event to happen, in order func (t *Tracker[T]) WaitOrdered(events ...T) { t.t.Helper() for i, event := range events { var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_non_crash_signal.txt
panic(err) } // signal may not be received immediately. Wait for it. select{} }) } func FuzzKill(f *testing.F) { f.Fuzz(func(*testing.T, bool) { pid := syscall.Getpid() if err := syscall.Kill(pid, syscall.SIGKILL); err != nil { panic(err) } // signal may not be received immediately. Wait for it. select{} }) } func FuzzCrash(f *testing.F) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 1.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DeploymentRegistry.java
/** * Behavior when a deployment is out-of-date. */ enum ChangeBehavior { /** * When changes are detected, wait for a deployment request before rebuilding. * * The deployment needs to call {@link Deployment#status()} to trigger a rebuild wait for changes. */ BLOCK_AND_REBUILD, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Mar 23 06:23:31 UTC 2019 - 2.4K bytes - Viewed (0) -
pkg/volume/csi/testing/testing.go
factory := informers.NewSharedInformerFactory(client, csi.CsiResyncPeriod) csiDriverInformer := factory.Storage().V1().CSIDrivers() csiDriverLister := csiDriverInformer.Lister() factory.Start(wait.NeverStop) syncedTypes := factory.WaitForCacheSync(wait.NeverStop) if len(syncedTypes) != 1 { t.Fatalf("informers are not synced") } for ty, ok := range syncedTypes { if !ok { t.Fatalf("failed to sync: %#v", ty) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K bytes - Viewed (0) -
src/log/syslog/syslog_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 12 16:09:24 UTC 2023 - 9.6K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
sort.Strings(unhealthy) if expectPush { upd, err := adscon.Wait(5*time.Second, v3.EndpointType) assert.NoError(t, err) if len(upd) > 0 && !slices.Contains(upd, v3.EndpointType) { t.Fatalf("Expecting EDS push as endpoint health is changed. But received %v", upd) } } else { upd, _ := adscon.Wait(50*time.Millisecond, v3.EndpointType) if slices.Contains(upd, v3.EndpointType) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
te = null; thread = new Thread( this, name ); thread.setDaemon( true ); synchronized (thread) { thread.start(); thread.wait( timeout ); /* wait for doConnect */ switch (state) { case 1: /* doConnect never returned */ state = 0; thread = null;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K bytes - Viewed (0) -
pkg/probe/grpc/grpc_test.go
fmt.Fprint(w, "res") })) u := strings.Split(server.URL, ":") assert.Equal(t, 3, len(u)) port, err := strconv.Atoi(u[2]) assert.Equal(t, nil, err) // take some time to wait server boot time.Sleep(2 * time.Second) p, _, err := s.Probe("127.0.0.1", "", port, time.Second) assert.Equal(t, probe.Failure, p) assert.Equal(t, nil, err) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 20 00:23:53 UTC 2021 - 5.7K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return nil } // ExpectError waits until an error is received and returns it func (a *DeltaAdsTest) ExpectError() error { a.t.Helper() select { case <-time.After(a.timeout): a.t.Fatalf("did not get error in time") case err := <-a.error: return err } return nil } // ExpectNoResponse waits a short period of time and ensures no response is received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
src/os/pidfd_linux.go
handle, status := p.handleTransientAcquire() switch status { case statusDone: // Process already completed Wait, or was not found by // pidfdFind. Return ECHILD for consistency with what the wait // syscall would return. return nil, NewSyscallError("wait", syscall.ECHILD) case statusReleased: return nil, syscall.EINVAL } defer p.handleTransientRelease() var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0)