} catch (Exception e) {
                    exceptions.add(e);
                } finally {
                    endLatch.countDown();
                }
            });
        }

        // Start all threads simultaneously
        startLatch.countDown();

        // Wait for completion
        assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout");
        executor.shutdown();

        dstIndex++;
        dst[dstIndex++] = (byte) 0x00;
        return 2;
    }

    @Override
    protected int writeParametersWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

        SMBUtil.writeInt2(mapInformationLevel(this.informationLevel), dst, dstIndex);
        dstIndex += 2;

        /*
         * windows98 has what appears to be another 4 0's followed by the share

        ViewHelper.TextFragment fragment = new ViewHelper.TextFragment("prefix", "start", "end", "suffix");
        String urlString = fragment.toURLString();
        assertNotNull(urlString);
        assertTrue(urlString.contains("text="));
        assertTrue(urlString.contains("start"));

        fragment = new ViewHelper.TextFragment(null, "start", null, null);
        urlString = fragment.toURLString();

labels.wizard_button_register_again=Create Continuously
labels.wizard_button_register_next=Create
labels.wizard_start_crawling_title=Start Crawling
labels.wizard_start_crawler_title=Crawler
labels.wizard_start_crawling_desc=You can start crawling now by clicking "Start Crawling" button.
labels.wizard_button_start_crawling=Start Crawling
labels.wizard_button_finish=Skip
labels.search_list_configuration=Search
labels.search_list_button_delete=Delete

    int getBatchLimit(final byte command) {
        return command == SMB_COM_CLOSE ? BATCH_LIMIT : 0;
    }

    @Override
    int writeParameterWordsWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

        writeInt2(fid, dst, dstIndex);
        dstIndex += 2;
        writeInt4(offset, dst, dstIndex);
        dstIndex += 4;
        writeInt2(maxCount, dst, dstIndex);
        dstIndex += 2;

        dstIndex++;
        dst[dstIndex++] = (byte) 0x00;
        return 2;
    }

    @Override
    int writeParametersWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

        writeInt2(sid, dst, dstIndex);
        dstIndex += 2;
        writeInt2(Trans2FindFirst2.LIST_COUNT, dst, dstIndex);
        dstIndex += 2;
        writeInt2(informationLevel, dst, dstIndex);

              }
            })
        .start();
  }

  static void repeatedlyInterruptTestThread(
      long interruptPeriodMillis, TearDownAccepter tearDownAccepter) {
    Interruptenator interruptingTask =
        new Interruptenator(Thread.currentThread(), interruptPeriodMillis);
    Thread interruptingThread = new Thread(interruptingTask);
    interruptingThread.start();
    tearDownAccepter.addTearDown(

        return 0;
    }

    @Override
    protected int readParameterWordsWireFormat(final byte[] buffer, int bufferIndex) {
        final int start = bufferIndex;

        bufferIndex += 2; // reserved
        this.dataCompactionMode = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 4; // 2 reserved

    @Override
    public int size() {
        return size8(Smb2Constants.SMB2_HEADER_LENGTH + STRUCTURE_SIZE);
    }

    @Override
    protected int writeBytesWireFormat(byte[] dst, int dstIndex) {
        int start = dstIndex;

        // StructureSize (2 bytes) - must be 36
        SMBUtil.writeInt2(STRUCTURE_SIZE, dst, dstIndex);
        dstIndex += 2;

        // Reserved (2 bytes)

     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#writeBytesWireFormat(byte[], int)
     */
    @Override
    protected int writeBytesWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;
        SMBUtil.writeInt2(24, dst, dstIndex);
        SMBUtil.writeInt2(this.closeFlags, dst, dstIndex + 2);
        dstIndex += 4;
        dstIndex += 4; // Reserved