- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 962 for waitc (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
// Depending upon object type, waits afterward until the object is synced // by the policy source func (p *PolicyTestContext[P, B, E]) update(wait bool, objects ...runtime.Object) error { for _, object := range objects { if err := p.updateOne(object); err != nil { return err } } if wait { timeoutCtx, timeoutCancel := context.WithTimeout(p, 3*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pkg/envoy/agent.go
type exitStatus struct { err error } // Run starts the envoy and waits until it terminates. // There are a few exit paths: // 1. Envoy exits. In this case, we simply log and exit. // 2. /quitquitquit (on agent, not Envoy) is called. We will set skipDrain and cancel the context, which triggers us to exit immediately.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
src/net/http/main_test.go
// shutting down, so give it some time. time.Sleep(1 * time.Millisecond) } t.Errorf("Test appears to have leaked %s:\n%s", bad, stacks) } // waitCondition waits for fn to return true, // checking immediately and then at exponentially increasing intervals. func waitCondition(t testing.TB, delay time.Duration, fn func(time.Duration) bool) { t.Helper() start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
}() // wait for all in-flight non-long running requests to finish nonLongRunningRequestDrainedCh := make(chan struct{}) go func() { defer close(nonLongRunningRequestDrainedCh) defer klog.V(1).Info("[graceful-termination] in-flight non long-running request(s) have drained") // wait for the delayed stopCh before closing the handler chain (it rejects everything after Wait has been called).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
pkg/util/iptables/iptables.go
// WaitString a constant for specifying the wait flag const WaitString = "-w" // WaitSecondsValue a constant for specifying the default wait seconds const WaitSecondsValue = "5" // WaitIntervalString a constant for specifying the wait interval flag const WaitIntervalString = "-W" // WaitIntervalUsecondsValue a constant for specifying the default wait interval useconds const WaitIntervalUsecondsValue = "100000"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 28.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_dragonfly_amd64.go
SYS_OPEN = 5 // { int open(char *path, int flags, int mode); } SYS_CLOSE = 6 // { int close(int fd); } SYS_WAIT4 = 7 // { int wait4(int pid, int *status, int options, struct rusage *rusage); } wait4 wait_args int // SYS_NOSYS = 8; // { int nosys(void); } __nosys nosys_args int SYS_LINK = 9 // { int link(char *path, char *link); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 27.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/ContinuousBuildGateIntegrationTest.groovy
and: // command the gate keeper to open the gate and shutdown command.releaseAll() server.expect(server.get("command").send("stop")) then: // waits for build to start and finish buildTriggeredAndSucceeded() // Change has been incorporated outputFile.text == "changed" }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/proxy/config/config.go
func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) { c.eventHandlers = append(c.eventHandlers, handler) } // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadUnexpectedException(t); } } // /** // * Spin-waits up to LONG_DELAY_MS until flag becomes true. // */ // public void await(AtomicBoolean flag) { // await(flag, LONG_DELAY_MS); // } // /** // * Spin-waits up to the specified timeout until flag becomes true. // */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0)