Arguments.of(WinError.ERROR_BAD_PIPE, "The pipe state is invalid."),
                Arguments.of(WinError.ERROR_PIPE_BUSY, "All pipe instances are busy."),
                Arguments.of(WinError.ERROR_NO_DATA, "The pipe is being closed."),
                Arguments.of(WinError.ERROR_PIPE_NOT_CONNECTED, "No process is on the other end of the pipe."),

            "No mapping between account names and security IDs was done.", "The security ID structure is invalid.",
            "All pipe instances are busy.", "All pipe instances are busy.", "The pipe state is invalid.", "All pipe instances are busy.",
            "No process is on the other end of the pipe.", "The pipe is being closed.",

import org.jspecify.annotations.Nullable;

@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public final class InterruptibleTaskTest extends TestCase {

  // Regression test for a deadlock where a task could be stuck busy waiting for the task to
  // transition to DONE
  public void testInterruptThrows() throws Exception {
    CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);

import org.jspecify.annotations.Nullable;

@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public final class InterruptibleTaskTest extends TestCase {

  // Regression test for a deadlock where a task could be stuck busy waiting for the task to
  // transition to DONE
  public void testInterruptThrows() throws Exception {
    CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);

import jcifs.Configuration;

/**
 * Response for SMB1 TRANS_WAIT_NAMED_PIPE transaction.
 *
 * This response is received after waiting for a named pipe to become available
 * for connection when the pipe server was busy.
 */
public class TransWaitNamedPipeResponse extends SmbComTransactionResponse {

    /**
     * Constructs a response for a wait named pipe request.
     *
     * @param config the configuration to use
     */

 */
public enum LoadBalancingStrategy {
    /**
     * Round-robin selection through available channels
     */
    ROUND_ROBIN,

    /**
     * Select the least busy channel based on pending operations
     */
    LEAST_LOADED,

    /**
     * Weighted random selection based on channel scores
     */
    WEIGHTED_RANDOM,

    /**

				// - Do not consume disks which are not reachable
				//   unformatted or simply not accessible for some reason.
				//
				// - Do not consume disks which are being healed
				//
				// - Future: skip busy disks
				return
			}

			mu.Lock()
			newDisks = append(newDisks, disks[i])
			mu.Unlock()
		}()
	}
	wg.Wait()
	return newDisks
}

    @Test
    @DisplayName("Should track elapsed time")
    void testElapsedTime() throws InterruptedException {
        // Given
        exception = new SmbOperationException(SmbOperationException.ErrorCode.BUSY, "Server busy");

        // When
        Thread.sleep(100);

        // Then
        assertTrue(exception.getElapsedTime() >= 100);
        assertTrue(exception.getElapsedTime() < 200);
    }

    @Test

import jcifs.Configuration;

/**
 * SMB1 Transaction Wait Named Pipe request implementation.
 * Implements the TRANS_WAIT_NAMED_PIPE transaction to wait for a named pipe
 * to become available when the pipe server is busy or temporarily unavailable.
 *
 * @author mbechler
 */
public class TransWaitNamedPipe extends SmbComTransaction {

    /**
     * Constructs a wait request for a named pipe.
     *

                true), RESOURCE_LOCKED("Resource is locked", ErrorCategory.RESOURCE, true),

        // Transient errors
        BUSY("Server busy", ErrorCategory.TRANSIENT, true), TRY_AGAIN("Try again later", ErrorCategory.TRANSIENT,
                true), SERVICE_UNAVAILABLE("Service temporarily unavailable", ErrorCategory.TRANSIENT, true),

        // Generic errors