import org.dbflute.dbway.DBDef;
import org.dbflute.util.DfTypeUtil;

/**
 * The DBM of FailureUrl.
 *
 * @author ESFlute (using FreeGen)
 */
public class FailureUrlDbm extends AbstractDBMeta {

    protected static final Class<?> suppressUnusedImportLocalDateTime = LocalDateTime.class;

    // ===================================================================================

import org.dbflute.dbway.DBDef;
import org.dbflute.util.DfTypeUtil;

/**
 * The DBM of JobLog.
 *
 * @author ESFlute (using FreeGen)
 */
public class JobLogDbm extends AbstractDBMeta {

    protected static final Class<?> suppressUnusedImportLocalDateTime = LocalDateTime.class;

    // ===================================================================================

    TestSuite suite = new TestSuite(AbstractFutureFallbackAtomicHelperTest.class.getName());
    for (Method method : AbstractFutureTest.class.getDeclaredMethods()) {
      if (Modifier.isPublic(method.getModifiers()) && method.getName().startsWith("test")) {
        suite.addTest(
            TestSuite.createTest(AbstractFutureFallbackAtomicHelperTest.class, method.getName()));
      }
    }
    return suite;
  }

  @Override

    @Resource
    private SystemHelper systemHelper;

    @Resource
    private JobHelper jobHelper;

    /** The job class to be executed by this scheduler */
    protected Class<? extends LaJob> jobClass = ScriptExecutorJob.class;

    /** The timestamp when the scheduler was last updated */
    protected long schedulerTime;

    @Override
    public void schedule(final LaCron cron) {

import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.util.SMBUtil;

@ExtendWith(MockitoExtension.class)
class Smb2LogoffResponseTest {

    // Helper to create an instance with a mocked Configuration
    private Smb2LogoffResponse newResponse() {
        Configuration cfg = Mockito.mock(Configuration.class);
        return new Smb2LogoffResponse(cfg);
    }

    @Test

            return redirect(ErrorAction.class);
        }
        final String url = DocumentUtil.getValue(doc, fessConfig.getIndexFieldUrl(), String.class);
        if (url == null) {
            saveError(messages -> messages.addErrorsDocumentNotFound(GLOBAL, form.docId));
            return redirect(ErrorAction.class);
        }

        if (fessConfig.isSearchLog()) {

        // Any PACDecodingException is acceptable for this test
        assertNotNull(e.getMessage());
    }

    @Test
    void testTooSmallPac() {
        // Test that PAC smaller than 8 bytes is rejected
        byte[] smallData = new byte[4];

        PACDecodingException e = assertThrows(PACDecodingException.class, () -> new Pac(smallData, keys));

        // Use a fresh context to avoid affecting previous tests
        CIFSContext ctx2 = mock(CIFSContext.class);
        Configuration config2 = mock(Configuration.class);
        Credentials creds2 = mock(Credentials.class);
        NameServiceClient nsc2 = mock(NameServiceClient.class);
        when(ctx2.getConfig()).thenReturn(config2);
        when(ctx2.getCredentials()).thenReturn(creds2);

internal class InsecureAndroidTrustManager(
  private val delegate: X509TrustManager,
  private val insecureHosts: List<String>,
) : X509TrustManager {
  private val checkServerTrustedMethod: Method? =
    try {
      delegate::class.java.getMethod(
        "checkServerTrusted",
        Array<X509Certificate>::class.java,
        String::class.java,
        String::class.java,
      )

 * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function)
 * Futures.catching} family of methods. Those versions have slightly different signatures.
 */
abstract class GwtFuturesCatchingSpecialization {
  /*
   * In the GWT versions of the methods (below), every exceptionType parameter is required to be
   * Class<Throwable>. To handle only certain kinds of exceptions under GWT, you'll need to write