public static final String CHECKSUM_POLICY_IGNORE = "ignore";

    public static final String DEFAULT_CHECKSUM_POLICY = CHECKSUM_POLICY_FAIL;

    private boolean enabled;

    private String updatePolicy;

    private String checksumPolicy;

    public ArtifactRepositoryPolicy() {
        this(true, null, null);
    }

    public ArtifactRepositoryPolicy(ArtifactRepositoryPolicy policy) {

import org.mockito.Mock;
import org.mockito.MockitoAnnotations;

import jcifs.dcerpc.rpc;

class MsrpcSamrOpenDomainTest {

    @Mock
    private SamrPolicyHandle mockHandle;
    @Mock
    private rpc.sid_t mockSid;
    @Mock
    private SamrDomainHandle mockDomainHandle;

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

    @Test

    private var organizationalUnit: String? = null
    private val altNames = mutableListOf<String>()
    private var serialNumber: BigInteger? = null
    private var keyPair: KeyPair? = null
    private var signedBy: HeldCertificate? = null
    private var maxIntermediateCas = -1
    private var keyAlgorithm: String? = null
    private var keySize: Int = 0

    init {
      ecdsa256()
    }

    /**

     */
    public static class ChannelInfo {
        private final String channelId;
        private final InetAddress localAddress;
        private final InetAddress remoteAddress;
        private final NetworkInterface networkInterface;
        private final SmbTransportImpl transport;
        private final AtomicInteger activeConnections = new AtomicInteger(0);
        private volatile boolean isHealthy = true;

public class DirectoryCacheEntry {
    private final String directoryPath;
    private final Smb2LeaseKey leaseKey;
    private final long createTime;
    private volatile long lastUpdateTime;
    private volatile long lastAccessTime;
    
    // Cached directory contents
    private final ConcurrentHashMap<String, FileInfo> children;
    private final ReadWriteLock lock;
    
    // Cache metadata

    }

    // Helper methods

    private void setupMockConfig(String fesenUrl, String username, String password) {
        setupMockConfig(fesenUrl, username, password, "");
    }

    private void setupMockConfig(String fesenUrl, String username, String password, String certificateAuthorities) {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

      )
    }
  }

  private fun assertData(hex: String) {
    assertData(hex.decodeHex())
  }

  private fun assertData(expected: ByteString) {
    val actual = data.readByteString(Math.min(expected.size.toLong(), data.size))
    assertThat(actual).isEqualTo(expected)
  }

  companion object {
    private fun binaryData(length: Int): ByteString {

package org.apache.maven.artifact.versioning;

/**
 * Describes a restriction in versioning.
 *
 */
public class Restriction {
    private final ArtifactVersion lowerBound;

    private final boolean lowerBoundInclusive;

    private final ArtifactVersion upperBound;

    private final boolean upperBoundInclusive;

    public static final Restriction EVERYTHING = new Restriction(null, false, null, false);

public class AuthenticationRateLimiter implements AutoCloseable {

    private static final Logger log = LoggerFactory.getLogger(AuthenticationRateLimiter.class);

    // Rate limiting configuration
    private final int maxAttemptsPerAccount;
    private final int maxAttemptsPerIp;
    private final int maxGlobalAttemptsPerMinute;
    private final Duration lockoutDuration;
    private final Duration cleanupInterval;

    // Tracking maps

     */
    public static class PoolHealthMetrics {
        private final int activeConnections;
        private final int nonPooledConnections;
        private final int trackedConnections;
        private final int maxPoolSize;
        private final long totalHealthChecks;
        private final long failedHealthChecks;
        private final long connectionsRemoved;
        private final int uniqueEndpoints;