- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 350 for waitms (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/server/routes/debugsocket.go
s.mux.HandleFunc("/debug/flags", f.Index) s.mux.HandleFunc("/debug/flags/", f.Index) url := path.Join("/debug/flags", flag) s.mux.HandleFunc(url, handler) f.addFlag(flag) } // Run starts the server and waits for stopCh to be closed to close the server. func (s *DebugSocket) Run(stopCh <-chan struct{}) error { if err := os.Remove(s.path); err != nil && !os.IsNotExist(err) { return fmt.Errorf("failed to remove (%v): %v", s.path, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 00:33:16 UTC 2022 - 2.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertThat(nanosPerSecond * Long.MAX_VALUE).isLessThan(0L); // Check that we wait long enough anyway (presumably as long as MAX_VALUE nanos): TimedWaiterThread waiter = new TimedWaiterThread(future, Long.MAX_VALUE, SECONDS); waiter.start(); waiter.awaitWaiting(); future.set(1); waiter.join(); } @J2ktIncompatible // TODO(b/324550390): Enable
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
- the HTTP Server stops listening immediately - any new request arriving on a new TCP socket is denied with a network error similar to 'connection refused' - the HTTP Server waits gracefully for existing requests to complete up to '60s' (dictated by ShutdownTimeout) - active long running requests will receive a GOAWAY. T0+70s: HTTPServerStoppedListening:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/msan8.go
void msanGoTraceback(void* parg) { struct cgoTracebackArg* arg = (struct cgoTracebackArg*)(parg); arg->buf[0] = 0; } // msanGoWait will be called with all registers undefined as far as // msan is concerned. It just waits for a signal. // Because the registers are msan-undefined, the signal handler will // be invoked with all registers msan-undefined. __attribute__((noinline))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 18 21:30:58 UTC 2023 - 2.7K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackClient.java
} /** Set the OAuth session for this client. */ public synchronized void initOauthSession(OAuthSession session) { this.session = session; this.notifyAll(); } /** Waits for an OAuth session for this client to be set. */ public synchronized void awaitAccessToken(Timeout timeout) throws InterruptedIOException { while (session == null) { timeout.waitUntilNotified(this); } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 12 03:31:36 UTC 2019 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
// initialization signals. type InitializationSignal interface { // Signal notifies the dispatcher about finished initialization. Signal() // Wait waits for the initialization signal. Wait() } type initializationSignal struct { once sync.Once done chan struct{} } func NewInitializationSignal() InitializationSignal { return &initializationSignal{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
* numElements} elements are not available, it will wait for them up to the specified timeout. * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements * @param numElements the number of elements to be waited for * @param timeout how long to wait before giving up * @return the number of elements transferred
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 18K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/ContinuousBuildGateIntegrationTest.groovy
and: // command the gate keeper to open the gate and shutdown command.releaseAll() server.expect(server.get("command").send("stop")) then: // waits for build to start and finish buildTriggeredAndSucceeded() // Change has been incorporated outputFile.text == "changed" }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/proxy/config/config.go
func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) { c.eventHandlers = append(c.eventHandlers, handler) } // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0)