loadBalancer.setStrategy(LoadBalancingStrategy.AFFINITY_BASED);

        Smb2ReadRequest readRequest = mock(Smb2ReadRequest.class);
        when(readRequest.getTreeId()).thenReturn(123); // Set consistent tree ID for affinity

        when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));

        // Multiple calls with same file ID should return same channel

            jcifs.SID[] expected = new jcifs.SID[] { member };
            when(mockResolver.getGroupMemberSids(eq(mockCtx), eq("srv"), any(jcifs.SID.class), eq(512), eq(123))).thenReturn(expected);

            // Act
            jcifs.SID[] res = group.getGroupMemberSids("srv", mockCtx, 123);

            // Assert
            assertArrayEquals(expected, res);

    private static Stream<Arguments> valueProvider() {
        return Stream.of(Arguments.of(0, 0L, 0L, 0L, 0L), // all zeros
                Arguments.of(1, 1L, 1L, 1L, 1L), // ones
                Arguments.of(123, 456L, 789L, 101112L, 131415L), // arbitrary positives
                Arguments.of(Integer.MAX_VALUE, Long.MAX_VALUE, Long.MIN_VALUE, 999_999_999_999L, -1L), // extremes

        CustomTestObject testValue = new CustomTestObject("test", 123);
        OptionalEntity<CustomTestObject> result = OptionalUtil.ofNullable(testValue);

        assertNotNull(result);
        assertTrue(result.isPresent());
        assertEquals(testValue, result.get());
        assertEquals("test", result.get().getName());
        assertEquals(123, result.get().getValue());
    }

        SmbSessionImpl session = mock(SmbSessionImpl.class);
        when(tree.getSession()).thenReturn(session);
        when(session.getSessionKey()).thenReturn(new byte[] { 1, 2, 3 });

        byte[] key = target.getSessionKey();
        assertArrayEquals(new byte[] { 1, 2, 3 }, key);
        verify(tree, times(1)).getSession();
        verify(session, times(1)).getSessionKey();
    }

    @Test

    runs-on: ${{ matrix.platform }}

    services:
      gaussdb:
        image: ${{ matrix.dbversion }}
        env:
          # GaussDB has password limitations
          GS_PASSWORD: Gaussdb@123
          TZ: Asia/Shanghai
        ports:
          - 9950:5432

    steps:
      - name: Set up Go 1.x
        uses: actions/setup-go@v4
        with:
          go-version: ${{ matrix.go }}

"1.1.1 OK"
"1.1.2 OK"
"1.1.3 OK"
"1.1.4 OK"
"1.1.5 OK"
"1.1.6 OK"
"1.1.7 OK"
"1.1.8 OK"
"1.2.1 OK"
"1.2.2 OK"
"1.2.3 OK"
"1.2.4 OK"
"1.2.5 OK"
"1.2.6 OK"
"1.2.7 OK"
"1.2.8 OK"
"10.1.1 OK"
"12.1.1 UNIMPLEMENTED"
"12.1.10 UNIMPLEMENTED"
"12.1.11 UNIMPLEMENTED"
"12.1.12 UNIMPLEMENTED"
"12.1.13 UNIMPLEMENTED"
"12.1.14 UNIMPLEMENTED"
"12.1.15 UNIMPLEMENTED"
"12.1.16 UNIMPLEMENTED"
"12.1.17 UNIMPLEMENTED"

    try {
      iterator.next();
      fail("did not detect end of list");
    } catch (NoSuchElementException expected) {
    }
    iterator.remove();
    assertEquals(asList("1", "2", "3"), list);
    assertFalse(iterator.hasNext());
  }

  public void testPartition_badSize() {
    List<Integer> source = singletonList(1);

      assertEqualsSame(expected, in, anyOf("-").collapseFrom(in, replacement));
      assertEqualsSame(expected, in, anyOf("-#").collapseFrom(in, replacement));
      assertEqualsSame(expected, in, anyOf("-#123").collapseFrom(in, replacement));
    }
  }

  private void doTestCollapseWithNoChange(String inout) {
    assertSame(inout, is('-').collapseFrom(inout, '_'));

      }
    }
    return flip(max);
  }

  /**
   * Returns a string containing the supplied unsigned {@code long} values separated by {@code
   * separator}. For example, {@code join("-", 1, 2, 3)} returns the string {@code "1-2-3"}.
   *
   * @param separator the text that should appear between consecutive values in the resulting string
   *     (but not at the start or end)