- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 844 for steady (0.13 sec)
-
guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
} @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(runnable); checkNotNull(timeoutUnit); try { runnable.run(); } catch (Exception e) { // sneaky checked exception throw new UncheckedExecutionException(e); } catch (Error e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/test/echo/server/instance.go
UDSServer: udsServer, IsServerReady: s.isReady, Version: s.Version, Cluster: s.Cluster, TLSCert: s.TLSCert, TLSKey: s.TLSKey, Dialer: s.Dialer, ListenerIP: listenerIP, DisableALPN: s.DisableALPN, IstioVersion: s.IstioVersion, }) } func (s *Instance) isReady() bool { return atomic.LoadUint32(&s.ready) == 1 }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 7.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val index = serialTaskQueue.indexOfFirst { it.isReady() } if (index == -1) return null val nextTask = serialTaskQueue.removeAt(index) currentTask = nextTask contextSwitchCount++ nextTask.start() return nextTask } private interface SerialTask { /** Returns true if this task is ready to start. */ fun isReady() = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
labelQueue.add(label); } /** * Dispatches all listeners {@linkplain #enqueue enqueued} prior to this call, serially and in * order. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception void dispatch() { boolean scheduleEventRunner = false; synchronized (this) { if (!isThreadScheduled) { isThreadScheduled = true;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ImmediateFuture.java
this.value = value; } @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 3.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
private byte[] b; private int n; private boolean ready; private SmbFileOutputStream out; private SmbException e = null; WriterThread () { super("JCIFS-WriterThread"); this.ready = false; } /** * @return the ready */ boolean isReady () { return this.ready; } /** * @throws SmbException
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:52:42 UTC 2020 - 17.1K bytes - Viewed (0) -
samples/addons/grafana.yaml
"x":0,"y":1},"id":19,"links":[],"options":{"code":{"language":"plaintext","showLineNumbers":false,"showMiniMap":false},"content":"The charts on this dashboard are intended to show Istio main components cost in terms of resources utilization under steady load.\n\n- **vCPU / 1k rps:** shows vCPU utilization by the main Istio components normalized by 1000 requests/second. When idle or low traffic, this chart will be blank. The curve for istio-proxy refers to the services sidecars only.\n- **vCPU:**...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 242.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() } if (connectResult.isSuccess) { return connectResult.plan.handleSuccess() } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt
*/ package okhttp3.internal.connection /** Reuse a connection from the pool. */ internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected") override fun connectTlsEtc() = error("already connected") override fun handleSuccess() = connection
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt
var firstException: IOException? = null while (true) { if (routePlanner.isCanceled()) throw IOException("Canceled") try { val plan = routePlanner.plan() if (!plan.isReady) { val tcpConnectResult = plan.connectTcp() val connectResult = when { tcpConnectResult.isSuccess -> plan.connectTlsEtc() else -> tcpConnectResult }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0)