"http://dbflute.org/meta/lastadi10.dtd">
<components>
	<component name="searchEngineClient" class="org.codelibs.fess.opensearch.client.SearchEngineClient">
		<property name="settings">
			{"http.cors.enabled":"true",
			 "http.cors.allow-origin":"*",
			 "discovery.type":"single-node",
			 "cluster.allocator.existing_shards_allocator.batch_enabled":"true",
			 <!--
			 "node.name":"search_engine",

        assertTrue(length > 0);
        assertNull(testBlock.getAndx()); // andx should be cleared when batching disabled
    }

    @Test
    @DisplayName("Test encode with andx command and batching enabled")
    void testEncodeWithAndxBatchingEnabled() {
        when(mockConfig.isUseBatching()).thenReturn(true);
        when(mockAndxCommand.getCommand()).thenReturn(0x42);

    assertNotNull(region2);
    
    manager.cleanup();
}
```

### 7.2 Integration Tests
```java
@Test
@EnabledIfSystemProperty(named = "rdma.test.enabled", matches = "true")
public void testRdmaLargeFileTransfer() throws Exception {
    CIFSContext context = getTestContext();
    context.getConfig().setProperty("jcifs.smb.client.useRDMA", "true");
    

        if (log.isDebugEnabled() && trans.isSigningOptional() && !loc.isIPC() && !this.ctx.getConfig().isSigningEnforced()) {
            log.debug("Signatures for file enabled but not required " + this);
        }

        if (referral != null) {
            t.markDomainDfs();
        }

        try {
            if (log.isTraceEnabled()) {

                    LaRequestUtil.getOptionalRequest().ifPresent(request -> {
                        request.setAttribute("running", entity.isRunning());
                        request.setAttribute("enabled", entity.isEnabled());
                    });
                }).orElse(() -> {
                    throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml);

        verify(mockRequest).setSignSeq(10);
        verify(mockResponse).setSignSeq(11);
    }

    @Test
    @DisplayName("Test sign method with bypass enabled")
    void testSignWithBypass() {
        SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey, true, 10);
        byte[] data = new byte[100];

         * only the documents from the current session.
         *
         * <p>The deletion process:</p>
         * <ul>
         *   <li>Checks if old document deletion is enabled</li>
         *   <li>Builds a query to find old documents for this configuration</li>
         *   <li>Optionally preserves expired documents based on configuration</li>

    @BeforeClass
    public static void beforeClass() throws Exception {
        runner = new OpenSearchRunner();
        runner.onBuild((number, settingsBuilder) -> {
            settingsBuilder.put("http.cors.enabled", true);
            settingsBuilder.put("discovery.type", "single-node");
        })
                .build(newConfigs().clusterName("SuggestIndexWriterTest")
                        .numOfNode(1)

        return false;
    }

    /**
     * {@return whether the directory described by this source element should be included in the build}
     * The default value is {@code true}.
     */
    default boolean enabled() {
        return true;
    }

  * More reliable kube-up/kube-down
  * Enable ICMP Type 3 Code 4 for ELBs
  * ARP caching fix
  * Use /dev/xvdXX names
  * ELB:
    * ELB proxy protocol support 
	* mixed plaintext/encrypted ports support in ELBs
    * SSL support for ELB listeners
  * Allow VPC CIDR to be specified (experimental)
  * Fix problems with >2 security groups
* GCP:
  * Enable using gcr.io as a Docker registry mirror.