SMBUtil.writeInt4(0, buffer, bodyStart + 12);

        // Write test data at the specified offset
        byte[] testData = new byte[dataLength];
        for (int i = 0; i < dataLength; i++) {
            testData[i] = (byte) (i & 0xFF);
        }
        System.arraycopy(testData, 0, buffer, dataOffsetFromHeader, dataLength);

        // Use reflection to set headerStart

    }

    private Artifact createTestPomArtifact(String directory) throws IOException {
        File testData = getTestFile(directory);
        FileUtils.deleteDirectory(testData);
        testData.mkdirs();

        Artifact artifact = artifactFactory.createProjectArtifact("test", "test", "1.0");
        artifact.setFile(new File(testData, "test-1.0.pom"));
        assertFalse(artifact.getFile().exists());
        return artifact;
    }

        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

        // Create test data
        byte[] testData = new byte[64];
        for (int i = 0; i < testData.length; i++) {
            testData[i] = (byte) i;
        }

        // Run concurrent updates
        for (int i = 0; i < threadCount; i++) {
            executor.submit(() -> {
                try {

port: 14225
net: localhost

tls {
    cert_file:  "./testdata/contrib/certs/nats_server_cert.pem"
    key_file:   "./testdata/contrib/certs/nats_server_key.pem"

	}

	testenv.MustHaveGoBuild(t)

	td, err := os.Open("testdata/src/pkg")
	if err != nil {
		t.Fatal(err)
	}
	fis, err := td.Readdir(0)
	if err != nil {
		t.Fatal(err)
	}
	for _, fi := range fis {
		if !fi.IsDir() {
			continue
		}

		// TODO(gri) remove extra pkg directory eventually
		goldenFile := filepath.Join("testdata", "src", "pkg", fi.Name(), "golden.txt")

	var testData [256]byte
	for i := range testData {
		testData[i] = byte(i)
	}
	ok := true
	for algo := invalidErasureAlgo + 1; algo < lastErasureAlgo; algo++ {
		for _, conf := range testConfigs {
			failOnErr := func(err error) {

	Fatal(args ...any)
}

func loadCompressed(t tester, file string) (js []byte) {
	dec, err := zstd.NewReader(nil)
	if err != nil {
		t.Fatal(err)
	}
	defer dec.Close()
	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
	if err != nil {
		t.Fatal(err)
	}
	js, err = dec.DecodeAll(js, nil)
	if err != nil {
		t.Fatal(err)
	}

	return js
}

var testCases = []struct {
	name  string

    echo "Fess is not available."
    cat ${temp_log_file} ./fess-*/logs/*.log
    exit 1
  fi
  sleep 1
done

pushd /tmp >/dev/null
git clone https://github.com/codelibs/fess-testdata.git
cd fess-testdata
git checkout f19176ab1b7ddc0a40393a8cbbb8d1c17b27c3ce
cd ..
popd >/dev/null

cat ${temp_log_file} ./fess-*/logs/*.log
curl -s "http://localhost:9201/_cat/indices?v"

        assertNotNull(os);
        byte[] testData = "test data".getBytes();
        os.write(testData);
        os.flush();
        os.close();

        // Assert
        // Verify that data was written to the underlying stream through CacheStream
        verify(initialOutputStream).write(testData);
        verify(initialOutputStream).flush();
        verify(initialOutputStream).close();

        Object[][] testData = { { "\\pipe\\srvsvc", "srvsvc", "4B324FC8-1670-01D3-1278-5A47BF6EE188", 3, 0 },
                { "\\pipe\\lsarpc", "lsarpc", "12345778-1234-ABCD-EF00-0123456789AB", 2, 1 },
                { "\\pipe\\samr", "samr", "12345778-1234-ABCD-EF00-0123456789AC", 1, 0 } };

        for (Object[] data : testData) {
            String endpoint = (String) data[0];