- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,274 for Forever (0.38 sec)
-
security/pkg/nodeagent/sds/sdsservice.go
// configured, in which case this will fail; if it becomes noisy we should disable the entire SDS // server in these cases. go func() { // TODO: do we need max timeout for retry, seems meaningless to retry forever if it never succeed b := backoff.NewExponentialBackOff(backoff.DefaultOption()) // context for both timeout and channel, whichever stops first, the context will be done ctx, cancel := context.WithCancel(context.Background())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/handler-api.go
if unlock, ok := val.(chan struct{}); ok && unlock != nil { // Wait until unfrozen. select { case <-unlock: case <-r.Context().Done(): // if client canceled we don't need to wait here forever. return } } } } globalHTTPStats.addRequestsInQueue(1) pool, deadline := globalAPIConfig.getRequestsPool() if pool == nil { globalHTTPStats.addRequestsInQueue(-1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
src/net/rpc/server_test.go
if err != nil { t.Fatal("close error:", err) } err = client.Call("Arith.Add", &Args{7, 9}, new(Reply)) if err != ErrShutdown { t.Errorf("Forever: expected ErrShutdown got %v", err) } } // Tests the fix to issue 11221. Without the fix, this loops forever or crashes. func TestAcceptExitAfterListenerClose(t *testing.T) { newServer := NewServer() newServer.Register(new(Arith))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 05:23:29 UTC 2023 - 19K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharStreamsTest.java
@Override public int read(char[] cbuf, int off, int len) throws IOException { // if a buffer isn't being cleared correctly, this method will eventually start being called // with a len of 0 forever if (len <= 0) { fail("read called with a len of " + len); } // read fewer than the max number of chars to read // shouldn't be a problem unless the buffer is shrinking each call
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharStreamsTest.java
@Override public int read(char[] cbuf, int off, int len) throws IOException { // if a buffer isn't being cleared correctly, this method will eventually start being called // with a len of 0 forever if (len <= 0) { fail("read called with a len of " + len); } // read fewer than the max number of chars to read // shouldn't be a problem unless the buffer is shrinking each call
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
"istio.io/istio/pkg/model" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/wasm" ) // sendDeltaRequest is a small wrapper around sending to con.requestsChan. This ensures that we do not // block forever on func (con *ProxyConnection) sendDeltaRequest(req *discovery.DeltaDiscoveryRequest) { con.deltaRequestsChan.Put(req) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
lastVerified atomic.Value } func (l *log) Name() string { return "log" } func (l *log) Check(_ *http.Request) error { l.startOnce.Do(func() { l.lastVerified.Store(time.Now()) go wait.Forever(func() { klog.Flush() l.lastVerified.Store(time.Now()) }, time.Minute) }) lastVerified := l.lastVerified.Load().(time.Time) if time.Since(lastVerified) < (2 * time.Minute) { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/Striped64.java
* colliding threads. Because search is random, and collisions * only become known via CAS failures, convergence can be slow, * and because threads are typically not bound to CPUS forever, * may not occur at all. However, despite these limitations, * observed contention rates are typically low in these cases. * * It is possible for a Cell to become unused when threads that
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 11.5K bytes - Viewed (0) -
docs/en/docs/tutorial/security/first-steps.md
* Normally, a token is set to expire after some time. * So, the user will have to log in again at some point later. * And if the token is stolen, the risk is less. It is not like a permanent key that will work forever (in most of the cases). * The frontend stores that token temporarily somewhere. * The user clicks in the frontend to go to another section of the frontend web app. * The frontend needs to fetch some more data from the API.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon Jun 03 01:48:20 UTC 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
* colliding threads. Because search is random, and collisions * only become known via CAS failures, convergence can be slow, * and because threads are typically not bound to CPUS forever, * may not occur at all. However, despite these limitations, * observed contention rates are typically low in these cases. * * It is possible for a Cell to become unused when threads that
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 11.5K bytes - Viewed (2)