*
     * @param queryContext the query context to modify
     * @param searchRequestType the type of search request to determine if virtual host filtering should be applied
     */
    protected void buildVirtualHostQuery(final QueryContext queryContext, final SearchRequestType searchRequestType) {
        switch (searchRequestType) {
        case ADMIN_SEARCH:
            // nothing to do
            break;

    void connectLogon_withNull_isInvoked() throws Exception {
        // Act
        tree.connectLogon(null);

        // Assert - even null should be passed through to implementation
        verify(tree).connectLogon(null);
    }

    @Test
    @DisplayName("connectLogon propagates SmbException from implementation")
    void connectLogon_throws_propagates() throws Exception {

  @ListFeature.Require(SUPPORTS_SET)
  @CollectionSize.Require(absent = ZERO)
  public void testSet() {
    doTestSet(e3());
  }

  @CollectionSize.Require(absent = ZERO)
  @CollectionFeature.Require(ALLOWS_NULL_VALUES)
  @ListFeature.Require(SUPPORTS_SET)
  public void testSet_null() {
    doTestSet(null);
  }

  @CollectionSize.Require(absent = ZERO)

  @CollectionSize.Require(absent = ZERO)
  @MapFeature.Require(SUPPORTS_REMOVE)
  public void testPropagatesRemoveLastElementToMultimap() {
    Collection<V> result = multimap().asMap().get(k0());
    assertTrue(result.remove(v0()));
    assertGet(k0());
  }

  @CollectionSize.Require(absent = ZERO)
  @MapFeature.Require(SUPPORTS_REMOVE)
  public void testPropagatesClearToMultimap() {
    Collection<V> result = multimap().asMap().get(k0());

  public static class StringSubscriber {

    @Subscribe
    public void handle(String s) {}
  }

  public static class IntegerSubscriber {

    @Subscribe
    public void handle(Integer i) {}
  }

  public static class ObjectSubscriber {

    @Subscribe
    public void handle(Object o) {}
  }

  public void testFlattenHierarchy() {
    assertEquals(
        ImmutableSet.of(

  @SuppressWarnings("DoNotMock")
  @Override
  protected void setUp() throws Exception {
    super.setUp();
    hasher = mock(Hasher.class);
    hashFunction = mock(HashFunction.class);
    buffer = new ByteArrayInputStream(testBytes);

    when(hashFunction.newHasher()).thenReturn(hasher);
  }

  public void testRead_putSingleByte() throws Exception {

    @DisplayName("Test getAttributes returns 0")
    void testGetAttributes() {
        assertEquals(0, fileStandardInfo.getAttributes());
    }

    @Test
    @DisplayName("Test getCreateTime returns 0")
    void testGetCreateTime() {
        assertEquals(0L, fileStandardInfo.getCreateTime());
    }

    @Test
    @DisplayName("Test getLastWriteTime returns 0")
    void testGetLastWriteTime() {

        public void columnId() {
            doColumn("_id");
        }

        public void columnCreatedTime() {
            doColumn("createdTime");
        }

        public void columnExpiredTime() {
            doColumn("expiredTime");
        }

        public void columnName() {
            doColumn("name");
        }

        public void columnSessionId() {
            doColumn("sessionId");

public class NdrBufferTest {

    private byte[] buffer;
    private NdrBuffer ndrBuffer;

    @BeforeEach
    void setUp() {
        buffer = new byte[1024]; // Initialize with a reasonable size
        ndrBuffer = new NdrBuffer(buffer, 0);
    }

    @Test
    void testConstructor() {
        // Verify initial state
        assertEquals(0, ndrBuffer.start);
        assertEquals(0, ndrBuffer.index);

  @CollectionSize.Require(absent = ZERO)
  public void testContainsKeyYes() {
    assertTrue(multimap().containsKey(k0()));
  }

  public void testContainsKeyNo() {
    assertFalse(multimap().containsKey(k3()));
  }

  public void testContainsKeysFromKeySet() {
    for (K k : multimap().keySet()) {
      assertTrue(multimap().containsKey(k));
    }
  }

  public void testContainsKeyAgreesWithGet() {