doDelete(entity, null);
    }

    public int queryDelete(CBCall<BoostDocumentRuleCB> cbLambda) {
        return doQueryDelete(createCB(cbLambda), null);
    }

    public int[] batchInsert(List<BoostDocumentRule> list) {
        return batchInsert(list, null, null);
    }

    public int[] batchInsert(List<BoostDocumentRule> list, RequestOptionCall<BulkRequestBuilder> call) {

        doDelete(entity, null);
    }

    public int queryDelete(CBCall<DuplicateHostCB> cbLambda) {
        return doQueryDelete(createCB(cbLambda), null);
    }

    public int[] batchInsert(List<DuplicateHost> list) {
        return batchInsert(list, null, null);
    }

    public int[] batchInsert(List<DuplicateHost> list, RequestOptionCall<BulkRequestBuilder> call) {

        doDelete(entity, null);
    }

    public int queryDelete(CBCall<JobLogCB> cbLambda) {
        return doQueryDelete(createCB(cbLambda), null);
    }

    public int[] batchInsert(List<JobLog> list) {
        return batchInsert(list, null, null);
    }

    public int[] batchInsert(List<JobLog> list, RequestOptionCall<BulkRequestBuilder> call) {

     */

    @Override
    public int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /**
     * Reads up to len bytes of data from this input stream into an array of bytes.
     *
     * @throws IOException if a network error occurs
     */

    @Override
    public int read(final byte[] b, final int off, final int len) throws IOException {

    }

    @Test
    void testNegativeSidWrapsCorrectly() {
        // -1 == 0xFFFF
        int negativeSid = -1;
        SmbComFindClose2 neg = new SmbComFindClose2(mockConfig, negativeSid);
        byte[] dst = new byte[2];
        int written = neg.writeParameterWordsWireFormat(dst, 0);
        assertEquals(2, written);

     * @param len
     *            read up to <code>len</code> bytes
     * @return number of bytes read
     * @throws SmbException if an I/O error occurs during read
     */
    int read(byte[] b, int off, int len) throws SmbException;

    /**
     * Current position in file
     *
     * @return current position
     */
    long getFilePointer();

    /**
     * Seek to new position
     *

        for (int i = 0; i < threadCount; i++) {
            final int threadId = i;
            executor.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        startLatch.await();
                        for (int j = 0; j < operationsPerThread; j++) {
                            // Read name

    private int flags;
    private String newNodeAddress;

    // Notification flags
    /** Resource state is unknown */
    public static final int WITNESS_RESOURCE_STATE_UNKNOWN = 0x00000000;
    /** Resource is available for use */
    public static final int WITNESS_RESOURCE_STATE_AVAILABLE = 0x00000001;
    /** Resource is unavailable */
    public static final int WITNESS_RESOURCE_STATE_UNAVAILABLE = 0x000000FF;

        return Arrays.equals(key, other.key);
    }

    @Override
    public int hashCode() {
        return Arrays.hashCode(key);
    }

    @Override
    public String toString() {
        StringBuilder sb = new StringBuilder("LeaseKey[");
        for (int i = 0; i < key.length; i++) {
            if (i > 0) {
                sb.append(' ');
            }

     * This method should do nothing and return 0.
     */
    @Test
    void testWriteParameterWordsWireFormat() {
        byte[] dst = new byte[10];
        int dstIndex = 0;
        // The method should return 0 as it writes no parameter words
        int result = smbComNegotiate.writeParameterWordsWireFormat(dst, dstIndex);
        assertEquals(0, result, "writeParameterWordsWireFormat should return 0.");
    }

    /**