Function writeUntilFull

test/host/wasi/wasi.cpp:272–300

template <typename SockSendT>
void writeUntilFull(WasmEdge::Runtime::Instance::MemoryInstance &MemInst,
                    WasmEdge::Runtime::CallingFrame &CallFrame,
                    SockSendT &WasiSockSend, int32_t Fd) {
  using namespace std::literals;
  std::array<WasmEdge::ValVariant, 1> Errno;
  while (true) {
    const uint32_t IOVecSize = 1;
    const uint32_t NWrittenPtr = 0;
    const uint32_t RoFlagsPtr = NWrittenPtr + sizeof(__wasi_size_t);
    const uint32_t IOVecPtr = RoFlagsPtr + sizeof(__wasi_size_t);
    const uint32_t DataPtr = IOVecPtr + sizeof(__wasi_iovec_t) * IOVecSize;
    const uint32_t SiFlags = 0;
    const auto Data = "somedata"sv;
    writeString(MemInst, Data, DataPtr);
    auto IOVec = MemInst.getSpan<__wasi_ciovec_t>(IOVecPtr, IOVecSize);
    IOVec[0].buf = WasmEdge::EndianValue(DataPtr).le();
    IOVec[0].buf_len =
        WasmEdge::EndianValue(static_cast<__wasi_size_t>(Data.size())).le();
    EXPECT_TRUE(
        WasiSockSend.run(CallFrame,
                         std::initializer_list<WasmEdge::ValVariant>{
                             Fd, IOVecPtr, IOVecSize, SiFlags, NWrittenPtr},
                         Errno));
    if (Errno[0].get<int32_t>() != __WASI_ERRNO_SUCCESS) {
      EXPECT_EQ(Errno[0].get<int32_t>(), __WASI_ERRNO_AGAIN);
      break;
    }
  }
}

} // namespace