// Given
        Smb2TreeConnectRequest req = new Smb2TreeConnectRequest(mockConfig, path);
        byte[] buffer = new byte[1024];

        // Encode to set headerStart
        req.encode(buffer, 0);

        // Then
        byte[] pathBytes = path.getBytes(StandardCharsets.UTF_16LE);

        // Verify path is written correctly at body + 8
        byte[] actualPath = new byte[pathBytes.length];

                    readings[0] = l.toArray(String[]::new);

                    if (items == null) {
                        items = new ArrayList<>(text.length() * fields.length / field.length());
                    }

                    final String[] langs = lang == null ? new String[] {} : new String[] { lang };
                    items.add(new SuggestItem(words, readings, new String[] { field }, 1L, 0, -1, tags, roles, langs,

        CurlRequest request = new CurlRequest(Method.GET, url);

        // Add additional param
        request.param("new", "value");

        assertNotNull(request);
    }

    @Test
    public void testMultipleThreadPoolCalls() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");
        ForkJoinPool pool1 = new ForkJoinPool(2);

        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        writeLittleEndianInt(baos, PacSignature.KERB_CHECKSUM_HMAC_MD5);
        // Write only 10 bytes instead of 16
        baos.write(new byte[10]);
        byte[] data = baos.toByteArray();

        // Verify that PACDecodingException is thrown
        assertThrows(PACDecodingException.class, () -> {
            new PacSignature(data);
        });
    }

                SuggestItem.Kind.DOCUMENT);

        String[][] readings2Query = new String[2][];
        readings2Query[0] = new String[] { "zenbun", "fuga" };
        readings2Query[1] = new String[] { "kensaku", "fuga" };
        String[] tags2Query = new String[] { "tag4" };

        config = new PropertyConfiguration(new Properties());
    }

    /**
     * Test of readParameterWordsWireFormat method
     */
    @Test
    public void testReadParameterWordsWireFormat() {
        // Given
        byte[] buffer = new byte[] { (byte) 0xff, (byte) 0xff, 0, 0, 0, 0, 0, 0 };
        SmbComWriteAndXResponse instance = new SmbComWriteAndXResponse(config);

        // When

            lsarpc.LsarRefDomainList domains = new lsarpc.LsarRefDomainList();
            domains.count = 1;
            domains.max_count = 1;
            domains.domains = new lsarpc.LsarTrustInformation[1];
            domains.domains[0] = new lsarpc.LsarTrustInformation();
            domains.domains[0].name = new UnicodeString("TESTDOM", false);
            domains.domains[0].sid = new jcifs.dcerpc.rpc.sid_t();

    @BeforeEach
    public void setUp() {
        testGuid = new HandleGuid();
        testFileId = new byte[16];
        for (int i = 0; i < 16; i++) {
            testFileId[i] = (byte) (i + 1);
        }
        testLeaseKey = new Smb2LeaseKey();
    }

    @Test
    public void testHandleInfoCreation() {

        project.setScm(new Scm());
        project.getScm().setConnection("scm-connection");
        project.addDependency(dependency1);
        project.addDependency(dependency2);
        project.setBuild(new Build());

        // Build up an artifactMap
        project.addArtifact(new Artifact("g0", "a0", "v0", "e0", "c0"));
        project.addArtifact(new Artifact("g1", "a1", "v1", "e1", "c1"));

  private final ExecutionList list = new ExecutionList();

  public void testRunOnPopulatedList() throws Exception {
    Executor exec = newCachedThreadPool();
    CountDownLatch countDownLatch = new CountDownLatch(3);
    list.add(new MockRunnable(countDownLatch), exec);
    list.add(new MockRunnable(countDownLatch), exec);
    list.add(new MockRunnable(countDownLatch), exec);