when(mockConfig.getResolveOrder()).thenReturn(Arrays.asList(ResolverType.RESOLVER_DNS)); // Only DNS, no broadcast
        when(mockConfig.getNetbiosHostname()).thenReturn("TESTHOST");
        when(mockConfig.getNetbiosScope()).thenReturn(null);
        when(mockConfig.getNetbiosCachePolicy()).thenReturn(30); // Short cache
        when(mockConfig.getWinsServers()).thenReturn(new InetAddress[0]);

        when(config.getSessionTimeout()).thenReturn(30_000);
        when(config.getResponseTimeout()).thenReturn(5_000);
        when(address.getHostAddress()).thenReturn("127.0.0.1");
        when(address.getHostName()).thenReturn("testhost");

        transport = new SmbTransportImpl(context, address, 445, null, 0, false);
    }

    /**
     * Test that pre-auth integrity hash is properly synchronized
     */
    @Test

        SmbTransportImpl mockTransport = Mockito.mock(SmbTransportImpl.class);
        Mockito.when(mockTransport.acquire()).thenReturn(mockTransport);

        SmbSessionImpl session = new SmbSessionImpl(mockContext, "testhost", "testdomain", mockTransport);

        int threadCount = 10;
        int operationsPerThread = 200;
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

            // When
            SmbTransport result = transportPool.getSmbTransport(context, TEST_HOST, DEFAULT_PORT, false, false);

            // Then
            assertNotNull(result);
            assertEquals(transport, result);
            verify(transportPool).getSmbTransport(context, TEST_HOST, DEFAULT_PORT, false, false);
        }

    Helpers.testComparator(comparator, ordered);
  }

  public void testSort() {
    testSort(new long[] {}, new long[] {});
    testSort(new long[] {2}, new long[] {2});
    testSort(new long[] {2, 1, 0}, new long[] {0, 1, 2});
    testSort(new long[] {2, GREATEST, 1, LEAST}, new long[] {LEAST, 1, 2, GREATEST});
  }

  static void testSort(long[] input, long[] expected) {
    input = Arrays.copyOf(input, input.length);

.tags*

# Version file for dockerized build
.dockerized-kube-version-defs

# Web UI
/www/master/node_modules/
/www/master/npm-debug.log
/www/master/shared/config/development.json

# Karma output
/www/test_out

# precommit temporary directories created by ./hack/verify-generated-docs.sh and ./hack/lib/util.sh
/_tmp/
/doc_tmp/

# Test artifacts produced by Prow/kubetest2 jobs
/_artifacts/
/_rundir/

    assertEquals(a, sortedSet.last());
  }

  @CollectionSize.Require(SEVERAL)
  public void testFirst() {
    assertEquals(a, sortedSet.first());
  }

  @CollectionSize.Require(SEVERAL)
  public void testLast() {
    assertEquals(c, sortedSet.last());
  }

 */
public class RdmaIntegrationTest {

    private String testServer;
    private int testPort;
    private CIFSContext testContext;

    @BeforeEach
    public void setUp() throws Exception {
        testServer = System.getProperty("rdma.test.server");
        String portStr = System.getProperty("rdma.test.port", "445");
        testPort = Integer.parseInt(portStr);

        // Create RDMA-enabled context

        final FieldDesc aaa = beanDesc.getFieldDesc("aaa");
        aaa.setStaticFieldValue(String.class);
    }

    /**
     * @throws Exception
     */
    @Test
    public void testList() throws Exception {
        final BeanDesc beanDesc = new BeanDescImpl(MyBean.class);
        final FieldDesc hoge = beanDesc.getFieldDesc("list");

  }

  @CollectionSize.Require(SEVERAL)
  public void testFirst() {
    assertEquals(a.getKey(), navigableMap.firstKey());
  }

  @CollectionSize.Require(SEVERAL)
  public void testLast() {
    assertEquals(c.getKey(), navigableMap.lastKey());
  }

  @CollectionSize.Require(absent = ZERO)
  public void testHeadMapExclusive() {