- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,377 for waitc (0.04 sec)
-
src/math/tanh.go
// MAXLOG = 8.8029691931113054295988e+01 = log(2**127) // MINLOG = -8.872283911167299960540e+01 = log(2**-128) // // A rational function is used for |x| < 0.625. The form // x + x**3 P(x)/Q(x) of Cody & Waite is employed. // Otherwise, // tanh(x) = sinh(x)/cosh(x) = 1 - 2/(exp(2x) + 1). // // ACCURACY: // // Relative error: // arithmetic domain # trials peak rms
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
- the HTTP Server stops listening immediately - any new request arriving on a new TCP socket is denied with a network error similar to 'connection refused' - the HTTP Server waits gracefully for existing requests to complete up to '60s' (dictated by ShutdownTimeout) - active long running requests will receive a GOAWAY. T0+70s: HTTPServerStoppedListening:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K 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) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup.go
wg sync.WaitGroup // Once Wait is initiated, all consecutive Done invocation will be // rate limited using this rate limiter. limiter RateLimiter stopCtx context.Context mu sync.Mutex // wait indicate whether Wait is called, if true, // then any Add with positive delta will return error. wait bool // number of request(s) currently using the wait group count int }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 3.7K 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) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 8.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) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go
defer wg.mu.RUnlock() if wg.wait && delta > 0 { return fmt.Errorf("add with positive delta after Wait is forbidden") } wg.wg.Add(delta) return nil } // Done decrements the WaitGroup counter. func (wg *SafeWaitGroup) Done() { wg.wg.Done() } // Wait blocks until the WaitGroup counter is zero. func (wg *SafeWaitGroup) Wait() { wg.mu.Lock() wg.wait = true wg.mu.Unlock() wg.wg.Wait()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 11 03:04:14 UTC 2018 - 1.5K 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)