- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 797 for Forever (0.26 sec)
-
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) -
pilot/cmd/pilot-discovery/app/cmd.go
if err := discoveryServer.Start(stop); err != nil { return fmt.Errorf("failed to start discovery service: %v", err) } cmd.WaitSignal(stop) // Wait until we shut down. In theory this could block forever; in practice we will get // forcibly shut down after 30s in Kubernetes. discoveryServer.WaitUntilCompletion() return nil }, } } func addFlags(c *cobra.Command) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/cache/ttlCache.go
// method. Given the nature of this code, forgetting to call Close on one of these objects // can lead to a substantial permanent memory leak in a process by causing the cache to // remain alive forever, along with all the entries the cache points to. The use of the // ttlWrapper type makes it so we control the exposure of the underlying ttlCache pointer.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.8K bytes - Viewed (0) -
src/main/java/jcifs/SmbConstants.java
static final int SMB1_HEADER_LENGTH = 32; static final long MILLISECONDS_BETWEEN_1970_AND_1601 = 11644473600000L; static final String DEFAULT_OEM_ENCODING = "Cp850"; static final int FOREVER = -1; /** * When specified as the <tt>shareAccess</tt> constructor parameter, * other SMB clients (including other threads making calls into jCIFS)
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.9K bytes - Viewed (0) -
src/net/http/httptest/server_test.go
cidle.Write([]byte("HEAD / HTTP/1.1\r\nHost: foo\r\n\r\n")) _, err := http.ReadResponse(bufio.NewReader(cidle), nil) if err != nil { t.Fatal(err) } ts.Close() // test we don't hang here forever. } // Issue 14290 func testServerCloseClientConnections(t *testing.T, newServer newServerFunc) { var s *Server s = newServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:12 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
} c.EndpointReconciler.Destroy() }() select { case <-finishedReconciling: // done case <-time.After(2 * c.EndpointInterval): // don't block server shutdown forever if we can't reach etcd to remove ourselves klog.Warning("RemoveEndpoints() timed out") } } // Run periodically updates the kubernetes service func (c *Controller) Run(ch <-chan struct{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
internal/lock/lock_windows.go
} // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) { var lockType uint32 = lockFileFailImmediately | lockFileExclusiveLock
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/envoy/agent.go
// 4. /drain + SIGTERM. This is the shutdown when using Kubernetes native sidecars. // /drain is called when the pod shutdown starts. We start draining, forever. // Once the app containers shutdown, we get a SIGTERM. We have no use to run anymore, so shutdown immediately. // If somehow we do not shutdown from the SIGTERM fast enough, we may get a SIGKILL later.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup_test.go
activeAt, activeNow, err := target.Wait(func(count int) (RateLimiter, context.Context, context.CancelFunc) { defer close(waitingCh) // no deadline in context, Wait will wait forever, we want to measure // how long it takes for the requests to drain. return rate.NewLimiter(rate.Limit(n/int(grace.Seconds())), 1), context.Background(), func() {} }) took := time.Since(now)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 8.6K bytes - Viewed (0)