- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,113 for Forever (0.15 sec)
-
src/runtime/lock_futex.go
// // futexsleep(addr *uint32, val uint32, ns int64) // Atomically, // if *addr == val { sleep } // Might be woken up spuriously; that's allowed. // Don't sleep longer than ns; ns < 0 means forever. // // futexwakeup(addr *uint32, cnt uint32) // If any procs are sleeping on addr, wake up at most cnt. const ( mutex_unlocked = 0 mutex_locked = 1 mutex_sleeping = 2 active_spin = 4
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
// // https://github.com/kubernetes/client-go/blob/master/tools/clientcmd/overrides.go // // Set this to something reasonable so request to webhooks don't hang forever. clientConfig.Timeout = defaultRequestTimeout // Avoid client-side rate limiting talking to the webhook backend. // Rate limiting should happen when deciding how many requests to serve. clientConfig.QPS = -1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.3K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compilation_profiler.cc
DeviceCompilationProfiler::ClusterCompileStats* stats) { ++stats->execution_count; // The is_megamorphic bit is "sticky". We assume clusters that have been // observed to be megamorphic once stay megamorphic forever. if (!stats->is_megamorphic && ShouldBeMegamorphic(stats->compile_count, stats->execution_count)) { VLOG(1) << "Marking " << function.name() << " as megamorphic, compile_count=" << stats->compile_count
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/webhooks/webhookpatch.go
controllers.WithRateLimiter(workqueue.NewItemFastSlowRateLimiter(100*time.Millisecond, 1*time.Minute, 5)), // Webhook patching has to be retried forever. But the retries would be rate limited. controllers.WithMaxAttempts(math.MaxInt)) } // Run runs the WebhookCertPatcher func (w *WebhookCertPatcher) Run(stopChan <-chan struct{}) { go w.startCaBundleWatcher(stopChan)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 28 00:36:38 UTC 2023 - 6.1K bytes - Viewed (0) -
src/packaging/deb/init.d/fess
exit $return ;; stop) log_daemon_msg "Stopping $DESC" if [ -f "$PID_FILE" ]; then start-stop-daemon --stop --pidfile "$PID_FILE" \ --user "$FESS_USER" \ --quiet \ --retry forever/TERM/20 > /dev/null if [ $? -eq 1 ]; then log_progress_msg "$DESC is not running but pid file exists, cleaning up" elif [ $? -eq 3 ]; then PID="`cat $PID_FILE`"
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 5.8K bytes - Viewed (0) -
src/net/http/cgi/integration_test.go
func TestKillChildAfterCopyError(t *testing.T) { testenv.MustHaveExec(t) h := &Handler{ Path: os.Args[0], Root: "/test.go", } req, _ := http.NewRequest("GET", "http://example.com/test.go?write-forever=1", nil) rec := httptest.NewRecorder() var out bytes.Buffer const writeLen = 50 << 10 rw := &customWriterRecorder{&limitWriter{&out, writeLen}, rec} h.ServeHTTP(rw, req)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 18:42:44 UTC 2023 - 5.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
public boolean isDone() { /* * If isDone is true during the call to listenInPoolThread, * listenInPoolThread doesn't start a thread. Make sure it's false the * first time through (and forever after, since no one else cares about * it). */ return false; } } private static final class RecordingRunnable implements Runnable {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 9.7K bytes - Viewed (0) -
pkg/kubelet/token/token_manager.go
} return tokenRequest, err }, cache: make(map[string]*authenticationv1.TokenRequest), clock: clock.RealClock{}, } go wait.Forever(m.cleanup, gcPeriod) return m } // Manager manages service account tokens for pods. type Manager struct { // cacheMutex guards the cache cacheMutex sync.RWMutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/finisher/finisher.go
defer func() { go func() { timedOutAt := time.Now() var result *result select { case result = <-resultCh: case <-time.After(postTimeoutWait): // we will not wait forever, if we are here then we know that some sender // goroutines are taking longer than postTimeoutWait. } postTimeoutLogger(timedOutAt, result) }() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 14:20:33 UTC 2021 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
public boolean isDone() { /* * If isDone is true during the call to listenInPoolThread, * listenInPoolThread doesn't start a thread. Make sure it's false the * first time through (and forever after, since no one else cares about * it). */ return false; } } private static final class RecordingRunnable implements Runnable {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 9.7K bytes - Viewed (0)