- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 113 for react (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
if (plan is FailedPlan) return plan.result // Connect TCP asynchronously. tcpConnectsInFlight += plan val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}" taskRunner.newQueue().schedule( object : Task(taskName) { override fun runOnce(): Long { val connectResult = try { plan.connectTcp()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.8.md
* fix azure disk not available issue when device name changed ([#57549](https://github.com/kubernetes/kubernetes/pull/57549), [@andyzhangx](https://github.com/andyzhangx)) * Allow kubernetes components to react to SIGTERM signal and shutdown gracefully. ([#57756](https://github.com/kubernetes/kubernetes/pull/57756), [@mborsz](https://github.com/mborsz))
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Tue Feb 20 15:45:02 GMT 2024 - 312.2K bytes - Viewed (1) -
internal/s3select/sql/jsonpath.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/service.go
// For each call, unfreezeServices must be called once. func unfreezeServices() { // We need a lock since we need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
} /** * 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(); } /** * Waits for the all the services to reach a terminal state for no more than the given time. After
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Predicates.java
@Override public boolean apply(CharSequence t) { return pattern.matcher(t).find(); } @Override public int hashCode() { // Pattern uses Object.hashCode, so we have to reach // inside to build a hashCode consistent with equals. return Objects.hashCode(pattern.pattern(), pattern.flags()); } @Override public boolean equals(@CheckForNull Object obj) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 23.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
TimeoutException.class, () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS)); assertThat(e) .hasMessageThat() .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state."); } private static class TestService extends AbstractIdleService { int startUpCalled = 0; int shutDownCalled = 0; final List<State> transitionStates = Lists.newArrayList();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
config.QueueList = append(config.QueueList[:i], config.QueueList[i+1:]...) } // This is a one time activity we shall do this // here and allow stale ARN to be removed. We shall // never reach a stage where we will have stale // notification configs. } } else { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } configData, err := xml.Marshal(config)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
TimeoutException.class, () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS)); assertThat(e) .hasMessageThat() .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state."); } private static class TestService extends AbstractIdleService { int startUpCalled = 0; int shutDownCalled = 0; final List<State> transitionStates = Lists.newArrayList();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
(if (isCanceled()) "canceled " else "") + (if (forWebSocket) "web socket" else "call") + " to " + redactedUrl() ) } internal fun redactedUrl(): String = originalRequest.url.redact() inner class AsyncCall( private val responseCallback: Callback, ) : Runnable { @Volatile var callsPerHost = AtomicInteger(0) private set
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2)