diff options
| author | Amlal El Mahrouss <amlal@nekernel.org> | 2025-08-02 01:29:15 +0100 |
|---|---|---|
| committer | Amlal El Mahrouss <amlal@nekernel.org> | 2025-08-02 01:29:15 +0100 |
| commit | 678f457a9797ae064634f8ba2a83b156f2892871 (patch) | |
| tree | 31e5d6625e16dd5842022e5d99de4dd51ea55277 /dev/lib | |
| parent | 4dbb5cc1283eed26cb9b66600fe9bb594aad8ef3 (diff) | |
refactor! breaking API changes of SOCL, also reworked must_pass helpers, and added one for the fix parser.
Signed-off-by: Amlal El Mahrouss <amlal@nekernel.org>
Diffstat (limited to 'dev/lib')
| -rw-r--r-- | dev/lib/except/error.hpp | 1 | ||||
| -rw-r--r-- | dev/lib/fix/network.hpp | 7 | ||||
| -rw-r--r-- | dev/lib/fix/parser.hpp | 37 | ||||
| -rw-r--r-- | dev/lib/memory/tracked_ptr.hpp | 9 | ||||
| -rw-r--r-- | dev/lib/utility/cgi.hpp | 29 | ||||
| -rw-r--r-- | dev/lib/utility/embfs.hpp | 1 |
6 files changed, 58 insertions, 26 deletions
diff --git a/dev/lib/except/error.hpp b/dev/lib/except/error.hpp index 1a07ef0..9e16ad0 100644 --- a/dev/lib/except/error.hpp +++ b/dev/lib/except/error.hpp @@ -14,6 +14,7 @@ namespace snu::except using runtime_error = std::runtime_error; using fix_error = runtime_error; using math_error = runtime_error; + using cgi_error = runtime_error; } // namespace snu::except #endif // _SNU_ERR_HPP
\ No newline at end of file diff --git a/dev/lib/fix/network.hpp b/dev/lib/fix/network.hpp index 48234e6..e663869 100644 --- a/dev/lib/fix/network.hpp +++ b/dev/lib/fix/network.hpp @@ -28,8 +28,9 @@ namespace snu::fix delivery_modem& operator=(const delivery_modem&) = default; delivery_modem(const delivery_modem&) = default; + public: static constexpr auto local_address = "127.0.0.1"; - static constexpr auto backlog_cnt = 18U; + static constexpr auto backlog_count = 18U; public: delivery_socket_type fd_{}; @@ -63,7 +64,7 @@ namespace snu::fix } template <int32_t AF, int32_t Kind, int32_t IPProto, int32_t Port> - bool construct(const char* addr = local_address, const bool& is_server = false) noexcept + bool construct(const char* addr = delivery_modem::local_address, const bool& is_server = false) noexcept { static_assert(AF != 0, "AF is zero"); static_assert(Kind != 0, "Kind is zero"); @@ -87,7 +88,7 @@ namespace snu::fix return ret == 0; } - ::listen(fd_, backlog_cnt); + ::listen(fd_, delivery_modem::backlog_count); return true; } diff --git a/dev/lib/fix/parser.hpp b/dev/lib/fix/parser.hpp index e007906..5e3bc3b 100644 --- a/dev/lib/fix/parser.hpp +++ b/dev/lib/fix/parser.hpp @@ -14,10 +14,14 @@ #include <string> #include <vector> +#include <sys/types.h> +#include <unistd.h> +#include <signal.h> + namespace snu::fix { template <typename char_type> - struct visitor; + struct basic_visitor; template <typename char_type> struct range; @@ -86,6 +90,7 @@ namespace snu::fix class range_data final { public: + std::size_t magic_len_; std::basic_string<char_type> magic_; std::size_t body_len_; std::vector<std::pair<std::basic_string<char_type>, std::basic_string<char_type>>> body_; @@ -127,20 +132,20 @@ namespace snu::fix } }; - /// @brief visitor object which returns a fix::range_data instance. + /// @brief basic_visitor object which returns a fix::range_data instance. template <typename char_type> - class visitor final + class basic_visitor final { public: static constexpr const char_type soh = '|'; static constexpr const char_type eq = '='; static constexpr uint32_t base = 10U; - explicit visitor() = default; - ~visitor() = default; + explicit basic_visitor() = default; + ~basic_visitor() = default; - visitor& operator=(const visitor&) = default; - visitor(const visitor&) = default; + basic_visitor& operator=(const basic_visitor&) = default; + basic_visitor(const basic_visitor&) = default; range<char_type> operator()(const std::basic_string<char_type>& in) { @@ -162,18 +167,19 @@ namespace snu::fix { for (auto& ch : in) { - if (ch != visitor::soh) + if (ch != basic_visitor::soh) { in_tmp += ch; continue; } - std::basic_string<char_type> key = in_tmp.substr(0, in_tmp.find(visitor::eq)); - std::basic_string<char_type> val = in_tmp.substr(in_tmp.find(visitor::eq) + 1); + std::basic_string<char_type> key = in_tmp.substr(0, in_tmp.find(basic_visitor::eq)); + std::basic_string<char_type> val = in_tmp.substr(in_tmp.find(basic_visitor::eq) + 1); if (ret.magic_.empty()) { - ret.magic_ = val; + ret.magic_ = val; + ret.magic_len_ = ret.magic_.size(); } else { @@ -194,6 +200,15 @@ namespace snu::fix return ret; } }; + + template <typename char_type = char> + inline void must_pass(range_data<char_type>& range) + { + if (!range.is_valid()) + { + ::kill(::getpid(), SIGTRAP); + } + } } // namespace snu::fix #endif // ifndef _SNU_FIX_PARSER_HPP diff --git a/dev/lib/memory/tracked_ptr.hpp b/dev/lib/memory/tracked_ptr.hpp index 1ff4cca..61ad685 100644 --- a/dev/lib/memory/tracked_ptr.hpp +++ b/dev/lib/memory/tracked_ptr.hpp @@ -12,6 +12,10 @@ #include <memory> #include <atomic> +#include <sys/types.h> +#include <unistd.h> +#include <signal.h> + namespace snu::memory { template <typename T> @@ -211,6 +215,9 @@ namespace snu::memory template <typename T> inline void must_pass(tracked_ptr<T>& ptr) noexcept { - assert(ptr.manager().allocator().allocated_count_ < ptr.manager().allocator().deallocated_count_); + if (ptr.manager().allocator().allocated_count_ < ptr.manager().allocator().deallocated_count_) + { + ::kill(::getpid(), SIGTRAP); + } } } // namespace snu::memory
\ No newline at end of file diff --git a/dev/lib/utility/cgi.hpp b/dev/lib/utility/cgi.hpp index 068adf1..bae31b8 100644 --- a/dev/lib/utility/cgi.hpp +++ b/dev/lib/utility/cgi.hpp @@ -16,12 +16,14 @@ namespace snu namespace cgi { /// @brief CGI Writer class, writes to stdout; as CGI expects. - class writer final + template <typename char_type = char> + class basic_writer { - writer& eval_(const std::string& mime, const std::stringstream& ss) noexcept + private: + basic_writer& eval_(const std::basic_string<char>& mime, const std::basic_stringstream<char_type>& ss) noexcept { std::printf("Content-Type: %s\r\n", mime.c_str()); - std::printf("Server: %s\r\n", "snu-cpp-library"); + std::printf("Server: %s\r\n", "socl-cgi-system"); std::printf("Content-Length: %ld\r\n\r\n", ss.str().size()); std::printf("%s", ss.str().c_str()); @@ -29,29 +31,34 @@ namespace snu } public: - explicit writer() = default; - ~writer() = default; + explicit basic_writer() = default; + ~basic_writer() = default; - writer& operator=(const writer&) = default; - writer(const writer&) = default; + basic_writer& operator=(const basic_writer&) = default; + basic_writer(const basic_writer&) = default; public: - writer& eval_html(const std::stringstream& ss_html) + basic_writer& binary(const std::basic_stringstream<char_type>& ss_html) + { + return this->eval_("application/octet-stream", ss_html); + } + + basic_writer& html(const std::basic_stringstream<char_type>& ss_html) { return this->eval_("text/html", ss_html); } - writer& eval_xml(const std::stringstream& ss_html) + basic_writer& xml(const std::basic_stringstream<char_type>& ss_html) { return this->eval_("application/xml", ss_html); } - writer& eval_json(const std::stringstream& ss_html) + basic_writer& json(const std::basic_stringstream<char_type>& ss_html) { return this->eval_("application/json", ss_html); } - writer& eval_js(const std::stringstream& ss_html) + basic_writer& js(const std::basic_stringstream<char_type>& ss_html) { return this->eval_("text/javascript", ss_html); } diff --git a/dev/lib/utility/embfs.hpp b/dev/lib/utility/embfs.hpp index cb08eb9..7d73d62 100644 --- a/dev/lib/utility/embfs.hpp +++ b/dev/lib/utility/embfs.hpp @@ -23,6 +23,7 @@ namespace snu::embfs inline constexpr const size_t _superblock_name_len = 16; inline constexpr const size_t _superblock_reserve_len = 462; + inline constexpr const size_t _inode_name_len = 128; inline constexpr const size_t _inode_arr_len = 12; inline constexpr const size_t _inode_lookup_len = 8; |
