||a.formUtils.LANG,e.length||(e=b.parent());var g=this.getValue(b);b.valAttr("skipped",!1).one("beforeValidation",function(){(b.attr("disabled")||!b.is(":visible")&&!d.validateHiddenInputs)&&b.valAttr("skipped",1)}).trigger("beforeValidation",[g,c,d]);var h="true"===b.valAttr("optional"),i=!g&&h,j=b.attr(d.validationRuleAttribute),k=!0,l="",m={isValid:!0,shouldChangeDisplay:!0,errorMsg:""};if(!j||i||b.valAttr("skipped"))return m.shouldChangeDisplay=d.addValidClassOnAll,m;var n=b.valAttr("ignore");return...

      return samples;
    }

    @Override
    public Set<V> create(Object... elements) {
      @SuppressWarnings("unchecked")
      V[] valuesArray = (V[]) elements;

      // Start with a suitably shaped collection of entries
      Collection<Entry<K, V>> originalEntries = mapGenerator.getSampleElements(elements.length);

      // Create a copy of that, with the desired value for each value

        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        if (searchLogQueue.size() > fessConfig.getLoggingSearchMaxQueueSizeAsInteger()) {
            logger.warn("[{}] The search log queue size is too large. Skipped the search log: {}", queryId, query);
            return;
        }

        final SearchLogContext context = createSearchLogContext(params, fessConfig);

  ':x-pack:plugin:watcher:qa:rest',
  ':x-pack:plugin:watcher:qa:with-monitoring',
  ':x-pack:plugin:watcher:qa:with-security',
  ':x-pack:plugin:wildcard',
  ':x-pack:qa',
  ':x-pack:qa:runtime-fields:core-with-mapped',
  ':x-pack:qa:runtime-fields:core-with-search',
  ':x-pack:qa:runtime-fields:with-security',
  ':x-pack:qa:security-example-spi-extension',
  ':x-pack:test:idp-fixture',
  ':x-pack:test:smb-fixture'
]

        CompletableFuture<Void> task = asyncNotifyTasks.remove(registrationId);
        if (task != null) {
            task.cancel(true);
            log.debug("Stopped async notification monitoring for {}", registrationId);
        }
    }

    /**
     * Processes an async notification message and converts it to a WitnessNotification.
     *

        } catch (final Exception e) {
            return false;
        }
    }

    /**
     * Formats an IP address string for use in a URL.
     * IPv6 addresses are wrapped in brackets, IPv4 addresses are returned as-is.
     *
     * @param address the IP address string to format
     * @return the formatted address (IPv6 with brackets, IPv4 unchanged)
     */

     * Test for unwrap with nested wrapping.
     * Verifies that unwrap works correctly with multiple levels of wrapping.
     */
    @Test
    void testUnwrap_nestedWrapping() {
        // Create a chain of wrapped trees
        CustomSmbTree innerTree = mock(CustomSmbTree.class);
        ExtendedSmbTree middleTree = mock(ExtendedSmbTree.class);

        when(smbTree.unwrap(ExtendedSmbTree.class)).thenReturn(middleTree);

        ctx.setMechs(updated);
        assertArrayEquals(updated, ctx.getMechs());
    }

    @Test
    @DisplayName("toString includes wrapped mechanism context")
    void testToString() {
        SpnegoContext ctx = newContext();
        when(this.mechContext.toString()).thenReturn("MECHCTX");
        assertEquals("SPNEGO[MECHCTX]", ctx.toString());
    }

import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;

/**
 * Job for exporting indexed search documents to the filesystem.
 * Each document is exported as a single file with URL structure mapped to directory structure.
 */
public class IndexExportJob {

    private static final Logger logger = LogManager.getLogger(IndexExportJob.class);

    private static final int MAX_PATH_COMPONENT_LENGTH = 200;

   * <p>The names are retrieved from the {@code nameSupplier} on the thread that is being renamed
   * right before each task is run. The renaming is best effort, if a {@link SecurityManager}
   * prevents the renaming then it will be skipped but the tasks will still execute.
   *
   * @param executor The executor to decorate
   * @param nameSupplier The source of names for each task
   */
  @J2ktIncompatible
  @GwtIncompatible // concurrency