 qing
|
1d44e0dcb8
|
feat(libmsg): add pymsg C++ library with AsyncQueue, MsgServer, and JSON RPC layer
- Add libmsg module: pymsg protocol implementation (4-byte BE length prefix + UTF-8)
- Add AsyncQueue<T>: generic async batch queue with backpressure (aligned with Python AsyncRpcQueue)
- Add MsgServer: select-based multi-client TCP server with optional thread pool
- Add RpcClient/RpcServer: JSON RPC convention layer with automatic route injection
- Refactor gateway/LogC.hpp to use AsyncQueue for async batch log delivery
- Update gateway/DbC.hpp to add call_msg() using pymsg TCP protocol
- Remove duplicated gateway/inc/Msg.hpp (now provided by libmsg)
- Update gateway/Makefile and _inst.sh build order
Fixes included:
- pmsg_send size check uses kMaxMsgSize (64MiB) instead of 4GiB
- MsgClient._running uses std::atomic<bool> for thread safety
- Deadline-based recv timeout to prevent Slowloris (header+payload shared deadline)
|
2026-08-06 23:48:06 +08:00 |
|
|
qing
|
55fbe2f1f1
|
feat(confs): 统一配置服务（pymsg/TCP :8010）
- confs.py 重写为统一配置服务：get/list/reload/health 路由，
内存缓存 + mtime 自动重载，路径遍历防护，ini/json 按键提取
- 复制 log_client.py，新增 configs/example.ini 示例配置
- 注册到 core/init.txt（db 之后启动）与 _inst.sh 安装序列
|
2026-08-01 02:15:04 +08:00 |
|
|
qing
|
f935448389
|
refix
|
2026-07-30 21:33:03 +08:00 |
|
 shufeng2012
|
957981c2c3
|
🍱 更新脚本
|
2026-07-26 20:57:04 +08:00 |
|
|
qing
|
202f2804b2
|
增加waf模块
|
2026-07-25 01:27:08 +08:00 |
|
|
shufeng2012
|
80d20f5015
|
解决冲突（这啥呀）
|
2026-07-24 14:46:26 +08:00 |
|
|
shufeng2012
|
4046ef8dc8
|
refix
|
2026-07-24 07:01:43 +08:00 |
|
|
shufeng2012
|
67ece6b5b9
|
^-^
|
2026-07-23 17:23:11 +08:00 |
|
|
qing
|
f2e2e59977
|
准备dnfs模块
|
2026-07-22 10:13:10 +08:00 |
|
|
qing
|
5d2f1499aa
|
modified
|
2026-07-20 11:36:18 +08:00 |
|
|
qing
|
70d467d052
|
init
|
2026-07-20 11:12:29 +08:00 |
|