Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 157 for crossed (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top