- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 3,641 for shouldn (0.16 sec)
-
cni/pkg/nodeagent/ztunnelserver.go
err: err, resp: resp, } case <-time.After(ztunnelKeepAliveCheckInterval): // do a short read, just to see if the connection to ztunnel is // still alive. As ztunnel shouldn't send anything unless we send // something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/handler-api.go
// Only replace if needed. // Existing requests will use the previous limit, // but new requests will use the new limit. // There will be a short overlap window, // but this shouldn't last long. t.requestsPool = make(chan struct{}, apiRequestsMaxPerNode) } t.requestsDeadline = cfg.RequestsDeadline listQuorum := cfg.ListQuorum if listQuorum == "" { listQuorum = "strict" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Murmur3_32HashFunction.java
new Murmur3_32HashFunction(0, /* supplementaryPlaneFix= */ true); // We can include the non-BMP fix here because Hashing.goodFastHash stresses that the hash is a // temporary-use one. Therefore it shouldn't be persisted. static final HashFunction GOOD_FAST_HASH_32 = new Murmur3_32HashFunction(Hashing.GOOD_FAST_HASH_SEED, /* supplementaryPlaneFix= */ true); private static final int CHUNK_SIZE = 4;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jun 15 20:59:00 GMT 2022 - 11.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
when(backingMap.putIfAbsent(eq(KEY), isA(AtomicInteger.class))).thenReturn(existing); // another map.get() when(backingMap.get(KEY)).thenReturn(existing); // we shouldn't see any more map operations; CHM will now just update the AtomicInteger assertEquals(12, multiset.add(KEY, 3)); assertEquals(15, existing.get()); } public void testRemove_zeroFromSome() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 14.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
when(backingMap.putIfAbsent(eq(KEY), isA(AtomicInteger.class))).thenReturn(existing); // another map.get() when(backingMap.get(KEY)).thenReturn(existing); // we shouldn't see any more map operations; CHM will now just update the AtomicInteger assertEquals(12, multiset.add(KEY, 3)); assertEquals(15, existing.get()); } public void testRemove_zeroFromSome() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 14.2K bytes - Viewed (0) -
internal/grid/muxclient.go
fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } defer func() { // addErrorNonBlockingClose will close the response channel // - maybe async, so we shouldn't do it here. if m.respErr.Load() == nil { xioutil.SafeClose(respHandler) } }() var pingTimer <-chan time.Time if m.deadline == 0 || m.deadline > clientPingInterval {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
docs/en/docs/tutorial/handling-errors.md
It should be this way because if you have a Pydantic `ValidationError` in your *response* or anywhere in your code (not in the client's *request*), it's actually a bug in your code. And while you fix it, your clients/users shouldn't have access to internal information about the error, as that could expose a security vulnerability.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Fri Mar 22 01:42:11 GMT 2024 - 9.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
// If we do have a route selector, use its routes. return localRouteSelector.hasNext() } /** * Return the route from [connection] if it should be retried, even if the connection itself is * unhealthy. The biggest gotcha here is that we shouldn't reuse routes from coalesced * connections. */ private fun retryRoute(connection: RealConnection): Route? { return connection.withLock { when {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
} } throw new AssertionError(); } /** Loads Finalizer.class. */ interface FinalizerLoader { /** * Returns Finalizer.class or null if this loader shouldn't or can't load it. * * @throws SecurityException if we don't have the appropriate privileges */ @CheckForNull Class<?> loadFinalizer(); } /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
} } throw new AssertionError(); } /** Loads Finalizer.class. */ interface FinalizerLoader { /** * Returns Finalizer.class or null if this loader shouldn't or can't load it. * * @throws SecurityException if we don't have the appropriate privileges */ @CheckForNull Class<?> loadFinalizer(); } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 13.1K bytes - Viewed (0)