lei.chen/myxce
1
0
Fork 1
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(ha-wal-replication): repl_broadcast TCP send (task 1.1)

Browse source 
Replace no-send stub with real WAL entry transmission via
xce_wal_batch_req_raw. For each non-catch-up registered standby,
serialize the entry header+payload into a wal_catchup_entry_t
and enqueue. Keep the MAX_PENDING_ACKS eviction guard.

5 new tests: no-standbys, one-standby-send, skip-catch-up,
evict-overloaded, send-failure-continues. Controller suite green.

Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Rongsong Shen 2026-06-10 08:11:05 +00:00
parent cdd446fc17
commit 18e351ee1b
7 changed files with 780 additions and 91 deletions
Download patch file Download diff file Expand all files Collapse all files

37
.wolf/anatomy.md
View file

@ -1,7 +1,11 @@
# anatomy.md
> Auto-maintained by OpenWolf. Last scanned: 2026-06-10T01:00:00.579Z
> Files: 505 tracked | Anatomy hits: 0 | Misses: 0
> Auto-maintained by OpenWolf. Last scanned: 2026-06-10T04:02:07.082Z
> Files: 511 tracked | Anatomy hits: 0 | Misses: 0
## ../../../../../../tmp/
- `e2e-task-7-7.sh` — E2E for ha-repl-hardening task 7.7 — entity-state (snapshot payload) assertion. (~1171 tok)
## ./
@ -466,13 +470,13 @@
- `.ha.c.~undo-tree~` — Declares xce_cluster_config_t (~40575 tok)
- `apiserver.c` — include <errno.h> (~5303 tok)
- `CLAUDE.md` — XCE Controller (~2630 tok)
- `cluster.c` — include "config.h" (~13092 tok)
- `config_repl.c` — define _GNU_SOURCE (~15780 tok)
- `cluster.c` — include "config.h" (~12336 tok)
- `config_repl.c` — define _GNU_SOURCE (~14877 tok)
- `config_repl.h` — pragma once (~2658 tok)
- `ctrl_metrics.c` — include "ctrl_metrics.h" (~767 tok)
- `dataex.c` — include <errno.h> (~2466 tok)
- `ha.c` — define _GNU_SOURCE (~42722 tok)
- `ha.h` — ifndef HA_H (~10718 tok)
- `ha.c` — define _GNU_SOURCE (~40638 tok)
- `ha.h` — ifndef HA_H (~10066 tok)
- `job.c` — include <errno.h> (~8259 tok)
- `join.c` — include "config.h" (~2514 tok)
- `main.c` — include <argp.h> (~2262 tok)
@ -512,7 +516,7 @@
- `test_ha_bootstrap_support.c` — ifdef XCE_TESTING (~1080 tok)
- `test_ha_bootstrap.c` — does: defer_config_fetch (~6244 tok)
- `test_ha_cluster.c` — include <stdatomic.h> (~1351 tok)
- `test_ha_connection_reuse.c` — define _GNU_SOURCE (~6754 tok)
- `test_ha_connection_reuse.c` — define _GNU_SOURCE (~6320 tok)
- `test_ha_ctrlhello.c` (~1416 tok)
- `test_ha_durability.c` — Declares char (~4366 tok)
- `test_ha_election.c` — Declares char (~11940 tok)
@ -523,7 +527,7 @@
- `test_ha_redirect.c` — include <stdatomic.h> (~905 tok)
- `test_ha_repl_ack.c` (~3314 tok)
- `test_ha_repl_push.c` — Declares is (~3020 tok)
- `test_ha_role.c` — include <signal.h> (~10340 tok)
- `test_ha_role.c` — include <signal.h> (~10563 tok)
- `test_ha_start_election_async.c` — Declares returns (~2097 tok)
- `test_ha_startup.c` — Declares char (~9207 tok)
- `test_ha_vote_gate.c` — define _GNU_SOURCE (~2934 tok)
@ -864,3 +868,20 @@
- `config.go` — APIServerInfo (64 fields); methods: Len, Swap, Less, GetConfig (~1607 tok)
- `logger.go` — LoggerConfig (48 fields) (~1877 tok)
- `logger.yaml` (~205 tok)
## src/include/
- `request.h` — if !defined(_REQUEST_H_) (~2674 tok)
- `typemap.h` — if !defined(_TYPEMAP_H_) (~3873 tok)
## src/lib/
- `request.c` — include <errno.h> (~15394 tok)
## src/lib/testsuite/
- `test_wal_wire.c` — include <errno.h> (~2162 tok)
## src/schema/
- `controller.capnp` — Declares OPCode (~8251 tok)