continue; // Slot is now non-empty
            }
          }
          collide = false;
        } else if (!wasUncontended) // CAS already known to fail
        wasUncontended = true; // Continue after rehash
        else if (a.cas(v = a.value, fn(v, x))) break;
        else if (n >= NCPU || cells != as) collide = false; // At max size or stale
        else if (!collide) collide = true;

        kuromojiPager.clear();
        assertEquals(0, kuromojiPager.getAllRecordCount());
        assertEquals(0, kuromojiPager.getAllPageCount());
        assertEquals(false, kuromojiPager.isExistPrePage());
        assertEquals(false, kuromojiPager.isExistNextPage());
        assertEquals(25, kuromojiPager.getPageSize());
        assertEquals(1, kuromojiPager.getCurrentPageNumber());
        assertNull(kuromojiPager.id);

        protwordsPager.clear();
        assertEquals(0, protwordsPager.getAllRecordCount());
        assertEquals(0, protwordsPager.getAllPageCount());
        assertEquals(false, protwordsPager.isExistPrePage());
        assertEquals(false, protwordsPager.isExistNextPage());
        assertEquals(25, protwordsPager.getPageSize());
        assertEquals(1, protwordsPager.getCurrentPageNumber());
        assertNull(protwordsPager.id);

        stopwordsPager.clear();
        assertEquals(0, stopwordsPager.getAllRecordCount());
        assertEquals(0, stopwordsPager.getAllPageCount());
        assertEquals(false, stopwordsPager.isExistPrePage());
        assertEquals(false, stopwordsPager.isExistNextPage());
        assertEquals(25, stopwordsPager.getPageSize());
        assertEquals(1, stopwordsPager.getCurrentPageNumber());
        assertNull(stopwordsPager.id);

    val ccEnabled: Boolean,
    val docsTestName: String,
    val docsTestDesc: String,
) {
    CONFIG_CACHE_ENABLED(true, "ConfigCacheDocsTest", "Docs Test With Config Cache Enabled"),
    CONFIG_CACHE_DISABLED(false, "DocsTest", "Docs Test"),
}

class DocsTest(
    model: CIBuildModel,
    stage: Stage,
    os: Os,
    testJava: JvmCategory,
    docsTestType: DocsTestType,

    ExecutorService service = mock(ExecutorService.class);
    when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
        .thenReturn(false)
        .thenReturn(false);
    assertFalse(shutdownAndAwaitTermination(service, 1L, SECONDS));
    verify(service).shutdown();
    verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);

                }
                updateThumbnailField(thumbnailId, StringUtil.EMPTY);
                return false;
            }
            boolean created = false;
            try (ImageInputStream input = ImageIO.createImageInputStream(responseData.getResponseBody())) {
                switch (saveImage(input, outputFile)) {
                case OK:
                    created = true;

     *            authentication). If false and the user has not been authenticated yet
     *            the client will be forced to send an authentication (server sends
     *            HttpServletResponse.SC_UNAUTHORIZED).
     * @return True if the negotiation is complete, otherwise false
     * @throws IOException if an I/O error occurs

        file("/build/resources/yamlRestCompatTest/rest-api-spec/test/" + additionalTest).text.contains("headers") == false

        file("/build/classes/java/yamlRestTest/MockIT.class").exists() //The "standard" runner is used to execute the compat test

        file("/build/resources/yamlRestCompatTest/rest-api-spec/api/" + wrongApi).exists() == false

def authenticate_user(fake_db, username: str, password: str):
    user = get_user(fake_db, username)
    if not user:
        verify_password(password, DUMMY_HASH)
        return False
    if not verify_password(password, user.hashed_password):
        return False
    return user


def create_access_token(data: dict, expires_delta: timedelta | None = None):
    to_encode = data.copy()
    if expires_delta: