- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 385 for Stopping (0.16 sec)
-
pkg/controller/nodeipam/ipam/sync/sync.go
logger.V(4).Info("Try to resync node later", "node", klog.KRef("", sync.nodeName), "resyncTime", timeout) for { select { case op, more := <-sync.opChan: if !more { logger.V(2).Info("Stopping sync loop") return } sync.c.ReportResult(op.run(logger, sync)) if !delayTimer.Stop() { <-delayTimer.C } case <-delayTimer.C:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K bytes - Viewed (0) -
src/cmd/go/internal/modcmd/vendor.go
} } type metakey struct { modPath string dst string } var copiedMetadata = make(map[metakey]bool) // copyMetadata copies metadata files from parents of src to parents of dst, // stopping after processing the src parent for modPath. func copyMetadata(modPath, pkg, dst, src string, copiedFiles map[string]bool) { for parent := 0; ; parent++ { if copiedMetadata[metakey{modPath, dst}] { break }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 14 14:19:59 UTC 2024 - 14.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error { // this can happen if the pod was dynamically added to the mesh after it was created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
} } @PreDestroy public void destroy() { if (!finishCrawling) { if (logger.isInfoEnabled()) { logger.info("Stopping all crawler."); } forceStop(); } } public void addFinishedSessionId(final String sessionId) { synchronized (finishedSessionIdList) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 24.2K bytes - Viewed (0) -
src/os/signal/signal_test.go
c := make(chan os.Signal, 1) Notify(c, syscall.SIGCONT) defer Stop(c) syscall.Kill(syscall.Getpid(), syscall.SIGCONT) waitSig(t, c, syscall.SIGCONT) } // Test race between stopping and receiving a signal (issue 14571). func TestAtomicStop(t *testing.T) { if os.Getenv("GO_TEST_ATOMIC_STOP") != "" { atomicStopTestProgram(t) t.Fatal("atomicStopTestProgram returned") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_server_journal.go
} } // heuristicsCopyFileLogs attempts to collect logs from either // /var/log/service // /var/log/service.log or // /var/log/service/service.log or // in that order stopping on first success. func heuristicsCopyFileLogs(ctx context.Context, w io.Writer, service string) { logFileNames := [3]string{ service, fmt.Sprintf("%s.log", service), fmt.Sprintf("%s/%s.log", service, service),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 26 18:56:28 UTC 2023 - 13.5K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
if err != nil { return result, fmt.Errorf("failed to create temp dir: %v", err) } var errCh chan error tearDown := func() { // Cancel is stopping apiserver and cleaning up // after itself, including shutting down its storage layer. tCtx.Cancel("tearing down") // If the apiserver was started, let's wait for it to // shutdown clearly.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheDependencyResolutionIntegrationTest.groovy
it.assertHasCause("Failed to transform a.jar (project :a) to match attributes {artifactType=jar, color=green}.") // TODO - should collect all failures rather than stopping on first failure } when: configurationCacheFails(":resolve") then: configurationCache.assertStateLoaded() output.count("processing") == 2
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 54.1K bytes - Viewed (0) -
src/runtime/runtime2.go
// with a waitreason of the form waitReasonSync{RW,}Mutex{R,}Lock. totalMutexWaitTime atomic.Int64 // stwStoppingTimeGC/Other are distributions of stop-the-world stopping // latencies, defined as the time taken by stopTheWorldWithSema to get // all Ps to stop. stwStoppingTimeGC covers all GC-related STWs, // stwStoppingTimeOther covers the others. stwStoppingTimeGC timeHistogram
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
src/index/suffixarray/suffixarray_test.go
if i < len(x) { for x[i] = 1; x[i] <= byte(max); x[i]++ { testRec(t, x, i+1, max, numFail, build) } return } if !testSA(t, x, build) { *numFail++ if *numFail >= 10 { t.Errorf("stopping after %d failures", *numFail) t.FailNow() } } } // testSA tests the suffix array build function on the input x. // It constructs the suffix array and then checks that it is correct.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 14.1K bytes - Viewed (0)