@NullMarked
public class TestLogHandler extends Handler {
  private final Object lock = new Object();

  /** We will keep a private list of all logged records */
  @GuardedBy("lock")
  private final List<LogRecord> list = new ArrayList<>();

  /** Adds the most recently logged record to our list. */
  @Override
  public void publish(@Nullable LogRecord record) {
    synchronized (lock) {
      if (record != null) {
        list.add(record);
      }

@ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
public class SmbComSessionSetupAndXTest {

    @Mock
    private CIFSContext mockContext;
    @Mock
    private SmbComNegotiateResponse mockNegotiate;
    @Mock
    private ServerMessageBlock mockAndX;
    @Mock
    private Configuration mockConfig;

    private static byte[] blobCred() {
        return "blobdata".getBytes(StandardCharsets.UTF_8);

    private LeaseManager leaseManager;
    private CIFSContext mockContext;
    private Configuration mockConfig;

    @BeforeEach
    void setUp() {
        mockContext = mock(CIFSContext.class);
        mockConfig = mock(Configuration.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);
        when(mockConfig.getLeaseTimeout()).thenReturn(30000);
        when(mockConfig.getMaxLeases()).thenReturn(1000);

    @Mock
    private jcifs.CIFSContext ctx;

    @Mock
    private SmbSession session;

    @Mock
    private jcifs.DfsReferralData referral;

    @BeforeEach
    void resetMocks() {
        Mockito.reset(transport, ctx, session, referral);
    }

    // Happy path: hasCapability returns based on provided capability codes
    @ParameterizedTest
    @DisplayName("hasCapability returns expected values for various caps")

  private ByteArrayInputStream buffer;

  @SuppressWarnings("DoNotMock")
  @Override
  protected void setUp() throws Exception {
    super.setUp();
    hasher = mock(Hasher.class);
    hashFunction = mock(HashFunction.class);
    buffer = new ByteArrayInputStream(testBytes);

    when(hashFunction.newHasher()).thenReturn(hasher);
  }

  public void testRead_putSingleByte() throws Exception {

	sync.Mutex
}

func (l *logOnceType) logOnceConsoleIf(ctx context.Context, subsystem string, err error, id string, errKind ...any) {
	if err == nil {
		return
	}

	nerr := unwrapErrs(err)
	l.Lock()
	shouldLog := true
	prev, ok := l.IDMap[id]
	if !ok {
		l.IDMap[id] = onceErr{
			Err:   nerr,
			Count: 1,
		}
	} else if prev.Err.Error() == nerr.Error() {
		// if errors are equal do not log.

package lifecycle

import (
	"fmt"
	"time"

	objlock "github.com/minio/minio/internal/bucket/object/lock"
	"github.com/minio/minio/internal/bucket/replication"
)

// Evaluator - evaluates lifecycle policy on objects for the given lifecycle
// configuration, lock retention configuration and replication configuration.
type Evaluator struct {
	policy        Lifecycle
	lockRetention *objlock.Retention

 */
@ExtendWith(MockitoExtension.class)
@DisplayName("DcerpcHandle Test Suite")
class DcerpcHandleTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private DcerpcBinding mockBinding;

    @Mock
    private BufferCache mockBufferCache;

    @Mock
    private DcerpcSecurityProvider mockSecurityProvider;

    // Concrete implementation of DcerpcHandle for testing

class CIFSContextCredentialWrapperTest {

    @Mock
    private AbstractCIFSContext mockDelegate;
    @Mock
    private Credentials mockCredentials;
    @Mock
    private SmbRenewableCredentials mockRenewableCredentials;
    @Mock
    private CredentialsInternal mockRenewedCredentialsInternal;
    @Mock
    private NtlmAuthenticator mockNtlmAuthenticator;
    @Mock

import org.apache.maven.session.scope.internal.SessionScope;
import org.junit.jupiter.api.Test;

import static org.codehaus.plexus.testing.PlexusExtension.getBasedir;
import static org.mockito.Mockito.mock;

/**
 */
@Deprecated
class ArtifactInstallerTest extends AbstractArtifactComponentTestCase {
    @Inject
    private ArtifactInstaller artifactInstaller;

    @Inject
    private SessionScope sessionScope;