cpp-ipc/src/libipc/imp/fmt.cpp

#include <cstdio>     // std::snprintf
#include <iomanip>    // std::put_time
#include <sstream>    // std::ostringstream
#include <array>
#include <cstring>    // std::memcpy
#include <algorithm>  // std::min
#include <initializer_list>
#include <cstdint>

#include "libipc/imp/fmt.h"
#include "libipc/imp/codecvt.h"
#include "libipc/imp/detect_plat.h"

namespace ipc {

/**
 * \brief Format conversions helpers.
 * \see http://personal.ee.surrey.ac.uk/Personal/R.Bowden/C/printf.html
 *      https://en.cppreference.com/w/cpp/io/c/fprintf
 */
namespace {

struct sfmt_policy {
  static constexpr std::size_t aligned_size = 32U;
};

template <typename Policy = sfmt_policy>
span<char> local_fmt_sbuf() noexcept {
  thread_local std::array<char, Policy::aligned_size> sbuf;
  return sbuf;
}

span<char const> normalize(span<char const> const &a) {
  if (a.empty()) return {};
  return a.first(a.size() - (a.back() == '\0' ? 1 : 0));
}

span<char> smem_cpy(span<char> const &sbuf, span<char const> a) noexcept {
  if (sbuf.empty()) return {};
  a = normalize(a);
  auto sz = (std::min)(sbuf.size() - 1, a.size());
  if (sz != 0) std::memcpy(sbuf.data(), a.data(), sz);
  return sbuf.first(sz);
}

span<char> sbuf_cpy(span<char> sbuf, span<char const> const &a) noexcept {
  sbuf = smem_cpy(sbuf, a);
  *sbuf.end() = '\0';
  return sbuf;
}

span<char> sbuf_cat(span<char> const &sbuf, std::initializer_list<span<char const>> args) noexcept {
  std::size_t remain = sbuf.size();
  for (auto s : args) {
    remain -= smem_cpy(sbuf.last(remain), s).size();
  }
  auto sz = sbuf.size() - remain;
  sbuf[sz] = '\0';
  return sbuf.first(sz);
}

char const *as_cstr(span<char const> const &a) {
  if (a.empty()) return "";
  if (a.back() == '\0') return a.data();
  return sbuf_cpy(local_fmt_sbuf(), a).data();
}

span<char> fmt_of(span<char const> const &fstr, span<char const> const &s) {
  return sbuf_cat(local_fmt_sbuf(), {"%", fstr, s});
}

span<char> fmt_of_unsigned(span<char const> fstr, span<char const> const &l) {
  if (fstr.empty()) {
    return fmt_of(l, "u");
  }
  fstr = normalize(fstr);
  switch (fstr.back()) {
    case 'o':
    case 'x':
    case 'X':
    case 'u': return sbuf_cat(local_fmt_sbuf(), {"%", fstr.first(fstr.size() - 1), l, fstr.last(1)});
    default : return sbuf_cat(local_fmt_sbuf(), {"%", fstr, l, "u"});
  }
}

span<char> fmt_of_signed(span<char const> fstr, span<char const> const &l) {
  if (fstr.empty()) {
    return fmt_of(l, "d");
  }
  fstr = normalize(fstr);
  switch (fstr.back()) {
    case 'o':
    case 'x':
    case 'X':
    case 'u': return fmt_of_unsigned(fstr, l);
    default : return sbuf_cat(local_fmt_sbuf(), {"%", fstr, l, "d"});
  }
}

span<char> fmt_of_float(span<char const> fstr, span<char const> const &l) {
  if (fstr.empty()) {
    return fmt_of(l, "f");
  }
  fstr = normalize(fstr);
  switch (fstr.back()) {
    case 'e':
    case 'E':
    case 'g':
    case 'G': return sbuf_cat(local_fmt_sbuf(), {"%", fstr.first(fstr.size() - 1), l, fstr.last(1)});
    default : return sbuf_cat(local_fmt_sbuf(), {"%", fstr, l, "f"});
  }
}

template <typename A /*a fundamental or pointer type*/>
int sprintf(fmt_context &ctx, span<char const> const &sfmt, A a) {
  for (std::int32_t sz = -1;;) {
    auto sbuf = ctx.buffer(sz + 1);
    if (sbuf.size() < std::size_t(sz + 1)) {
      return -1;
    }
    sz = std::snprintf(sbuf.data(), sbuf.size(), sfmt.data(), a);
    if (sz <= 0) {
      return sz;
    }
    if (std::size_t(sz) < sbuf.size()) {
      ctx.expend(sz);
      return sz;
    }
  }
}

template <typename F /*a function pointer*/, 
          typename A /*a fundamental or pointer type*/>
bool sprintf(fmt_context &ctx, F fop, span<char const> const &fstr, span<char const> const &s, A a) noexcept {
  LIBIPC_TRY {
    return ipc::sprintf(ctx, fop(fstr, s), a) >= 0;
  } LIBIPC_CATCH(...) {
    return false;
  }
}

} // namespace

/// \brief The context of fmt.

fmt_context::fmt_context(std::string &j) noexcept
  : joined_(j)
  , offset_(0) {}

std::size_t fmt_context::capacity() noexcept {
  return (offset_ < sbuf_.size()) ? sbuf_.size() : joined_.size();
}

void fmt_context::reset() noexcept {
  offset_ = 0;
}

bool fmt_context::finish() noexcept {
  LIBIPC_TRY {
    if (offset_ < sbuf_.size()) {
      joined_.assign(sbuf_.data(), offset_);
    } else {
      joined_.resize(offset_);
    }
    return true;
  } LIBIPC_CATCH(...) {
    return false;
  }
}

span<char> fmt_context::buffer(std::size_t sz) noexcept {
  auto roundup = [](std::size_t sz) noexcept {
    constexpr std::size_t fmt_context_aligned_size = 512U;
    return (sz & ~(fmt_context_aligned_size - 1)) + fmt_context_aligned_size;
  };
  auto sbuf = make_span(sbuf_);
  LIBIPC_TRY {
    if (offset_ < sbuf.size()) {
      if ((offset_ + sz) < sbuf.size()) {
        return sbuf.subspan(offset_);
      } else {
        /// \remark switch the cache to std::string
        joined_.assign(sbuf.data(), offset_);
        joined_.resize(roundup(offset_ + sz));
      }
    } else if ((offset_ + sz) >= joined_.size()) {
      joined_.resize(roundup(offset_ + sz));
    }
    return {&joined_[offset_], joined_.size() - offset_};
  } LIBIPC_CATCH(...) {
    return {};
  }
}

void fmt_context::expend(std::size_t sz) noexcept {
  offset_ += sz;
}

bool fmt_context::append(span<char const> const &str) noexcept {
  auto sz = str.size();
  if (sz == 0) return true;
  if (str.back() == '\0') --sz;
  auto sbuf = buffer(sz);
  if (sbuf.size() < sz) {
    return false;
  }
  std::memcpy(sbuf.data(), str.data(), sz);
  offset_ += sz;
  return true;
}

/// \brief To string conversion.

bool to_string(fmt_context &ctx, char const *a) noexcept {
  return to_string(ctx, a, {});
}

bool to_string(fmt_context &ctx, std::string const &a) noexcept {
  return ctx.append(a);
}

bool to_string(fmt_context &ctx, char const *a, span<char const> fstr) noexcept {
  if (a == nullptr) return false;
  return ipc::sprintf(ctx, fmt_of, fstr, "s", a);
}

bool to_string(fmt_context &ctx, char a) noexcept {
  return ipc::sprintf(ctx, fmt_of, {}, "c", a);
}

bool to_string(fmt_context &ctx, wchar_t a) noexcept {
  LIBIPC_TRY {
    std::string des;
    cvt_sstr(std::wstring{a}, des);
    return ctx.append(des);
  } LIBIPC_CATCH(...) {
    return false;
  }
}

bool to_string(fmt_context &ctx, char16_t a) noexcept {
  LIBIPC_TRY {
    std::string des;
    cvt_sstr(std::u16string{a}, des);
    return ctx.append(des);
  } LIBIPC_CATCH(...) {
    return false;
  }
}

bool to_string(fmt_context &ctx, char32_t a) noexcept {
  LIBIPC_TRY {
    std::string des;
    cvt_sstr(std::u32string{a}, des);
    return ctx.append(des);
  } LIBIPC_CATCH(...) {
    return false;
  }
}

bool to_string(fmt_context &ctx, signed short a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_signed, fstr, "h", a);
}

bool to_string(fmt_context &ctx, unsigned short a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_unsigned, fstr, "h", a);
}

bool to_string(fmt_context &ctx, signed int a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_signed, fstr, "", a);
}

bool to_string(fmt_context &ctx, unsigned int a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_unsigned, fstr, "", a);
}

bool to_string(fmt_context &ctx, signed long a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_signed, fstr, "l", a);
}

bool to_string(fmt_context &ctx, unsigned long a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_unsigned, fstr, "l", a);
}

bool to_string(fmt_context &ctx, signed long long a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_signed, fstr, "ll", a);
}

bool to_string(fmt_context &ctx, unsigned long long a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_unsigned, fstr, "ll", a);
}

bool to_string(fmt_context &ctx, double a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_float, fstr, "", a);
}

bool to_string(fmt_context &ctx, long double a, span<char const> fstr) noexcept {
  return ipc::sprintf(ctx, fmt_of_float, fstr, "L", a);
}

bool to_string(fmt_context &ctx, std::nullptr_t) noexcept {
  return ctx.append("null");
}

bool to_string(fmt_context &ctx, void const volatile *a) noexcept {
  if (a == nullptr) {
    return to_string(ctx, nullptr);
  }
  return ipc::sprintf(ctx, fmt_of, "", "p", a);
}

bool to_string(fmt_context &ctx, std::tm const &a, span<char const> fstr) noexcept {
  if (fstr.empty()) {
    fstr = "%Y-%m-%d %H:%M:%S";
  }
  LIBIPC_TRY {
    std::ostringstream ss;
    ss << std::put_time(&a, as_cstr(fstr));
    return ctx.append(ss.str());
  } LIBIPC_CATCH(...) {
    return {};
  }
}

} // namespace ipc