- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 224 for Consume (0.11 sec)
-
src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java
assertEquals(2, sis.read()); // Read second message assertEquals(3, sis.read()); assertEquals(4, sis.read()); assertEquals(5, sis.read()); // After all data is consumed, next read throws IOException assertThrows(IOException.class, () -> sis.read()); } @Test @DisplayName("EOF handling when stream ends mid-header")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
* * @param success A callback for successful indexing. * @param error A callback for indexing errors. */ public void indexFromDocuments(final Consumer<Boolean> success, final Consumer<Throwable> error) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); final long interval = fessConfig.getSuggestUpdateRequestIntervalAsInteger().longValue();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 22.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/searchlist/AdminSearchlistAction.java
/** * Validates document fields according to index field requirements. * * @param doc the document to validate * @param throwError consumer to handle validation errors */ public static void validateFields(final Map<String, Object> doc, final Consumer<VaMessenger<FessMessages>> throwError) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); try {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 23.1K bytes - Viewed (1) -
docs/tuning/tuned.conf
vm.swappiness=0 vm.vfs_cache_pressure=50 # Start writeback at 3% memory vm.dirty_background_ratio=3 # Force writeback at 10% memory vm.dirty_ratio=10 # Quite a few memory map # areas may be consumed vm.max_map_count=524288 # Default is 500000 = 0.5ms kernel.sched_migration_cost_ns=5000000 # stalled hdd io threads kernel.hung_task_timeout_secs=85 # network tuning for bigger throughput
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 23:31:18 UTC 2024 - 1.9K bytes - Viewed (0) -
src/test/java/jcifs/DfsReferralDataTest.java
String result = mockReferralData.getShare(); // Then assertEquals(share, result); verify(mockReferralData).getShare(); } @Test @DisplayName("Should get path consumed") void testGetPathConsumed() { // Given int pathConsumed = 10; when(mockReferralData.getPathConsumed()).thenReturn(pathConsumed); // When
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableSet.java
return CollectSpliterators.indexed(size(), SPLITERATOR_CHARACTERISTICS, this::get); } @Override public void forEach(Consumer<? super E> consumer) { checkNotNull(consumer); int n = size(); for (int i = 0; i < n; i++) { consumer.accept(get(i)); } } @Override int copyIntoArray(@Nullable Object[] dst, int offset) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 35.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PurgeThumbnailJob.java
/** * Job for purging expired thumbnail files from the system. * This job removes thumbnail files that have exceeded their configured expiration time * to prevent disk space from being consumed by old thumbnails. */ public class PurgeThumbnailJob { /** Logger instance for this class */ private static final Logger logger = LogManager.getLogger(PurgeThumbnailJob.class); /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/DfsReferral.java
* This class extends SmbException to provide DFS referral information when a DFS path is encountered. */ public class DfsReferral extends SmbException { /** Number of characters consumed from the path */ public int pathConsumed; /** Time to live for this referral in seconds */ public long ttl; /** Target server for this referral */ public String server; // Server
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* {@code A -> B}. * * @since 9.0 (in 1.0 as {@code com.google.common.base.Service.State}) */ enum State { /** A service in this state is inactive. It does minimal work and consumes minimal resources. */ NEW, /** A service in this state is transitioning to {@link #RUNNING}. */ STARTING, /** A service in this state is operational. */ RUNNING,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Cut.java
return false; } // Prevent "missing hashCode" warning by explicitly forcing subclasses implement it @Override public abstract int hashCode(); /* * The implementation neither produces nor consumes any non-null instance of type C, so * casting the type parameter is safe. */ @SuppressWarnings("unchecked") static <C extends Comparable> Cut<C> belowAll() { return (Cut<C>) BelowAll.INSTANCE; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 12.4K bytes - Viewed (0)