}

    @Test
    @DisplayName("Should perform hexdump with correct formatting")
    void testHexdump() {
        // Capture output
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        PrintStream ps = new PrintStream(baos);

        // Test with 16 bytes (one complete line)
        byte[] data1 = createTestData(16);

	listingQuorum := (set.setDriveCount + 1) / 2

	// How to resolve partial results.
	resolver := metadataResolutionParams{
		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
		objQuorum: listingQuorum, // make sure to capture all quorum ratios
		bucket:    bucketName,
	}

	err := listPathRaw(ctx, listPathRawOptions{
		disks:          disks,
		bucket:         bucketName,
		recursive:      true,

  static final Integer N3 = 3;
  static final Integer N4 = 4;
  static final Integer N5 = 5;
  static final Integer NODE_NOT_IN_GRAPH = 1000;

  // TODO(user): Consider separating Strings that we've defined here to capture
  // identifiable substrings of expected error messages, from Strings that we've defined
  // here to provide error messages.
  // TODO(user): Some Strings used in the subclasses can be added as static Strings
  // here too.

up","mstack","msline","msrow","semantics","annotation","annotation-xml","mprescripts","none"]),U=i(["#text"]),z=i(["accept","action","align","alt","autocapitalize","autocomplete","autopictureinpicture","autoplay","background","bgcolor","border","capture","cellpadding","cellspacing","checked","cite","class","clear","color","cols","colspan","controls","controlslist","coords","crossorigin","datetime","decoding","default","dir","disabled","disablepictureinpicture","disableremoteplayback","download",...

	listingQuorum := (set.setDriveCount + 1) / 2

	// How to resolve partial results.
	resolver := metadataResolutionParams{
		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
		objQuorum: listingQuorum, // make sure to capture all quorum ratios
		bucket:    bi.Name,
	}

	err := listPathRaw(ctx, listPathRawOptions{
		disks:          disks,
		bucket:         bi.Name,
		path:           bi.Prefix,

        ArgumentCaptor<Integer> rnCap = ArgumentCaptor.forClass(Integer.class);

        verify(transport).getDfsReferrals(eq(ctx), nameCap.capture(), hostCap.capture(), domCap.capture(), rnCap.capture());
        assertEquals(name, nameCap.getValue());
        assertEquals(host, hostCap.getValue());
        assertEquals(domain, domCap.getValue());
        assertEquals(rn, rnCap.getValue());

        ArgumentCaptor<String> shareCap = ArgumentCaptor.forClass(String.class);
        ArgumentCaptor<String> svcCap = ArgumentCaptor.forClass(String.class);
        verify(session).getSmbTree(shareCap.capture(), svcCap.capture());
        assertEquals(share, shareCap.getValue());
        assertEquals(svc, svcCap.getValue());
    }

    // Edge/invalid inputs: null or empty share/service cause IllegalArgumentException (mocked)

  - job-description: Elasticsearch %BRANCH% branch intake sanity check.

            assertNotNull(handle);
            ArgumentCaptor<MsrpcSamrConnect4> captor = ArgumentCaptor.forClass(MsrpcSamrConnect4.class);
            verify(mockHandle).sendrecv(captor.capture());
            assertEquals("\\\\", captor.getValue().system_name); // Verify server name in RPC call
        }
    }

    @Test
    void testConstructor_FallbackToConnect2() throws IOException {

  - job-description: Elasticsearch %BRANCH% branch intake check part 1.