if ((dattrs & SmbConstants.ATTR_READONLY) != 0) {
                /*
                 * Remove READONLY and try again
                 */
                dest.setPathInformation(dattrs & ~SmbConstants.ATTR_READONLY, 0L, 0L, 0L);
                return dest.openUnshared(SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC,

        if (progressedSize < 0L) {
            throw new IllegalArgumentException("progressed file size cannot be negative: " + size);
        }
        if (size >= 0 && progressedSize > size) {
            throw new IllegalArgumentException(
                    "progressed file size cannot be greater than size: " + progressedSize + " > " + size);
        }

        if (size >= 0L && progressedSize != size) {

    }

    @Test
    public void test_sizeOf_arrayVariations() {
        // Empty array
        assertEquals(0L, MemoryUtil.sizeOf(new String[0]));
        assertEquals(0L, MemoryUtil.sizeOf(new Object[0]));

        // Array with null elements
        assertEquals(0L, MemoryUtil.sizeOf(new String[] { null, null }));

        // Mixed content array

    assertThat(min(LEAST)).isEqualTo(LEAST);
    assertThat(min(GREATEST)).isEqualTo(GREATEST);
    assertThat(min(0x5a4316b8c153ac4dL, 8L, 100L, 0L, 0x6cf78a4b139a4e2aL, 0xff1a618b7f65ea12L))
        .isEqualTo(0L);
  }

  public void testLexicographicalComparator() {
    List<long[]> ordered =
        Arrays.asList(
            new long[] {},
            new long[] {LEAST},
            new long[] {LEAST, LEAST},

        for (int i = 0; i < 16; i++)
            fileId[i] = (byte) (0xF0 + i);
        byte[] header = buildSmb2Header();
        byte[] body = buildCreateBodyNoContexts((byte) 0, (byte) 0, 0, 0L, 0L, 0L, 0L, 0L, 0L, 0, fileId);
        byte[] packet = buildPacket(header, body, null, null);
        resp.decode(packet, 0, false); // marks as received

            // Given
            ByteBuffer buffer = ByteBuffer.allocate(32);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putLong(0L);
            buffer.putLong(0L);
            buffer.putLong(0L);
            buffer.putInt(0);
            buffer.putInt(0);
            byte[] bufferArray = buffer.array();

            // When

    val pool = factory.newConnectionPool()
    val poolApi = ConnectionPool(pool)
    val c1 = factory.newConnection(pool, routeA1, 0L)
    allocateAndLeakAllocation(poolApi, c1)
    awaitGarbageCollection()
    assertThat(pool.closeConnections(100L)).isEqualTo(0L)
    assertThat(c1.calls).isEmpty()

    // Can't allocate once a leak has been detected.
    assertThat(c1.noNewExchanges).isTrue()
  }

  }

  @Test fun addDate() {
    val expected = Date(0L)
    val headers =
      Headers
        .Builder()
        .add("testDate", expected)
        .build()
    assertThat(headers["testDate"]).isEqualTo("Thu, 01 Jan 1970 00:00:00 GMT")
    assertThat(headers.getDate("testDate")).isEqualTo(Date(0L))
  }

  @Test fun addInstant() {
    val expected = Instant.ofEpochMilli(0L)
    val headers =
      Headers
        .Builder()

        assertEquals("0", mockConfig.getTimeAdjustTimeMillis());
        assertEquals(Long.valueOf(0L), mockConfig.getTimeAdjustTimeMillisAsLong());

        // Test multiple calls return same values
        for (int i = 0; i < 10; i++) {
            assertEquals("0", mockConfig.getTimeAdjustTimeMillis());
            assertEquals(Long.valueOf(0L), mockConfig.getTimeAdjustTimeMillisAsLong());
        }
    }

        final MockSearchRequestParams params = new MockSearchRequestParams();
        final LocalDateTime now = LocalDateTime.now();
        final QueryResponseList queryResponseList = new QueryResponseList(Collections.emptyList(), 0L, "eq", 0L, false, null, 0, 10, 0);

        searchLogHelper.createSearchLog(params, now, "test-query-id", "test query", 0, 10, queryResponseList, context);

        assertFalse(searchLogHelper.searchLogQueue.isEmpty());