- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 157 for crossed (0.05 sec)
-
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* ordering information is updated. This is used to avoid lock contention by recording a memento * of reads and delaying a lock acquisition until the threshold is crossed or a mutation occurs. * * <p>This must be a (2^n)-1 as it is used as a mask. */ static final int DRAIN_THRESHOLD = 0x3F; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 90K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
queue.scheduleAndDecide(task, delayNanos, recurrence = true) } if (queue.futureTasks.isNotEmpty()) { readyQueues.add(queue) // If the task crashed, start another thread to run the next task. if (!completedNormally) { startAnotherThread() } } } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/RangeTest.java
assertTrue(Range.closed(5, 6).isConnected(Range.closed(3, 5))); assertTrue(Range.closed(3, 5).isConnected(Range.openClosed(5, 5))); assertTrue(Range.open(3, 5).isConnected(Range.closed(5, 6))); assertTrue(Range.closed(3, 7).isConnected(Range.open(6, 8))); assertTrue(Range.open(3, 7).isConnected(Range.closed(5, 6))); assertFalse(Range.closed(3, 5).isConnected(Range.closed(7, 8)));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 24.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/GeneralRangeTest.java
assertEquals( GeneralRange.range(ORDERING, 3, CLOSED, 4, OPEN), range.intersect(GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED))); } public void testIntersectOverlappingRange() { GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED); assertEquals( GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED),
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ContiguousSetTest.java
assertFalse(set.containsAll((Collection<?>) ImmutableSet.of("blah"))); } public void testRange() { assertEquals(Range.closed(1, 3), ContiguousSet.create(Range.closed(1, 3), integers()).range()); assertEquals(Range.closed(1, 3), ContiguousSet.closed(1, 3).range()); assertEquals(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} else { openClientSockets.add(socket) serveConnection(nextConnectionIndex++, socket, peek) } } } public override fun close() { if (closed) return closed = true if (!started) return // Nothing to shut down. val serverSocket = this.serverSocket ?: return // If this is null, start() must have failed. // Cause acceptConnections() to break out.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
} @Test @DisplayName("Test initial state is CLOSED") void testInitialState() { assertEquals(SimpleCircuitBreaker.State.CLOSED, circuitBreaker.getState()); assertTrue(circuitBreaker.allowsRequests()); } @Test @DisplayName("Test successful calls in CLOSED state") void testSuccessfulCalls() throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
) : ForwardingSink(delegate) { private var completed = false private var bytesReceived = 0L private var closed = false @Throws(IOException::class) override fun write( source: Buffer, byteCount: Long, ) { check(!closed) { "closed" } if (contentLength != -1L && bytesReceived + byteCount > contentLength) { throw ProtocolException(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
server.processNextFrame() // Not closed until close reply is received. assertThat(client.closed).isFalse() server.sink.write("0a00".decodeHex()).emit() // Invalid non-final ping frame. client.processNextFrame() // Detects error, disconnects immediately since close already sent. client.webSocket!!.finishReader() taskFaker.runTasks() assertThat(client.closed).isTrue() client.listener.assertFailure(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.7K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
log.info("[{}] Circuit breaker closing after {} successful attempts", name, successes); transitionTo(State.CLOSED); } } else if (currentState == State.CLOSED) { // Reset failure count on success in closed state failureCount.set(0); } // Notify listeners for (CircuitBreakerListener listener : listeners) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0)