- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 824 for terminateCh (0.24 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) -
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) -
src/cmd/go/testdata/script/test_fuzz_mutator_repeat.txt
# TODO(jayconrod): support shared memory on more platforms. [!GOOS:darwin] [!GOOS:linux] [!GOOS:windows] skip # Verify that the fuzzing engine records the actual crashing input, even when # a worker process terminates without communicating the crashing input back # to the coordinator. [short] skip env GOCACHE=$WORK/cache # Start fuzzing. The worker crashes after 100 iterations. # The fuzz function writes the crashing input to "want" before exiting.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 2K bytes - Viewed (0)