callback.accept(builder);
            return builder.execute();
        });
        final OpenSearchResultList<T> targetList = new OpenSearchResultList<>();
        final SearchHits hits = response.getHits();
        final TotalHits totalHits = hits.getTotalHits();
        final long totalHitsValue = totalHits != null ? totalHits.value() : 0;
        targetList.setTotalHits(totalHitsValue);

        verify(fd, times(1)).close();
        verify(tree, times(1)).close();
    }

    @ParameterizedTest
    @ValueSource(ints = { TransPeekNamedPipeResponse.STATUS_DISCONNECTED, TransPeekNamedPipeResponse.STATUS_SERVER_END_CLOSED })
    @DisplayName("available() on SMB1 returns 0 and marks closed on disconnected statuses")

            assertEquals(100, testResponse.getAvailable());
            assertEquals(status, testResponse.getStatus());
        }
    }

    @ParameterizedTest
    @ValueSource(ints = { 0, 1, 100, 255, 1000, 32767, 65535 })
    @DisplayName("readParametersWireFormat should handle various available values")
    void testReadParametersWireFormatWithVariousAvailableValues(int available) {
        // Arrange

            }
        }

        // Yes, this might just be null.
        return (Method) cacheEntry;
    }

    /**
     * Populate the Map of direct hits. These
     * are taken from all the public methods
     * that our class provides.
     */
    private void populateMethodCache() {
        // get all publicly accessible methods

            ComponentRequirement cr = new ComponentRequirement();

            cr.setRole(requirement.getChild("role").getValue());

            cr.setRoleHint(requirement.getChild("role-hint").getValue());

            cr.setFieldName(requirement.getChild("field-name").getValue());

            mojo.addRequirement(cr);
        }

        return mojo;
    }

            tail[padLen + i] = (byte) (count * 8 >>> 8 * i);
        }

        engineUpdate(tail, 0, tail.length);

        final byte[] result = new byte[16];
        // cast this MD4's context (array of 4 ints) into an array of 16 bytes.
        for (int i = 0; i < 4; i++) {
            for (int j = 0; j < 4; j++) {
                result[i * 4 + j] = (byte) (context[i] >>> 8 * j);
            }
        }

        assertEquals(0x08, ace.getFlags());
        assertEquals(0x00000001, ace.getAccessMask());
    }

    @ParameterizedTest
    @DisplayName("Test various access mask values")
    @ValueSource(ints = { 0x00000001, // FILE_READ_DATA
            0x00000002, // FILE_WRITE_DATA
            0x00000004, // FILE_APPEND_DATA
            0x00010000, // DELETE
            0x00020000, // READ_CONTROL

                    "Should throw configured exception");
        }

        @ParameterizedTest
        @ValueSource(ints = { 1, 10, 50, 100, 255 })
        @DisplayName("Should handle various data lengths")
        void testVariousDataLengths(int length) throws SMBProtocolDecodingException {

  pymdownx.tilde: null
  pymdownx.blocks.admonition:
    types:
    - note
    - attention
    - caution
    - danger
    - error
    - tip
    - hint
    - warning
    - info
    - check
  pymdownx.blocks.details: null
  pymdownx.blocks.tab:
    alternate_style: true
  mdx_include: null
  markdown_include_variants: null
extra:
  social:

            assertNotNull(response.getDfsResponse());
            assertEquals(3, response.getDfsResponse().getNumReferrals());
        }

        @ParameterizedTest
        @ValueSource(ints = { 1, 2, 5, 10 })
        @DisplayName("Should handle varying number of referrals")
        void testReadDataWireFormatVaryingReferrals(int numReferrals) {