- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 385 for Stopping (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// blockedWatchers is a list of watchers whose buffer is currently full. blockedWatchers []*cacheWatcher // watchersToStop is a list of watchers that were supposed to be stopped // during current dispatching, but stopping was deferred to the end of // dispatching that event to avoid race with closing channels in watchers. watchersToStop []*cacheWatcher // Maintain a timeout queue to send the bookmark event before the watcher times out.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 27.5K bytes - Viewed (0) -
src/runtime/mgcscavenge_test.go
t.Fatal("timed out waiting for scavenger to run to completion") } // Run another check. verifyScavengerState(t, 2*totalWork) // This time, let's stop after a certain amount of work. // // Pick a stopping point such that when subtracted from totalWork // we get a multiple of a relatively large power of 2. verifyScavengerState // always makes an exact check, but the scavenger might go a little over,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.2K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/link.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 20.7K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/custom_tasks.adoc
<2> *Modify Output*: The task writes to its output file as it executes. <3> *Task Failure*: The task throws a `VerificationException` and fails at this point. <4> *Continue to Modify Output*: This line never runs due to the exception stopping the task. <5> *Consume Output*: The `postProcess` task depends on the output of the `process` task due to using that task's outputs as its own inputs.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Feb 25 15:21:05 UTC 2024 - 23.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/modfile/read.go
func (in *input) lex() token { tok := in.token in.readToken() return tok } // readToken lexes the next token from the text and stores it in in.token. func (in *input) readToken() { // Skip past spaces, stopping at non-space or EOF. for !in.eof() { c := in.peekRune() if c == ' ' || c == '\t' || c == '\r' { in.readRune() continue } // Comment runs to end of line. if in.peekPrefix("//") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 23.1K bytes - Viewed (0) -
src/context/context.go
}) } return c, func() { c.cancel(true, Canceled, nil) } } // A timerCtx carries a timer and a deadline. It embeds a cancelCtx to // implement Done and Err. It implements cancel by stopping its timer then // delegating to cancelCtx.cancel. type timerCtx struct { cancelCtx timer *time.Timer // Under cancelCtx.mu. deadline time.Time }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
cmd/admin-handlers.go
if nerr.Err != nil { logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String()) adminLogIf(ctx, nerr.Err) } } // Reply to the client before restarting, stopping MinIO server. writeSuccessResponseHeadersOnly(w) switch serviceSig { case serviceFreeze: freezeServices() case serviceUnFreeze: unfreezeServices() case serviceRestart, serviceStop:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/compress/flate/deflate_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/term/terminal.go
// for the last character in a line. However, when // writing a character (except a new line) that causes // a line wrap, the position will be advanced two // places. // // So, if we are stopping at the end of a line, we // need to write a newline so that our cursor can be // advanced to the next line. t.outBuf = append(t.outBuf, '\r', '\n') } } func (t *Terminal) eraseNPreviousChars(n int) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 22 17:16:14 UTC 2022 - 22.5K bytes - Viewed (0)