loadBalancer.setStrategy(strategy);
            assertEquals(strategy, loadBalancer.getStrategy());
        }

        // Test channel selection with mock request when no channels available
        ServerMessageBlock2Request mockRequest = mock(ServerMessageBlock2Request.class);
        when(mockRequest.getTreeId()).thenReturn(123);

        // Should throw NoAvailableChannelException when no healthy channels

    g = Github(settings.github_token.get_secret_value())
    repo = g.get_repo(settings.github_repository)
    if not settings.github_event_path.is_file():
        raise RuntimeError(
            f"No github event file available at: {settings.github_event_path}"
        )
    contents = settings.github_event_path.read_text()
    github_event = PartialGitHubEvent.model_validate_json(contents)
    logging.info(f"Using GitHub event: {github_event}")

    @BeforeEach
    public void setUp() {
        provider = new TcpRdmaProvider();
    }

    @Test
    public void testIsAvailable() {
        assertTrue(provider.isAvailable(), "TCP provider should always be available");
    }

    @Test
    public void testGetSupportedCapabilities() {
        Set<RdmaCapability> capabilities = provider.getSupportedCapabilities();

        if (len > 0xFFFF) {
            throw new IOException("write too large: " + len);
        }
        if (off < 4) {
            throw new IOException("NetBIOS socket output buffer requires 4 bytes available before off");
        }

        off -= 4;

        b[off + 0] = (byte) SessionServicePacket.SESSION_MESSAGE;
        b[off + 1] = (byte) 0x00;
        b[off + 2] = (byte) (len >> 8 & 0xFF);

            List<RemoteRepository> remoteRepositories) {
        super("No plugin found for prefix '" + prefix + "' in the current project and in the plugin groups "
                + pluginGroups + " available from the repositories " + format(localRepository, remoteRepositories));
    }

    private static String format(LocalRepository localRepository, List<RemoteRepository> remoteRepositories) {

import static java.util.Objects.requireNonNull;

/**
 * Early CLI {@link Logger} that simply accumulates log entries until some point a real logger can emit them. This
 * logger is created at start, and it exists while no logging is available yet.
 */
public class AccumulatingLogger implements Logger {
    private final AtomicReference<List<Entry>> entries = new AtomicReference<>(new CopyOnWriteArrayList<>());

    @Override

 * of phases that can be executed during a build.
 * <p>
 * Implementations of this interface will be discovered through the Java ServiceLoader mechanism
 * and their provided lifecycles will be available throughout the Maven build process.
 * <p>
 * Example usage:
 * <pre>
 * public class CustomLifecycleProvider implements LifecycleProvider {
 *     public Collection&lt;Lifecycle&gt; provides() {

 * in different contexts, such as compilation, testing, or runtime.
 * <p>
 * Implementations of this interface will be discovered through the Java ServiceLoader mechanism
 * and their provided path scopes will be available throughout the Maven build process.
 * <p>
 * Example usage:
 * <pre>
 * public class CustomPathScopeProvider implements PathScopeProvider {
 *     public Collection&lt;PathScope&gt; provides() {

 * are handled, including their default extension, classifier, and language.
 * <p>
 * Implementations of this interface will be discovered through the Java ServiceLoader mechanism
 * and their provided types will be available throughout the Maven build process.
 * <p>
 * Example usage:
 * <pre>
 * public class CustomTypeProvider implements TypeProvider {
 *     public Collection&lt;Type&gt; provides() {
 *         return Arrays.asList(

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package disk

import (
	"errors"
	"fmt"

	"golang.org/x/sys/unix"
)

// GetInfo returns total and free bytes available in a directory, e.g. `/`.
func GetInfo(path string, _ bool) (info Info, err error) {
	s := unix.Statvfs_t{}
	if err = unix.Statvfs(path, &s); err != nil {
		return Info{}, err
	}