- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 111 for Await (0.04 sec)
-
pkg/controlplane/apiserver/options/options_test.go
"--audit-log-maxbackup=12", "--audit-log-maxsize=13", "--audit-log-path=/var/log", "--audit-log-mode=blocking", "--audit-log-batch-buffer-size=46", "--audit-log-batch-max-size=47", "--audit-log-batch-max-wait=48s", "--audit-log-batch-throttle-enable=true", "--audit-log-batch-throttle-qps=49.5", "--audit-log-batch-throttle-burst=50", "--audit-log-truncate-enabled=true", "--audit-log-truncate-max-batch-size=45",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// fairness effect. go wait.JitterUntil(kl.syncNodeStatus, kl.nodeStatusUpdateFrequency, 0.04, true, wait.NeverStop) go kl.fastStatusUpdateOnce() // start syncing lease go kl.nodeLeaseController.Run(context.Background()) } go wait.Until(kl.updateRuntimeUp, 5*time.Second, wait.NeverStop) // Set up iptables util rules if kl.makeIPTablesUtilChains {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
cmd/batch-expire.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
if doneCh == nil { return } // Indicate we are ready to write. doneCh <- err // Wait for channel to be closed so we don't race on writes. <-doneCh // Clear so we can be called multiple times without crashing. doneCh = nil } } // waitForHTTPResponse will wait for responses where keepHTTPResponseAlive // has been used. // The returned reader contains the payload.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K 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) -
android/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) -
cmd/kube-apiserver/app/options/options_test.go
"--audit-log-maxbackup=12", "--audit-log-maxsize=13", "--audit-log-path=/var/log", "--audit-log-mode=blocking", "--audit-log-batch-buffer-size=46", "--audit-log-batch-max-size=47", "--audit-log-batch-max-wait=48s", "--audit-log-batch-throttle-enable=true", "--audit-log-batch-throttle-qps=49.5", "--audit-log-batch-throttle-burst=50", "--audit-log-truncate-enabled=true", "--audit-log-truncate-max-batch-size=45",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
internal/grid/connection.go
return true }) c.inStream.Range(func(key uint64, value *muxServer) bool { value.close() return true }) c.inStream.Clear() c.outgoing.Clear() // Wait for existing to exit c.handleMsgWg.Wait() } func (c *Connection) updateState(s State) { c.connChange.L.Lock() defer c.connChange.L.Unlock() // We may have reads that aren't locked, so update atomically.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/os/exec_posix.go
} } return newHandleProcess(pid, h), nil } func (p *Process) kill() error { return p.Signal(Kill) } // ProcessState stores information about a process, as reported by Wait. type ProcessState struct { pid int // The process's id. status syscall.WaitStatus // System-dependent status info. rusage *syscall.Rusage } // Pid returns the process id of the exited process.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { return err } diskVersions[index] = resp.Sign dataDirs[index] = resp.OldDataDir return nil }, index) } // Wait for all renames to finish. errs := g.Wait() err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum) if err != nil { dg := errgroup.WithNErrs(len(disks)) for index, nerr := range errs {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0)