feat(stack-coexist): route sendmsg/recvmsg/getpeername/getsockname/shutdown to kernel stack

Add 5 host bridges (ff_host_sendmsg/recvmsg/shutdown/getpeername/getsockname) and route them in ff_syscall_wrapper.c for managed kernel fds; ff_shutdown also dual-drives the dual-stack map fd like ff_close. All under FF_KERNEL_COEXIST. Verified: macro-on build rc=0 with symbols present, macro-off rc=0 size 6539682 byte-identical to baseline (zero regression); cmocka dual-mode (host 27/24, epoll 21, config 54/50) incl. new loopback bridge test; real-machine kernel-fd selftest PASS (getpeername/getsockname/sendmsg/recvmsg/shutdown end-to-end) and F-Stack fast path curl 200. Spec D8 converged (zh+en): these 5 now routed, readv/writev/ioctl remain known limitations.

Author: jfb8856606

docs/kernel_event_support_spec/02-current-state-analysis.md

@@ -12,7 +12,7 @@
 > - **hook cross-reference**: `fstack_kernel_fd_map[65536]` (`ff_hook_syscall.c:258`, bare array, lock-free, single-threaded poll); epoll dual-build merge (create `:1990-2000`, wait `:2324+`, close linkage `:1871-1884`); **socket/listen are NOT dual-built**.
 > - **native vs hook**: isomorphic (map / epoll merge / close linkage); divergent (socket/bind/listen/connect auto dual-build is v6-only).
 > - **v6 map gap (D9, grep verified)**: `grep ff_native_fd_map / ff_native_map_get/set/clear lib/` → 0 hits; `FF_MAX_FREEBSD_FILES` only in `ff_hook_syscall.c:257` and these docs. The v6 native map and default dual-build/dual-drive are NOT yet landed — to-be-implemented at R7. v6 adds (HOST_CFLAGS, `#ifdef FF_KERNEL_COEXIST`): `static int ff_native_fd_map[FF_MAX_FREEBSD_FILES]` + `ff_native_map_get/set/clear` in `ff_host_interface.{c,h}`, lock-free (modeled on hook).
-> - **D1-D8** code-doc inconsistencies fixed in §6 (D2 config parse line `:1027-1031` not `:956`; D3 no `default_stack`, `ff_api.h:91` comment stale; D4 header `unsigned int` vs impl `socklen_t`; D5 `ff_stack_get_stats` NOT implemented; D6 encode-offset + `ff_epoll_pairs`, not enum/ownership-table; D8 routing covers 13 entries, NOT `ff_readv/writev/send/recv/getpeername/getsockname/shutdown/ioctl/sendmsg/recvmsg`).
+> - **D1-D8** code-doc inconsistencies fixed in §6 (D2 config parse line `:1027-1031` not `:956`; D3 no `default_stack`, `ff_api.h:91` comment stale; D4 header `unsigned int` vs impl `socklen_t`; D5 `ff_stack_get_stats` NOT implemented; D6 encode-offset + `ff_epoll_pairs`, not enum/ownership-table; D8 R8 adds kernel routing for `sendmsg/recvmsg/getpeername/getsockname/shutdown` (first four single-stack hot-route, shutdown kernel-route + dual-stack dual-drive); `ff_readv/writev/ioctl` remain unrouted (known limitation)).
 
 ---
 

docs/kernel_event_support_spec/zh_cn/02-current-state-analysis.md

@@ -129,7 +129,7 @@
 | D5 | `ff_stack_stats`/`ff_stack_get_stats` **未实现**，标注待定 |
 | D6 | fd 区分=`FF_KERNEL_FD_BASE` 偏移 + `ff_epoll_pairs` 配对；v6 增 `ff_native_fd_map` 双栈映射（仍非 enum/归属表） |
 | D7 | 原生 v5 共存已落地（编译宏已包裹）；v6 在其上改默认语义为双栈 |
-| D8 | 路由仅 13 入口；`readv/writev/getpeername/getsockname/shutdown/ioctl/sendmsg/recvmsg` 等未加路由（已知限制）；v6 双栈 fd 对这些接口默认仅 F-Stack 驱动 |
+| D8 | R8 补齐 `sendmsg/recvmsg/getpeername/getsockname/shutdown` 内核路由（前 4 单栈热路由，shutdown 内核路由+双栈双驱动）；剩 `readv/writev/ioctl` 仍未加路由（已知限制），v6 双栈 fd 对其默认仅 F-Stack 驱动 |
 | **D9（v6）** | `ff_native_fd_map`/默认双建/双驱动**尚未实现**（§5.2 grep=0）——文档区分「v5 已实测」与「v6 待实现」，不当既成 |
 
 ---

docs/kernel_event_support_spec/zh_cn/05-interface-design.md

@@ -190,7 +190,8 @@ ff_connect(s, name, namelen)   s 为双栈 fd (ff_native_map_get(s)>0)
 | `ff_epoll_wait maxevents<1` | `-EINVAL`（`ff_epoll.c:221`） |
 | 内核/F-Stack 地址端口冲突 | 返回原生 errno（双栈某栈 bind 失败按部分失败契约处理） |
 | close 双栈 fd | 两栈 close + `ff_native_map_clear`；kqueue fd 清 `ff_epoll_pairs`（避免内核 fd 泄漏，FR-7） |
-| 双栈 fd 调用未路由接口 | `ff_readv/writev/getpeername/getsockname/shutdown/ioctl/sendmsg/recvmsg` 默认**仅 F-Stack 驱动**（D8 延伸已知限制） |
+| 内核 fd 调用 `sendmsg/recvmsg/getpeername/getsockname/shutdown` | R8 已加内核路由：前 4 内核 fd 走 `ff_host_*` 单栈；`shutdown` 内核 fd 走 host，双栈 map fd 两侧双驱动半关闭（仿 `ff_close`） |
+| 双栈 fd 调用未路由接口 | `ff_readv/writev/ioctl` 默认**仅 F-Stack 驱动**（D8 延伸已知限制） |
 
 ---
 

docs/kernel_event_support_spec/zh_cn/07-test-spec.md

@@ -113,7 +113,7 @@
   4. PERF-1/2/4 无回归。
   5. config 关/`SOCK_FSTACK`/宏关时与纯 F-Stack 一致（NFR-1/NFR-3）。
   6. **connect 契约确认**：`05 §6` 草案经用户确认后 UT-14/IT-9 方可定稿判 PASS。
-  7. D8 路由覆盖限制 + 双栈 fd 未路由接口仅 F-Stack 驱动须文档/用例明示。
+  7. R8 新增 `sendmsg/recvmsg/getpeername/getsockname/shutdown` 内核 fd 路由须单测覆盖；剩余 `readv/writev/ioctl` 仍为 D8 已知限制（双栈 fd 仅 F-Stack 驱动），须文档/用例明示。
 - 任一项失败 → bounce 打回上一里程碑（同步骤≤3 次，超限转人工）。
 
 ---

example/helloworld_stacksel/main.c

@@ -32,6 +32,7 @@
 #include <errno.h>
 #include <sys/types.h>
 #include <sys/socket.h>
+#include <sys/uio.h>
 #include <sys/wait.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
@@ -82,8 +83,31 @@ run_client(int port)
         ff_close(c);
         return 1;
     }
-    if (ff_send(c, "ping", 4, 0) != 4) {
-        perror("ff_send");
+
+    /* R8: exercise getpeername/getsockname on the kernel fd. */
+    struct sockaddr_in pn;
+    socklen_t pnlen = sizeof(pn);
+    if (ff_getpeername(c, (struct linux_sockaddr *)&pn, &pnlen) < 0 ||
+        ntohs(pn.sin_port) != (unsigned short)port) {
+        fprintf(stderr, "client: ff_getpeername mismatch\n");
+        ff_close(c);
+        return 1;
+    }
+    pnlen = sizeof(pn);
+    if (ff_getsockname(c, (struct linux_sockaddr *)&pn, &pnlen) < 0) {
+        perror("ff_getsockname");
+        ff_close(c);
+        return 1;
+    }
+
+    /* R8: send via ff_sendmsg. */
+    struct iovec io = { (void *)"ping", 4 };
+    struct msghdr mh;
+    memset(&mh, 0, sizeof(mh));
+    mh.msg_iov = &io;
+    mh.msg_iovlen = 1;
+    if (ff_sendmsg(c, &mh, 0) != 4) {
+        perror("ff_sendmsg");
         ff_close(c);
         return 1;
     }
@@ -105,9 +129,29 @@ run_server_once(int lfd)
         perror("ff_accept");
         return 1;
     }
-    ssize_t n = ff_recv(c, buf, sizeof(buf), 0);
+
+    /* R8: getpeername/getsockname on the accepted kernel fd. */
+    struct sockaddr_in pn;
+    socklen_t pnlen = sizeof(pn);
+    if (ff_getpeername(c, (struct linux_sockaddr *)&pn, &pnlen) < 0 ||
+        ff_getsockname(c, (struct linux_sockaddr *)&pn, &pnlen) < 0) {
+        perror("ff_get*name");
+        ff_close(c);
+        return 1;
+    }
+
+    /* R8: receive via ff_recvmsg. */
+    struct iovec io = { buf, sizeof(buf) };
+    struct msghdr mh;
+    memset(&mh, 0, sizeof(mh));
+    mh.msg_iov = &io;
+    mh.msg_iovlen = 1;
+    ssize_t n = ff_recvmsg(c, &mh, 0);
     if (n == 4 && memcmp(buf, "ping", 4) == 0)
         ff_send(c, "pong", 4, 0);
+
+    /* R8: half-close the write side via ff_shutdown. */
+    ff_shutdown(c, SHUT_WR);
     ff_close(c);
     return (n == 4) ? 0 : 1;
 }

lib/ff_host_interface.c

@@ -399,6 +399,36 @@ ff_host_epoll_wait(int epfd, void *events, int maxevents, int timeout)
 {
     return epoll_wait(epfd, (struct epoll_event *)events, maxevents, timeout);
 }
+
+ssize_t
+ff_host_sendmsg(int fd, const void *msg, int flags)
+{
+    return sendmsg(fd, (const struct msghdr *)msg, flags);
+}
+
+ssize_t
+ff_host_recvmsg(int fd, void *msg, int flags)
+{
+    return recvmsg(fd, (struct msghdr *)msg, flags);
+}
+
+int
+ff_host_shutdown(int fd, int how)
+{
+    return shutdown(fd, how);
+}
+
+int
+ff_host_getpeername(int fd, void *addr, socklen_t *addrlen)
+{
+    return getpeername(fd, (struct sockaddr *)addr, addrlen);
+}
+
+int
+ff_host_getsockname(int fd, void *addr, socklen_t *addrlen)
+{
+    return getsockname(fd, (struct sockaddr *)addr, addrlen);
+}
 #endif /* FF_KERNEL_COEXIST */
 
 void ff_os_errno(int error)

lib/ff_host_interface.h

@@ -167,6 +167,11 @@ int ff_host_fcntl(int fd, int cmd, int arg);
 int ff_host_epoll_create1(int flags);
 int ff_host_epoll_ctl(int epfd, int op, int fd, void *event);
 int ff_host_epoll_wait(int epfd, void *events, int maxevents, int timeout);
+ssize_t ff_host_sendmsg(int fd, const void *msg, int flags);
+ssize_t ff_host_recvmsg(int fd, void *msg, int flags);
+int ff_host_shutdown(int fd, int how);
+int ff_host_getpeername(int fd, void *addr, unsigned int *addrlen);
+int ff_host_getsockname(int fd, void *addr, unsigned int *addrlen);
 #endif /* FF_KERNEL_COEXIST */
 
 #endif

lib/ff_syscall_wrapper.c

@@ -1397,6 +1397,11 @@ ff_sendmsg(int s, const struct msghdr *msg, int flags)
     struct msghdr freebsd_msg;
     struct cmsghdr *freebsd_cmsg = NULL;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_is_kernel_fd(s))
+        return ff_host_sendmsg(ff_kernel_fd_real(s), msg, flags);
+#endif /* FF_KERNEL_COEXIST */
+
     freebsd_msg.msg_name = &freebsd_sa;
     if ((__DECONST(struct linux_msghdr *, msg))->msg_control) {
         freebsd_cmsg = malloc((__DECONST(struct linux_msghdr *, msg))->msg_controllen, NULL, 0);
@@ -1490,6 +1495,11 @@ ff_recvmsg(int s, struct msghdr *msg, int flags)
     int rc, ret;
     struct msghdr freebsd_msg;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_is_kernel_fd(s))
+        return ff_host_recvmsg(ff_kernel_fd_real(s), msg, flags);
+#endif /* FF_KERNEL_COEXIST */
+
     ret = linux2freebsd_msghdr((struct linux_msghdr *)msg, &freebsd_msg, 0);
     if (ret < 0) {
         rc = EINVAL;
@@ -1738,6 +1748,11 @@ ff_getpeername(int s, struct linux_sockaddr * name,
     struct sockaddr_storage pfss;
     struct sockaddr *pf = (struct sockaddr *)&pfss;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_is_kernel_fd(s))
+        return ff_host_getpeername(ff_kernel_fd_real(s), name, namelen);
+#endif /* FF_KERNEL_COEXIST */
+
     if ((rc = kern_getpeername(curthread, s, pf)))
         goto kern_fail;
 
@@ -1761,6 +1776,11 @@ ff_getsockname(int s, struct linux_sockaddr *name,
     struct sockaddr_storage pfss;
     struct sockaddr *pf = (struct sockaddr *)&pfss;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_is_kernel_fd(s))
+        return ff_host_getsockname(ff_kernel_fd_real(s), name, namelen);
+#endif /* FF_KERNEL_COEXIST */
+
     if ((rc = kern_getsockname(curthread, s, pf)))
         goto kern_fail;
 
@@ -1781,13 +1801,26 @@ ff_shutdown(int s, int how)
 {
     int rc;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_is_kernel_fd(s))
+        return ff_host_shutdown(ff_kernel_fd_real(s), how);
+#endif /* FF_KERNEL_COEXIST */
+
     struct shutdown_args sa = {
         .s = s,
         .how = how,
     };
     if ((rc = sys_shutdown(curthread, &sa)))
         goto kern_fail;
 
+#ifdef FF_KERNEL_COEXIST
+    if (ff_global_cfg.stack.kernel_coexist) {
+        int hfd = ff_native_map_get(s);
+        if (hfd > 0)
+            ff_host_shutdown(hfd, how);
+    }
+#endif /* FF_KERNEL_COEXIST */
+
     return (rc);
 kern_fail:
     ff_os_errno(rc);

tests/unit/test_ff_host_interface.c

@@ -613,6 +613,11 @@ test_ff_update_current_ts_assert_fail_on_clock_error(void **state)
 }
 
 #ifdef FF_KERNEL_COEXIST
+#include <sys/socket.h>
+#include <sys/uio.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
 /* Kernel-stack coexistence fd-space: a managed kernel fd is encoded as
  * (host_fd + FF_KERNEL_FD_BASE) and must never collide with FreeBSD fds
  * (< FF_KERNEL_FD_BASE). Verify the ff_is_kernel_fd/encode/real helpers. */
@@ -651,6 +656,68 @@ test_ff_native_fd_map(void **state)
     ff_native_map_set(-1, 5);
     ff_native_map_set(1 << 30, 5);
 }
+
+/*
+ * R8 host bridges: ff_host_sendmsg/recvmsg/getpeername/getsockname/shutdown.
+ * Drive them over a real loopback AF_INET TCP pair (no mock) so the bridge's
+ * direct host-libc passthrough is exercised end to end.
+ */
+static void
+test_ff_host_msg_name_shutdown_bridges(void **state)
+{
+    (void)state;
+    int ln = socket(AF_INET, SOCK_STREAM, 0);
+    assert_true(ln >= 0);
+    struct sockaddr_in sa;
+    memset(&sa, 0, sizeof(sa));
+    sa.sin_family = AF_INET;
+    sa.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
+    sa.sin_port = 0;
+    assert_int_equal(bind(ln, (struct sockaddr *)&sa, sizeof(sa)), 0);
+    assert_int_equal(listen(ln, 1), 0);
+
+    socklen_t slen = sizeof(sa);
+    assert_int_equal(getsockname(ln, (struct sockaddr *)&sa, &slen), 0);
+
+    int cli = socket(AF_INET, SOCK_STREAM, 0);
+    assert_true(cli >= 0);
+    assert_int_equal(connect(cli, (struct sockaddr *)&sa, sizeof(sa)), 0);
+    int srv = accept(ln, NULL, NULL);
+    assert_true(srv >= 0);
+
+    struct sockaddr_in pn;
+    socklen_t pnlen = sizeof(pn);
+    assert_int_equal(ff_host_getsockname(cli, &pn, &pnlen), 0);
+    assert_int_equal(pn.sin_addr.s_addr, htonl(INADDR_LOOPBACK));
+
+    pnlen = sizeof(pn);
+    assert_int_equal(ff_host_getpeername(cli, &pn, &pnlen), 0);
+    assert_int_equal(pn.sin_port, sa.sin_port);
+
+    char wbuf[] = "ping";
+    struct iovec wio = { wbuf, sizeof(wbuf) };
+    struct msghdr wmsg;
+    memset(&wmsg, 0, sizeof(wmsg));
+    wmsg.msg_iov = &wio;
+    wmsg.msg_iovlen = 1;
+    assert_int_equal(ff_host_sendmsg(cli, &wmsg, 0), (ssize_t)sizeof(wbuf));
+
+    char rbuf[16] = {0};
+    struct iovec rio = { rbuf, sizeof(rbuf) };
+    struct msghdr rmsg;
+    memset(&rmsg, 0, sizeof(rmsg));
+    rmsg.msg_iov = &rio;
+    rmsg.msg_iovlen = 1;
+    assert_int_equal(ff_host_recvmsg(srv, &rmsg, 0), (ssize_t)sizeof(wbuf));
+    assert_string_equal(rbuf, "ping");
+
+    assert_int_equal(ff_host_shutdown(cli, SHUT_WR), 0);
+    assert_int_equal(ff_host_recvmsg(srv, &rmsg, 0), 0);
+
+    ff_host_close(srv);
+    ff_host_close(cli);
+    ff_host_close(ln);
+}
 #endif /* FF_KERNEL_COEXIST */
 
 int
@@ -688,6 +755,7 @@ main(void)
 #ifdef FF_KERNEL_COEXIST
         cmocka_unit_test(test_ff_kernel_fd_encode_roundtrip),
         cmocka_unit_test(test_ff_native_fd_map),
+        cmocka_unit_test(test_ff_host_msg_name_shutdown_bridges),
 #endif /* FF_KERNEL_COEXIST */
     };
     return cmocka_run_group_tests(tests, NULL, NULL);