- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 43 for stopCh (0.18 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_manager.go
for _, containerResult := range killContainerResults { result.AddSyncResult(containerResult) } // stop sandbox, the sandbox will be removed in GarbageCollect killSandboxResult := kubecontainer.NewSyncResult(kubecontainer.KillPodSandbox, runningPod.ID) result.AddSyncResult(killSandboxResult) // Stop all sandboxes belongs to same pod for _, podSandbox := range runningPod.Sandboxes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
cmd/xl-storage.go
atomic.AddInt32(&s.scanning, 1) defer atomic.AddInt32(&s.scanning, -1) var err error stopFn := globalScannerMetrics.log(scannerMetricScanBucketDrive, s.drivePath, cache.Info.Name) defer func() { res := make(map[string]string) if err != nil { res["err"] = err.Error() } stopFn(res) }() // Updates must be closed before we return. defer xioutil.SafeClose(updates)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2) -
src/testing/testing.go
} // FailNow marks the function as having failed and stops its execution // by calling runtime.Goexit (which then runs all deferred calls in the // current goroutine). // Execution will continue at the next test or benchmark. // FailNow must be called from the goroutine running the // test or benchmark function, not from other goroutines // created during the test. Calling FailNow does not stop // those other goroutines.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
# the process is sometimes unstoppable, so this function works around it # by killing the processes. function Restart-LogService([string]$service, [string]$cmdline) { Stop-Service -NoWait -ErrorAction Ignore $service # Wait (if necessary) for service to stop. $timeout = 10 $stopped = (Get-service $service).Status -eq 'Stopped' for ($i = 0; $i -lt $timeout -and !($stopped); $i++) { Start-Sleep 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
src/net/http/transport.go
if t.IdleConnTimeout > 0 { oldTime = time.Now().Add(-t.IdleConnTimeout) } // Look for most recently-used idle connection. if list, ok := t.idleConn[w.key]; ok { stop := false delivered := false for len(list) > 0 && !stop { pconn := list[len(list)-1] // See whether this connection has been idle too long, considering // only the wall time (the Round(0)), in case this is a laptop or VM
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/AbstractGradleExecuter.java
result.assertResultVisited(); } beforeExecute.execute(this); assertCanExecute(); assert !(usesSharedDaemons() && (args.contains("--stop") || tasks.contains("--stop"))) : "--stop cannot be used with daemons that are shared with other tests, since this will cause other tests to fail."; collectStateBeforeExecution(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 55.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
stop := istiotest.NewStop(t) go configController.Run(stop) se := serviceentry.NewController(configController, xdsUpdater, meshWatcher) client.RunAndWait(stop) kc.AppendWorkloadHandler(se.WorkloadInstanceHandler) se.AppendWorkloadHandler(kc.WorkloadInstanceHandler) go kc.Run(stop) go se.Run(stop) return configController, client.Kube(), xdsUpdater }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
PreStop: a.PreStopHandler, } } return pod, container, nil } // killContainer kills a container through the following steps: // * Run the pre-stop lifecycle hooks (if applicable). // * Stop the container.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (p *PriorityQueue) Run(logger klog.Logger) { go wait.Until(func() { p.flushBackoffQCompleted(logger) }, 1.0*time.Second, p.stop) go wait.Until(func() { p.flushUnschedulablePodsLeftover(logger) }, 30*time.Second, p.stop) } // queueingStrategy indicates how the scheduling queue should enqueue the Pod from unschedulable pod pool. type queueingStrategy int const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/services/BuildServiceIntegrationTest.groovy
} """ when: fails("first", "second") then: failure.assertHasFailure("Failed to stop service 'counter1'.") { it.assertHasCause("broken") } failure.assertHasFailure("Failed to stop service 'counter2'.") { it.assertHasCause("broken") } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 61K bytes - Viewed (0)