final List<OpenSearchUrlQueue> emptyList = new ArrayList<>();

        // Should not throw exception
        urlQueueService.offerAll(sessionId, emptyList);

        // Verify no items were added
        final OpenSearchUrlQueue polled = urlQueueService.poll(sessionId);
        assertNull(polled);
    }

    public void test_offerAll_duplicateUrlsTx() {
        final String sessionId = "offer_session2";

        String[] sitemaps = robotsTxt.getSitemaps();
        assertEquals(1, sitemaps.length);
    }

    public void test_getSitemapsEmpty() {
        // Test getSitemaps when no sitemaps are added
        RobotsTxt robotsTxt = new RobotsTxt();

        String[] sitemaps = robotsTxt.getSitemaps();
        assertNotNull(sitemaps);
        assertEquals(0, sitemaps.length);
    }

    private final ConcurrentHashMap<String, Integer> failureCounts;

    /**
     * Directory change types
     */
    public enum DirectoryChangeType {
        /**
         * File was added to the directory
         */
        FILE_ADDED,
        /**
         * File was removed from the directory
         */
        FILE_REMOVED,
        /**
         * File was modified in the directory

        message.setFlag(0b0001, true);
        assertEquals(0b0001, message.getFlags(), "Flag 0b0001 should be set.");

        message.setFlag(0b0100, true);
        assertEquals(0b0101, message.getFlags(), "Flag 0b0100 should be added to existing flags.");

        // Test clearing a flag
        message.setFlag(0b0001, false);
        assertEquals(0b0100, message.getFlags(), "Flag 0b0001 should be cleared.");

        message.setFlag(0b0100, false);

        »»»

    Translate with (German):

        «««
        ## Ein weiteres Modul mit `APIRouter` { #another-module-with-apirouter }
        »»»

    Do NOT translate with (German) – notice the added period:

        «««
        ## Ein weiteres Modul mit `APIRouter`. { #another-module-with-apirouter }
        »»»

 *  New: Prevent OkHttp from retransmitting a request body by overriding `RequestBody.isOneShot()`.
    This is most useful when writing the request body is destructive.

 *  New: We've added `requestFailed()` and `responseFailed()` methods to `EventListener`. These
    are called instead of `requestBodyEnd()` and `responseBodyEnd()` in some failure situations.

- [ ] (Optional) Add custom dictionaries for search analysis
- [ ] Verify all UI pages display correctly in new language
- [ ] Test error messages and form validation

        byte[] buffer = createBasicNegotiateResponseBuffer();

        // Set security buffer offset close to Integer.MAX_VALUE to test overflow protection
        SMBUtil.writeInt2(32767, buffer, 56); // Large offset (will be added to header start)
        SMBUtil.writeInt2(1000, buffer, 58); // Some length

        SMBProtocolDecodingException exception = assertThrows(SMBProtocolDecodingException.class, () -> {

        // If we see a '.', rewind to the beginning of the previous group and parse as IPv4.
        if (!decodeIpv4Suffix(input, groupOffset, limit, address, b - 2)) return null
        b += 2 // We rewound two bytes and then added four.
        break
      } else {
        return null // Wrong delimiter.
      }
    }

    // Read a group, one to four hex digits.
    var value = 0
    groupOffset = i
    while (i < limit) {

     * First, this method resolves the given root against the project base directory, then normalizes the path.
     * If no source already exists for the same scope, language and normalized directory,
     * these arguments are added as a new {@link SourceRoot} element.
     * Otherwise (i.e., in case of potential conflict), the behavior depends on the {@code ProjectManager}.
     * The default implementation does nothing in the latter case.
     *