private fun waitForDataFrames(dataLength: Int) {
    val expectedFrameCount = dataLength / 16384
    var dataFrameCount = 0
    while (dataFrameCount < expectedFrameCount) {
      val log = testLogHandler.take()
      if (log == "FINE: << 0x00000003 16384 DATA          ") {
        dataFrameCount++
      }
    }
  }

  @Test
  fun connectionWindowUpdateOnClose() {

pkg syscall (freebsd-arm64), const EV_ENABLE ideal-int
pkg syscall (freebsd-arm64), const EV_EOF = 32768
pkg syscall (freebsd-arm64), const EV_EOF ideal-int
pkg syscall (freebsd-arm64), const EV_ERROR = 16384
pkg syscall (freebsd-arm64), const EV_ERROR ideal-int
pkg syscall (freebsd-arm64), const EV_FLAG1 = 8192
pkg syscall (freebsd-arm64), const EV_FLAG1 ideal-int
pkg syscall (freebsd-arm64), const EV_ONESHOT = 16

pkg syscall (netbsd-arm64-cgo), const CLONE_PTRACE ideal-int
pkg syscall (netbsd-arm64-cgo), const CLONE_SIGHAND = 2048
pkg syscall (netbsd-arm64-cgo), const CLONE_SIGHAND ideal-int
pkg syscall (netbsd-arm64-cgo), const CLONE_VFORK = 16384
pkg syscall (netbsd-arm64-cgo), const CLONE_VFORK ideal-int
pkg syscall (netbsd-arm64-cgo), const CLONE_VM = 256
pkg syscall (netbsd-arm64-cgo), const CLONE_VM ideal-int
pkg syscall (netbsd-arm64-cgo), const CREAD = 2048

    reusedConnectionFailsWithPost(TransferKind.END_OF_STREAM, 16384)
  }

  @Test
  fun postFailsWithChunkedRequestForSmallRequest() {
    reusedConnectionFailsWithPost(TransferKind.CHUNKED, 1024)
  }

  @Test
  fun postFailsWithChunkedRequestForLargeRequest() {
    reusedConnectionFailsWithPost(TransferKind.CHUNKED, 16384)
  }

  @Test

	// Initialize byte pool once for all sets, bpool size is set to
	// setCount * setDriveCount with each memory upto blockSizeV2.
	buffers := bpool.NewBytePoolCap(n, blockSizeV2, blockSizeV2*2)
	if n >= 16384 {
		// pre-populate buffers only n >= 16384 which is (32Gi/2Mi)
		// for all setups smaller than this avoid pre-alloc.
		buffers.Populate()
	}
	globalBytePoolCap.Store(buffers)

	var localDrives []StorageAPI

pkg syscall (netbsd-386), const CLONE_PTRACE ideal-int
pkg syscall (netbsd-386), const CLONE_SIGHAND = 2048
pkg syscall (netbsd-386), const CLONE_SIGHAND ideal-int
pkg syscall (netbsd-386), const CLONE_VFORK = 16384
pkg syscall (netbsd-386), const CLONE_VFORK ideal-int
pkg syscall (netbsd-386), const CLONE_VM = 256
pkg syscall (netbsd-386), const CLONE_VM ideal-int
pkg syscall (netbsd-386), const MADV_DONTNEED = 4

pkg debug/macho, const FlagBindAtLoad = 8
pkg debug/macho, const FlagBindAtLoad uint32
pkg debug/macho, const FlagBindsToWeak = 65536
pkg debug/macho, const FlagBindsToWeak uint32
pkg debug/macho, const FlagCanonical = 16384
pkg debug/macho, const FlagCanonical uint32
pkg debug/macho, const FlagDeadStrippableDylib = 4194304
pkg debug/macho, const FlagDeadStrippableDylib uint32
pkg debug/macho, const FlagDyldLink = 4

    val ping = peer.takeFrame()
    assertThat(ping.type).isEqualTo(Http2.TYPE_PING)
    assertThat(ping.payload1).isEqualTo(2)
  }

  @Test fun clientDoesNotLimitFlowControl() {
    val dataLength = 16384
    // Write the mocking script.
    peer.sendFrame().settings(Settings())
    peer.acceptFrame() // ACK
    peer.acceptFrame() // SYN_STREAM
    peer.sendFrame().headers(false, 3, headerEntries("b", "banana"))

            request.setPadding((byte) 1);
            request.setReadFlags(Smb2ReadRequest.SMB2_READFLAG_READ_UNBUFFERED);
            request.setReadLength(8192);
            request.setOffset(16384L);
            request.setMinimumCount(1024);
            request.setRemainingBytes(4096);

            // Calculate expected size
            int expectedSize = ((Smb2Constants.SMB2_HEADER_LENGTH + 49 + 7) / 8) * 8;

    // Less than 65,536 bytes, because we binary search on a 14-bit index with a stride of 4 bytes.
    assertThat(compactTable.ranges.length).isLessThan((1 shl 14) * 4)

    // Less than 16,384 chars, because we index on a 14-bit index in the ranges table.
    assertThat(compactTable.mappings.length).isLessThan(1 shl 14)

    // Confirm the data strings are ASCII.