SimpleCircuitBreaker breaker = new SimpleCircuitBreaker("concurrent", 5, 3, 100);
        AtomicInteger successCount = new AtomicInteger(0);
        AtomicInteger failureCount = new AtomicInteger(0);

        // Create multiple threads
        Thread[] threads = new Thread[10];
        for (int i = 0; i < threads.length; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {

        if (smbUrl == null || smbUrl.isEmpty()) {
            throw new SmbException("SMB URL cannot be null or empty");
        }

        // Check URL format
        if (!smbUrl.toLowerCase().startsWith("smb://")) {
            throw new SmbException("Invalid SMB URL format");
        }

        try {
            URL url = new URL(null, smbUrl, new jcifs.smb.Handler());

            // Validate host

              result.put(key, value);
              // add extra entries
              result.put(value, key);
            }
            return result;
          }
        };
    LoadingCache<Object, Object> cache = CacheBuilder.newBuilder().build(loader);

    Object[] lookupKeys = new Object[] {new Object(), new Object(), new Object()};
    Map<Object, Object> result = cache.getAll(asList(lookupKeys));

        List<FileNotifyInformation> info = new ArrayList<>();
        NotifyResponse resp = mock(NotifyResponse.class);
        when(resp.isReceived()).thenReturn(true);
        when(resp.getErrorCode()).thenReturn(0);
        when(resp.getNotifyInformation()).thenReturn(info);
        setupSmb2(resp, new byte[16]);
        SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0x1234, true);

    assertSuppressed(
        new Suppression(c2, tryException, c2Exception),
        new Suppression(c1, tryException, c1Exception));
  }

  public void testErrors() throws IOException {
    Closer closer = new Closer(suppressor);

    Error c1Exception = new Error();
    Error c2Exception = new Error();
    Error c3Exception = new Error();

    void testType1MessageFromBytes() throws IOException {
        // Given - Create a Type 1 message and convert to bytes
        Type1Message original = new Type1Message(mockContext);
        byte[] messageBytes = original.toByteArray();

        // When
        Type1Message parsed = new Type1Message(messageBytes);

        // Then
        // Note: getType() method does not exist in Type1Message

        SmbClient client = new SmbClient();
        client.setResolveSids(false);
        StandardCrawlerContainer container =
                new StandardCrawlerContainer().singleton("smbClient", client).singleton("mimeTypeHelper", MimeTypeHelperImpl.class);

        Map<String, Object> params = new HashMap<>();
        SmbAuthentication auth = new SmbAuthentication();
        auth.setUsername("testuser");

    private ModelResolver newModelResolver() throws Exception {
        final File localRepo = new File(this.getLocalRepository().getBasedir());
        final DefaultRepositorySystemSession repoSession = new DefaultRepositorySystemSession(h -> false);
        repoSession.setLocalRepositoryManager(new LegacyLocalRepositoryManager(localRepo));

        return new ProjectModelResolver(
                repoSession,
                null,

    void setUp() throws UnknownHostException {
        failover = new ChannelFailover(mockChannelManager);

        InetAddress addr = InetAddress.getByName("192.168.1.100");
        NetworkInterfaceInfo localInterface = new NetworkInterfaceInfo(addr, 1000);
        NetworkInterfaceInfo remoteInterface = new NetworkInterfaceInfo(addr, 1000);

        failedChannel = new ChannelInfo("failed-channel", mockTransport, localInterface, remoteInterface);

    }

    protected FessJsonResourceProvider createJsonResourceProvider() {
        return new FessJsonResourceProvider();
    }

    protected FessCurtainBeforeHook createCurtainBeforeHook() {
        return new FessCurtainBeforeHook();
    }

    protected FessCurtainFinallyHook createCurtainFinallyHook() {
        return new FessCurtainFinallyHook();
    }