* @param client The OpenSearch client.
     * @param readingConverter The reading converter.
     * @param normalizer The normalizer.
     */
    public SuggestRequestBuilder(final Client client, final ReadingConverter readingConverter, final Normalizer normalizer) {
        super(client, new SuggestRequest());
        request.setReadingConverter(readingConverter);
        request.setNormalizer(normalizer);
    }

    /**

     */
    @Execute
    public JsonResponse<ApiResult> settings(final SearchBody body) {
        validateApi(body, messages -> {});
        final FileConfigPager pager = copyBeanToNewBean(body, FileConfigPager.class);
        final List<FileConfig> list = fileConfigService.getFileConfigList(pager);
        return asJson(

    private OptionalEntity<File> getTargetFile(final String fileName) {
        final File baseDir = new File(getServletContext().getRealPath("/"));
        final File targetFile = new File(getServletContext().getRealPath(fileName));
        final List<File> fileList = getAccessibleFileList(baseDir);
        for (final File file : fileList) {
            if (targetFile.equals(file)) {

    public void testFieldType() throws Exception {
        final Map<TypeVariable<?>, Type> map = ParameterizedClassDescFactory.getTypeVariables(Hoge.class);
        final Field field = Hoge.class.getField("foo");
        final ParameterizedClassDesc desc = ParameterizedClassDescFactory.createParameterizedClassDesc(field, map);
        assertThat(desc.getRawClass(), is(sameClass(Map.class)));

        final ParameterizedClassDesc[] args = desc.getArguments();

    private final int shareAccess;

    private int createDisposition;

    private int createOptions;

    private final int impersonationLevel;
    private long allocationSize;
    private final byte securityFlags;
    private int namelen_index;

    int flags0, desiredAccess;

    SmbComNTCreateAndX(final String name, final int flags, final int access, final int shareAccess, final int extFileAttributes,

    // GET /api/admin/systeminfo
    @Execute
    public JsonResponse<ApiResult> get$index() {
        final List<Map<String, String>> bugReportItems = getBugReportItems();
        final List<Map<String, String>> envItems = getEnvItems();
        final List<Map<String, String>> fessPropItems = getFessPropItems(fessConfig);
        final List<Map<String, String>> propItems = getPropItems();

public class CancelCall {
  private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
  private final OkHttpClient client = new OkHttpClient();

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
        .build();

    final long startNanos = System.nanoTime();

     */
    public Smb2ReadRequest(final Configuration config, final byte[] fileId, final byte[] outputBuffer, final int outputBufferOffset) {
        super(config, SMB2_READ);
        this.fileId = fileId;
        this.outputBuffer = outputBuffer;
        this.outputBufferOffset = outputBufferOffset;
    }

    @Override
    protected Smb2ReadResponse createResponse(final CIFSContext tc, final ServerMessageBlock2Request<Smb2ReadResponse> req) {

         * @param level the lookup level
         * @param count the number of SIDs
         */
        public LsarLookupSids(final rpc.policy_handle handle, final LsarSidArray sids, final LsarRefDomainList domains,
                final LsarTransNameArray names, final short level, final int count) {
            this.handle = handle;
            this.sids = sids;
            this.domains = domains;

/** Exception classes for use in tests. */
@GwtCompatible
final class TestExceptions {
  static final class SomeError extends Error {}

  static final class SomeCheckedException extends Exception {}

  static final class SomeOtherCheckedException extends Exception {}

  static final class YetAnotherCheckedException extends Exception {}

  static final class SomeUncheckedException extends RuntimeException {}