- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,123 for terminateCh (0.5 sec)
-
pkg/filewatcher/worker.go
case ft.errors <- err: // nothing to do case ft := <-wk.retireTrackerCh: retireTracker(ft) case <-wk.terminateCh: return } } case ft := <-wk.retireTrackerCh: retireTracker(ft) case <-wk.terminateCh: return } } } // used only by the worker goroutine func (wk *worker) drainRetiringTrackers() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 22:31:06 UTC 2024 - 5.2K bytes - Viewed (0) -
src/runtime/testdata/testwinsignal/main.go
// // (In https://go.dev/issue/41884 the handler returned immediately, // which caused Windows to terminate the program before the goroutine // that received the SIGTERM had a chance to actually clean up.) time.Sleep(time.Second) // Print the signal's name: "terminated" makes the test succeed. fmt.Println(sig)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 18 07:37:53 UTC 2022 - 1.3K bytes - Viewed (0) -
pkg/envoy/agent.go
log.Warnf("Error in invoking drain listeners endpoint: %v", err) } // If we drained now, skip draining + waiting later // When we terminate, we will instead exit immediately a.DisableDraining() } // terminate starts exiting the process. func (a *Agent) terminate() { log.Infof("Agent draining Proxy for termination") if a.skipDrain.Load() { log.Infof("Agent already drained, exiting immediately")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pkg/ctrlz/assets/templates/home.html
</tr> <tr> <td>IP Address</td> <td>{{.IP}}</td> </tr> </tbody> </table> <br/> <button id="terminate" class="btn btn-istio" onclick="terminateProcess()">Terminate Process</button> <p id="terminated" style="display:none">Process Terminated</p> {{ template "last-refresh" .}} <script> "use strict" function refreshHomeInfo() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.8K bytes - Viewed (0) -
src/text/tabwriter/tabwriter.go
// A cell represents a segment of text terminated by tabs or line breaks. // The text itself is stored in a separate buffer; cell only describes the // segment's size in bytes, its width in runes, and whether it's an htab // ('\t') terminated cell. type cell struct { size int // cell size in bytes width int // cell width in runes htab bool // true if the cell is terminated by an htab ('\t') }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 16:46:34 UTC 2024 - 17.8K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_non_crash_signal.txt
# When a process terminates another process, it provides an exit code. [GOOS:windows] skip [!fuzz] skip [short] skip env GOCACHE=$WORK/cache # FuzzNonCrash sends itself a signal that does not appear to be a crash. # We should not save a crasher. ! go test -fuzz=FuzzNonCrash ! exists testdata ! stdout unreachable ! stderr unreachable
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 1.9K bytes - Viewed (0) -
src/internal/fuzz/worker.go
// it terminates. If the worker doesn't terminate after a short time, stop // signals it with os.Interrupt (where supported), then os.Kill. // // stop returns the error the process terminated with, if any (same as // w.waitErr). // // stop must be called at least once after start returns successfully, even if // the worker process terminates unexpectedly. func (w *worker) stop() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_io_error.txt
sendGarbageToCoordinator(f) time.Sleep(3600 * time.Second) // pause until coordinator terminates the process } f.Fuzz(func(*testing.T, []byte) {}) } func FuzzClosePipeAfter(f *testing.F) { f.Fuzz(func(t *testing.T, _ []byte) { if isWorker() { sendGarbageToCoordinator(t) time.Sleep(3600 * time.Second) // pause until coordinator terminates the process } }) } -- io_error_windows_test.go -- package io_error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
klog.V(3).InfoS("No status for pod", "pod", klog.KObj(w.pod)) return true } // Worker should terminate if pod is terminated. if status.Phase == v1.PodFailed || status.Phase == v1.PodSucceeded { klog.V(3).InfoS("Pod is terminated, exiting probe worker", "pod", klog.KObj(w.pod), "phase", status.Phase) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/kube/kclient/events.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 22:23:28 UTC 2023 - 1.9K bytes - Viewed (0)