- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 1,075 for stats (0.02 sec)
-
guava/src/com/google/common/util/concurrent/ClosingFuture.java
} } private void checkAndUpdateState(State oldState, State newState) { checkState( compareAndUpdateState(oldState, newState), "Expected state to be %s, but it was %s", oldState, newState); } private boolean compareAndUpdateState(State oldState, State newState) { return state.compareAndSet(oldState, newState); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
assertThat(manager.servicesByState().keySet()).containsExactly(Service.State.FAILED); } private static void assertState( ServiceManager manager, Service.State state, Service... services) { Collection<Service> managerServices = manager.servicesByState().get(state); for (Service service : services) { assertEquals(service.toString(), state, service.state());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 20:34:52 UTC 2025 - 25.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
@GwtIncompatible final class DirectExecutorService extends AbstractListeningExecutorService { /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */ private final Object lock = new Object(); /* * Conceptually, these two variables describe the executor being in * one of three states: * - Active: shutdown == false * - Shutdown: runningTasks > 0 and shutdown == true
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Apr 12 15:07:59 UTC 2025 - 3.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
// from being reused. Otherwise we're still obligated to transmit the request body to // leave the connection in a consistent state. exchange.noNewExchangesOnConnection() } } } else if (!isUpgradeRequest) { exchange.noRequestBody() } if (requestBody == null || !requestBody.isDuplex()) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 7.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/pager/GroupPager.java
import java.io.Serializable; import java.util.List; import org.codelibs.fess.util.ComponentUtil; /** * GroupPager provides pagination functionality for group management operations in Fess. * This class manages the state and metadata required for paginated display of group lists, * including page navigation, record counts, and search criteria. * */ public class GroupPager implements Serializable {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/ServerMessageBlockTest.java
} } @Nested @DisplayName("Response State Tests") class ResponseStateTests { @BeforeEach void setup() { testBlock = new TestServerMessageBlock(mockConfig); } @Test @DisplayName("Test received state") void testReceivedState() { assertFalse(testBlock.isReceived());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 36.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/DirFileEntryEnumIterator2Test.java
} /** * Reflectively set the 'status' on a SMB2 response to drive control flow. */ private static void setStatus(jcifs.internal.smb2.ServerMessageBlock2Response resp, int status) throws Exception { Field f = jcifs.internal.smb2.ServerMessageBlock2.class.getDeclaredField("status"); f.setAccessible(true); f.setInt(resp, status); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/interval/FessIntervalController.java
/** * FessIntervalController extends DefaultIntervalController to provide * Fess-specific interval control functionality for web crawling operations. * This controller manages delays and timing for various crawling states * including processing delays, queue waiting times, and new URL discovery. */ public class FessIntervalController extends DefaultIntervalController { /** * Default constructor. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// Fail fast on a null. We throw NPE here because the contract of Executor states that it throws // NPE on null listener, so we propagate that contract up into the add method as well. checkNotNull(runnable, "Runnable was null."); checkNotNull(executor, "Executor was null."); // Lock while we check state. We must maintain the lock while adding the new pair so that
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/en/docs/advanced/response-change-status-code.md
# Response - Change Status Code { #response-change-status-code } You probably read before that you can set a default [Response Status Code](../tutorial/response-status-code.md){.internal-link target=_blank}. But in some cases you need to return a different status code than the default. ## Use case { #use-case } For example, imagine that you want to return an HTTP status code of "OK" `200` by default.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 1.5K bytes - Viewed (0)