}

  private static class TestCallable implements Callable<String> {
    @Override
    public String call() {
      return "foo";
    }
  }

  /** Simple same thread listening executor service that doesn't handle shutdown. */
  private static class TestListeningExecutorService extends AbstractListeningExecutorService {

    @Override
    public void execute(Runnable runnable) {

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs;

import java.util.List;
import java.util.concurrent.Callable;

/**
 * Handle for receiving change notifications from an SMB server
 *
 *
 * @author mbechler
 *
 */
public interface SmbWatchHandle extends AutoCloseable, Callable<List<FileNotifyInformation>> {

    /**

public interface Mojo {
    /**
     * Executes the behavior defined by this {@code Mojo}. This method is invoked
     * during the Maven build lifecycle to perform the Mojo's designated task.
     *
     * <p>Implementations should handle any task-specific logic and may communicate
     * errors by throwing an {@link Exception}. Error conditions should provide
     * sufficient detail to aid troubleshooting.</p>
     *

            // Some soak tests produce OOM exceptions
            // There are also random worker crashes for some tests.
            // We have test-retry to handle the crash in tests
            javaCrash = false
        }
    })

private fun determineFlakyTestStrategy(stage: Stage): String {

        assertTrue(rateLimiter.checkAttempt("user7", ip), "Should be allowed after manual unblock");
    }

    @Test
    public void testNullUsername() throws Exception {
        // Null username should be handled gracefully
        assertTrue(rateLimiter.checkAttempt(null, "192.168.1.8"), "Null username should be allowed");

        // Should not affect IP limiting
        rateLimiter.recordFailure(null, "192.168.1.8");

   *
   * <p>This method is similar to {@link java.util.concurrent.CompletableFuture#exceptionally}. It
   * can also serve some of the use cases of {@link java.util.concurrent.CompletableFuture#handle}
   * and {@link java.util.concurrent.CompletableFuture#handleAsync} when used along with {@link
   * #transform}.
   *
   * @param exceptionType the exception type that triggers use of {@code fallback}. The exception

        assertTrue(ex.getMessage().contains("refresh failed"));
    }

    @ParameterizedTest
    @MethodSource("domains")
    @DisplayName("getUserDomain handles null and empty")
    void getUserDomain_edges(String domain) {
        TestCredentials creds = new TestCredentials(domain, false, false, new Subject(), false);
        assertEquals(domain, creds.getUserDomain());
    }

    // Test MappingUpdater close method with error in writer
    public void test_mappingUpdater_closeWithError() throws Exception {
        writeTestFile("a,b => c\n");

        // This test verifies that close() handles errors gracefully
        CharMappingItem newItem = new CharMappingItem(0, new String[] { "x", "y" }, "z");

        // Insert will trigger MappingUpdater which will be closed automatically

import jcifs.internal.TreeConnectResponse;
import jcifs.internal.smb1.AndXServerMessageBlock;
import jcifs.internal.smb1.ServerMessageBlock;

/**
 * SMB1 Tree Connect AndX response implementation.
 * Handles server responses to tree connect requests in SMB1 protocol, providing
 * information about the connected share including service type and DFS capabilities.
 *
 * @author mbechler
 */

                request.addArtifact(pomArtifact);
            } else if (metadata instanceof SnapshotArtifactRepositoryMetadata
                    || metadata instanceof ArtifactRepositoryMetadata) {
                // eaten, handled by repo system
            } else {
                request.addMetadata(new MetadataBridge(metadata));
            }
        }

        try {
            repoSystem.install(session, request);