assertEquals("?????", tree.service);
        assertEquals(0, tree.connectionState);

        // Test constructor with service starting with "??"
        tree = new SmbTree(session, "testShare", "??service");
        assertEquals("TESTSHARE", tree.share);
        assertEquals("?????", tree.service);
        assertEquals(0, tree.connectionState);
    }

    @Test
    void testMatches() {

    } finally {
      service.shutdown();
    }
  }

  public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
      throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);
    ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
    try {
      queue.addListener(listener, service);

    } finally {
      service.shutdown();
    }
  }

  public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
      throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);
    ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
    try {
      queue.addListener(listener, service);

- **Network**
  - [stable] Services can reference another service by DNS name, rather than being hosted in pods ([kubernetes/features#33](https://github.com/kubernetes/enhancements/issues/33))

     * @param path the UNC path to the shared resource
     * @param service the service type (e.g., "A:" for disk share, "LPT1:" for printer)
     * @param andx the next command in the AndX chain, or null
     */
    public SmbComTreeConnectAndX(final CIFSContext ctx, final ServerData server, final String path, final String service,
            final ServerMessageBlock andx) {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.service;

import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
import org.codelibs.fess.crawler.service.impl.OpenSearchUrlQueueService;
import org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig;

            batchLimits[8] = Byte.parseByte(s);
        }
    }

    SmbComTreeConnectAndX(final SmbSession session, final String path, final String service, final ServerMessageBlock andx) {
        super(andx);
        this.session = session;
        this.path = path;
        this.service = service;
        command = SMB_COM_TREE_CONNECT_ANDX;
    }

    @Override
    int getBatchLimit(final byte command) {

    }

    public void test_setEcsServiceName() {
        activityHelper.setEcsServiceName("test-service");
        activityHelper.useEcsFormat = true;
        activityHelper.login(OptionalThing.empty());
        assertTrue(localLogMsg.get().contains("\"service.name\":\"test-service\""));
    }

    public void test_setEcsEventDataset() {
        activityHelper.setEcsEventDataset("test-dataset");

		logger.FatalIf(initGlobalGrid(GlobalContext, globalEndpoints), "Unable to configure server grid RPC services")
	})

	// Initialize lock grid
	bootstrapTrace("initLockGrid", func() {
		logger.FatalIf(initGlobalLockGrid(GlobalContext, globalEndpoints), "Unable to configure server lock grid RPC services")
	})

	// Configure server.
	bootstrapTrace("configureServer", func() {

    }

    @Test
    @DisplayName("getErrorString for name service error with known code")
    void testNameServiceKnown() {
        String expected = "ERR_NAM_SRVC/FMT_ERR: Format ErrorUnknown error code: 1";
        assertEquals(expected, NbtException.getErrorString(NbtException.ERR_NAM_SRVC, NbtException.FMT_ERR));
    }

    @Test
    @DisplayName("getErrorString for name service error with unknown code")
    void testNameServiceUnknown() {