frameCallback.onReadPong(controlFrameBuffer.readByteString())
      }
      OPCODE_CONTROL_CLOSE -> {
        var code = CLOSE_NO_STATUS_CODE
        var reason = ""
        val bufferSize = controlFrameBuffer.size
        if (bufferSize == 1L) {
          throw ProtocolException("Malformed close payload length of 1.")
        } else if (bufferSize != 0L) {
          code = controlFrameBuffer.readShort().toInt()

                        }
                      };
                    }
                  };
                }

                @Override
                public int size() {
                  return map.size();
                }

                @Override
                public boolean remove(Object o) {
                  return map.entrySet().remove(o);
                }

        int attributes = mockEntry.getAttributes();
        long createTime = mockEntry.createTime();
        long lastModified = mockEntry.lastModified();
        long lastAccess = mockEntry.lastAccess();
        long size = mockEntry.length();

        // Assert: values and interactions
        assertEquals("file.txt", name, "getName should return stubbed value");
        assertEquals(1, type1);
        assertEquals(1, type2);

    if (isWindows()) {
      return; // TODO: b/136041958 - Running very slowly on Windows CI.
    }
    int size = 50;
    CyclicBarrier barrier =
        new CyclicBarrier(
            2 // for the setter threads
                + size // for the listeners
                + size // for the get threads,
                + 1); // for the main thread

  var minFreshSeconds = -1
  var onlyIfCached = false
  var noTransform = false
  var immutable = false

  var canUseHeaderValue = true
  var headerValue: String? = null

  loop@ for (i in 0 until headers.size) {
    val name = headers.name(i)
    val value = headers.value(i)

    when {
      name.equals("Cache-Control", ignoreCase = true) -> {
        if (headerValue != null) {

    }

    /**
     * @return the lastWriteTime
     */
    @Override
    public final long getLastWriteTime() {
        return this.lastWriteTime;
    }

    /**
     * Gets the allocation size.
     *
     * @return the allocationSize
     */
    public final long getAllocationSize() {
        return this.allocationSize;
    }

    /**
     * Gets the end of file position.
     *

    void testWriteSetupWireFormatMinimumBuffer() {
        // Arrange
        transWaitNamedPipe = new TransWaitNamedPipe(mockConfig, testPipeName);
        byte[] dst = new byte[4]; // Minimum required size

        // Act
        int bytesWritten = transWaitNamedPipe.writeSetupWireFormat(dst, 0);

        // Assert
        assertEquals(4, bytesWritten);

        assertEquals("true", returned.get("storeKey"));
        assertEquals("******@****.***", returned.get("principal"));
        // Ensure no unexpected extra options
        assertEquals(3, returned.size(), "Only provided options are expected");
    }

    @Test
    @DisplayName("Null options cause IllegalArgumentException when retrieving entries (JAAS requires non-null options)")
    void nullOptions_throwOnAccess() {

        if (artifacts == null) {
            return "";
        }
        StringBuilder sb = new StringBuilder(256);
        int i = 1;
        sb.append("---------\n");
        sb.append(artifacts.size()).append('\n');
        for (Artifact a : artifacts) {
            sb.append(i).append(' ').append(a).append('\n');
            i++;
        }
        sb.append("---------\n");
        return sb.toString();

    void testDES() throws Exception {
        // Given
        byte[] key = "testkey1".getBytes(); // 8 bytes for DES
        byte[] plaintext = "12345678".getBytes(); // 8 bytes (DES block size)

        // When
        Cipher desCipher = Crypto.getDES(key);
        desCipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(key, "DES"));
        byte[] encrypted = desCipher.doFinal(plaintext);