@Mock
    private LoginContext loginContext;

    @Mock
    private Subject subject;

    @Mock
    private KerberosKey key1;

    @Mock
    private KerberosKey key2;

    private static final String LOGIN_CONTEXT_NAME = "TestLoginContext";
    private static final int KEY_TYPE_1 = 1;
    private static final int KEY_TYPE_2 = 2;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
    }

     * - Purges job logs older than configured days
     * - Purges user info logs older than configured days
     * - Updates job log status
     *
     * @return a string containing the execution result and any error messages
     */
    public String execute() {
        final CrawlingInfoService crawlingInfoService = ComponentUtil.getComponent(CrawlingInfoService.class);

    boolean androidMorEarlier = Build.VERSION.SDK_INT <= 23;

    OkHttpClient.Builder builder = new OkHttpClient.Builder();

    if (androidMorEarlier) {
      String isgCert =
              "-----BEGIN CERTIFICATE-----\n" +
              "MIIFazCCA1OgAwIBAgIRAIIQz7DSQONZRGPgu2OCiwAwDQYJKoZIhvcNAQELBQAw\n" +
              "TzELMAkGA1UEBhMCVVMxKTAnBgNVBAoTIEludGVybmV0IFNlY3VyaXR5IFJlc2Vh\n" +

    checkFromStringCase(":123", -1, "", 123, true);
    checkFromStringCase("\nOMG\t", 89, "\nOMG\t", 89, false);
  }

  private static void checkFromStringCase(
      String hpString,
      int defaultPort,
      @Nullable String expectHost,
      int expectPort,
      boolean expectHasExplicitPort) {
    HostAndPort hp;
    try {
      hp = HostAndPort.fromString(hpString);

  dependencies:
    date-format "^4.0.14"
    debug "^4.3.4"
    fs-extra "^8.1.0"

string-width@^4.1.0, string-width@^4.2.0:
  version "4.2.3"
  resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
  integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==

public class DockerCloudEssElasticsearchDistributionType implements ElasticsearchDistributionType {

    DockerCloudEssElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "dockerCloudEss";
    }

    @Override
    public boolean isDocker() {
        return true;
    }

public class DockerElasticsearchDistributionType implements ElasticsearchDistributionType {

    DockerElasticsearchDistributionType() {}

    @Override
    public String getName() {
        return "docker";
    }

    @Override
    public boolean isDocker() {
        return true;
    }

    ConsoleHandler().apply {
      level = Level.FINE
      formatter =
        object : SimpleFormatter() {
          override fun format(record: LogRecord) = String.format("[%1\$tF %1\$tT] %2\$s %n", record.millis, record.message)
        }
    }

  fun enable(
    loggerClass: String,
    handler: Handler = logHandler(),
  ): Closeable {
    val logger = Logger.getLogger(loggerClass)
    if (configuredLoggers.add(logger)) {

        @ValueSource(strings = { "192.168.1.1", "10.0.0.255", "0.0.0.0", "255.255.255.255" })
        void shouldReturnTrueForValidIpAddresses(String ip) {
            assertTrue(UniAddress.isDotQuadIP(ip));
        }

        @ParameterizedTest(name = "should return false for invalid IP address or hostname: {0}")
        @ValueSource(strings = { "192.168.1", "hostname", "1.2.3.4.5", "192.168.1.1a", "a.b.c.d" })

package clause_test

import (
	"fmt"
	"testing"

	"gorm.io/gorm/clause"
)

func TestLocking(t *testing.T) {
	results := []struct {
		Clauses []clause.Interface
		Result  string
		Vars    []interface{}
	}{
		{
			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate}},
			"SELECT * FROM `users` FOR UPDATE", nil,
		},
		{