- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 22 for Buffer (0.07 seconds)
-
src/test/java/org/codelibs/fess/timer/LogNotificationTargetTest.java
// Add events to buffer ComponentUtil.getLogNotificationHelper() .offer(new LogNotificationEvent(System.currentTimeMillis(), "ERROR", "org.test", "msg1", null)); ComponentUtil.getLogNotificationHelper() .offer(new LogNotificationEvent(System.currentTimeMillis(), "WARN", "org.test", "msg2", null)); // expired() will drain buffer then fail on OpenSearch (not available) but should not throwCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 4.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java
logNotificationTarget.flush(); } } /** * Offers an event to the buffer. If the buffer exceeds the maximum size, the oldest event is dropped. * * @param event the log notification event to add */ public void offer(final LogNotificationEvent event) { int maxBufferSize; try {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 5.3K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
int initialBufferSize = min(BUFFER_SIZE, max(128, Integer.highestOneBit(totalLen) * 2)); // Starting with an 8k buffer, double the size of each successive buffer. Smaller buffers // quadruple in size until they reach 8k, to minimize the number of small reads for longer // streams. Buffers are retained in a deque so that there's no copying between buffers while
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
.teamcity/scripts/CheckBadMerge.java
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Mar 30 16:25:09 GMT 2026 - 9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/LogNotificationHelperTest.java
LogNotificationHelper helper = new LogNotificationHelper(); // Default buffer size is 1000; offer more than that for (int i = 0; i < 1100; i++) { helper.offer(new LogNotificationEvent(i, "ERROR", "org.test", "msg" + i, null)); } List<LogNotificationEvent> events = helper.drainAll(); // Should be capped at buffer size (1000) assertTrue(events.size() <= 1000);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 6.3K bytes - Click Count (0) -
RELEASE.md
([CVE-2021-37649](https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-37649)) * Fixes a segfault and a heap buffer overflow in `{Experimental,}DatasetToTFRecord` ([CVE-2021-37650](https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-37650)) * Fixes a heap buffer overflow in `FractionalAvgPoolGrad` ([CVE-2021-37651](https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-37651))Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Mon Mar 30 18:31:38 GMT 2026 - 746.5K bytes - Click Count (3) -
src/main/java/org/codelibs/fess/util/LogNotificationAppender.java
import org.codelibs.fess.helper.LogNotificationHelper; import org.codelibs.fess.helper.LogNotificationHelper.LogNotificationEvent; /** * Custom Log4j2 Appender that captures log events into a buffer for notification purposes. */ @Plugin(name = "LogNotificationAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = true) public class LogNotificationAppender extends AbstractAppender {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 6K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* the queue the shortest time. New elements are inserted at the tail of the queue, and the queue * retrieval operations obtain elements at the head of the queue. * * <p>This is a classic "bounded buffer", in which a fixed-sized array holds elements * inserted by producers and extracted by consumers. Once created, the capacity cannot be increased.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* the queue the shortest time. New elements are inserted at the tail of the queue, and the queue * retrieval operations obtain elements at the head of the queue. * * <p>This is a classic "bounded buffer", in which a fixed-sized array holds elements * inserted by producers and extracted by consumers. Once created, the capacity cannot be increased.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
src/main/resources/fess_config.properties
log.notification.max.message.length=200 # Maximum number of events to fetch from search engine per notification job. log.notification.search.size=1000 # Maximum number of events to buffer in memory. log.notification.buffer.size=1000 # Interval (seconds) for the notification job cycle, used in notification messages.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 59.3K bytes - Click Count (0)