* These flags control what operations can be performed on a memory region.
 */
public enum RdmaAccess {
    /**
     * Local read access to the memory region
     */
    LOCAL_READ,

    /**
     * Local write access to the memory region
     */
    LOCAL_WRITE,

    /**
     * Remote read access to the memory region
     */
    REMOTE_READ,

    /**

     * @return {@link Locale}
     */
    public static Locale getLocale(final String localeStr) {
        // TODO replace with Fess
        Locale locale = LocaleUtil.getDefault();
        if (localeStr != null) {
            final int index = localeStr.indexOf('_');
            if (index < 0) {
                locale = new Locale(localeStr);
            } else {
                final String language = localeStr.substring(0, index);

     * Processes collection definitions and tracks the element hierarchy.
     *
     * @param uri the namespace URI, or empty string if none
     * @param localName the local name without prefix, or empty string if namespace processing is not performed
     * @param qName the qualified name with prefix, or empty string if qualified names are not available

    }

    @Test
    public void testCreateConnection() throws Exception {
        InetSocketAddress remote = new InetSocketAddress("localhost", 445);
        InetSocketAddress local = null;

        RdmaConnection connection = provider.createConnection(remote, local);
        assertNotNull(connection, "Connection should not be null");
        assertEquals(remote, connection.getRemoteAddress(), "Remote address should match");
    }

    @Test

import java.util.Date;
import java.util.Locale;
import java.util.TimeZone;

import org.codelibs.core.misc.LocaleUtil;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

/**
 * @author higa
 */
public class TimestampConversionUtilTest {

    @Before
    public void setUp() throws Exception {
        LocaleUtil.setDefault(() -> Locale.JAPANESE);
    }

    @After

    /**
     * Get transport connection, with local binding
     *
     * @param tc
     *            context to use
     * @param address the server address
     * @param port the port number
     * @param localAddr the local address to bind to
     * @param localPort the local port to bind to
     * @param hostName the server host name
     * @param exclusive

     *
     * @param remote remote socket address
     * @param local local socket address, may be null for auto-binding
     * @return new RDMA connection instance
     * @throws IOException if connection creation fails
     */
    RdmaConnection createConnection(InetSocketAddress remote, InetSocketAddress local) throws IOException;

    /**
     * Connect to a remote RDMA endpoint
     *

                    messages.addErrorsFailedToStartJob(GLOBAL, entity.getName());
                });
            }
            try {
                entity.start();
            } catch (final Exception e) {
                throwValidationErrorApi(messages -> {
                    messages.addErrorsFailedToStartJob(GLOBAL, entity.getName());
                });
            }
        }).orElse(() -> {

    /**
     * Create new RDMA connection
     *
     * @param remote remote socket address
     * @param local local socket address, may be null
     */
    public RdmaConnection(InetSocketAddress remote, InetSocketAddress local) {
        this.remoteAddress = remote;
        this.localAddress = local;
        this.sendCredits = new AtomicInteger(0);

    * This is used in the negotation of local authentication.
    */
    int NTLMSSP_NEGOTIATE_OEM_DOMAIN_SUPPLIED = 0x00001000;

    /**
    * Indicates whether the OEM-formatted workstation name is supplied
    * in the Type-1 message.  This is used in the negotiation of local
    * authentication.
    */
    int NTLMSSP_NEGOTIATE_OEM_WORKSTATION_SUPPLIED = 0x00002000;