displaySize = new BigDecimal(size).divide(BigDecimal.valueOf(1000)) + "KB";
        } else {
            displaySize = size + "bytes";
        }
        return displaySize;
    }

    /**
     * Gets the currently used memory in bytes.
     *
     * @return used memory in bytes
     */
    public static long getUsedMemory() {
        final Runtime runtime = Runtime.getRuntime();

     */
    @Test
    void testReadParametersWireFormat() {
        NetShareEnumResponse response = new NetShareEnumResponse();
        // Parameters: status (2 bytes), converter (2 bytes), numEntries (2 bytes), totalAvailableEntries (2 bytes)
        byte[] buffer = { 0x00, 0x00, // status = 0 (Success)
                0x12, 0x34, // converter = 0x3412
                0x02, 0x00, // numEntries = 2

     * @param remaining the number of bytes remaining to be written
     * @param b the data buffer containing bytes to write
     * @param off the offset in the buffer where data starts
     * @param len the number of bytes to write
     */
    public final void setParam(final int fid, final long offset, final int remaining, final byte[] b, final int off, final int len) {
        this.fid = fid;

		bucket    string
		versioned bool
		object    string
		content   []byte
	}{
		{"bucket1", false, "object1", []byte("aaaaaaaaaaaaaaaa")},
		{"bucket2", false, "object2", bytes.Repeat([]byte{'a'}, smallFileThreshold*2)},
		{"bucket3", true, "version1", []byte("aaaaaaaaaaaaaaaa")},
		{"bucket4", true, "version2", bytes.Repeat([]byte{'a'}, smallFileThreshold*2)},
	}

	for i, testCase := range testCases {

	for input.Scan() {
		line := strings.TrimSpace(input.Text())
		if line == "" {
			continue
		}
		// Find first separator.
		idx := strings.IndexByte(line, trailerKVSeparator[0])
		if idx <= 0 || idx >= len(line) {
			if cr.debug {
				fmt.Printf("Could not find separator, got %q\n", line)
			}
			return errMalformedEncoding
		}
		key := strings.ToLower(line[:idx])

      if (type == TYPE_A || type == TYPE_AAAA) {
        val bytes = ByteArray(length)
        buf.read(bytes)
        result.add(InetAddress.getByAddress(bytes))
      } else {
        buf.skip(length.toLong())
      }
    }

    return result
  }

  @Throws(EOFException::class)
  private fun skipName(source: Buffer) {
    // 0 - 63 bytes
    var length = source.readByte().toInt()

        // Encrypt first message - should work
        byte[] plaintext1 = "Message before rotation".getBytes();
        byte[] encrypted1 = assertDoesNotThrow(() -> context.encryptMessage(plaintext1, 1L));
        assertNotNull(encrypted1);

        // Encrypt larger message to trigger rotation
        byte[] largeMessage = new byte[150]; // Exceed 100 byte limit
        Arrays.fill(largeMessage, (byte) 'A');

        }
    }

    /**
     * Writes the specified byte array to the file at the given pathname.
     *
     * @param pathname
     *            The path to the file.
     * @param bytes
     *            The byte array to write.
     */
    public static void writeBytes(final String pathname, final byte[] bytes) {
        try (FileOutputStream fos = OutputStreamUtil.create(new File(pathname))) {

			return err
		}
	}

	path := filepath.Join(store.directory, key.String())
	if key.Compress {
		err = os.WriteFile(path, s2.Encode(nil, buf.Bytes()), os.FileMode(0o770))
	} else {
		err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770))
	}

	buf.Reset()
	if err != nil {
		return err
	}

	// Increment the item count.
	store.entries[key.String()] = time.Now().UnixNano()

// Use a Scanner with a custom split function to parse a comma-separated
// list with an empty final value but stops at the token "STOP".
func ExampleScanner_earlyStop() {
	onComma := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
		i := bytes.IndexByte(data, ',')
		if i == -1 {
			if !atEOF {
				return 0, nil, nil
			}
			// If we have reached the end, return the last token.
			return 0, data, bufio.ErrFinalToken