Yuan Jing Vincent Yan

C Client API (Wrapper over the C++ API)

10

### Is there an existing proposal for this? - [X] I have searched the existing proposals ### Is your feature request related to a problem? C API is very useful...

This series of changes improved the thread safety of components integral to the FSM mode, including `mqbc::StorageManager`, `mqbc::RecoveryManager`, and other neighboring components.

We had a journal file inconsistency bug if a replica node contains a purge appId record preceding a removal record for that appId, and bounces before rollover. Primary, who rolled...

Fix [MQB]: mqbc::StorageMgr: Transition to available only when all primary active

1

Fixes two flaky integration tests in FSM mode: 1. In [`test_basic` of `test_restart.py`](https://github.com/bloomberg/blazingmq/blob/bd72cb45958abea96adb947c2f5e0c2bc95df94f/src/integration-tests/test_restart.py#L61), there was an issue where a replica could advertise availability before all primaries are active; then, a...

### Is there an existing proposal for this? - [X] I have searched the existing proposals ### Is your feature request related to a problem? Currently, we have an implicit...

Feat FSM mode: Still write to QList file

1

In the existing code, FSM mode *never* writes to QList file. In this PR, we add a new `doesFSMWriteQLIST` flag to determine whether FSM mode still writes to QList file....

Leader message sequence out-of-sync when opening queue to cluster with 92.8 and 93.15 mix

1

### Is there an existing issue for this? - [x] I have searched the existing issues ### Current Behavior I observe this alarm: ``` 04APR2025_21:00:31.928 (6181072896) ERROR mqbblp_clusterstatemanager.cpp:1575 ALARM [CLUSTER_STATE]...

Fix for Internal Ticket 181406010

Facilitates https://github.com/bloomberg/blazingmq/pull/1001 to have quorum as unsigned int. NOTE: No need to merge this PR because https://github.com/bloomberg/blazingmq/pull/1001 already incorporates this commit.

Fixes the flaky [`test_replica_late_join`](https://github.com/bloomberg/blazingmq/blob/32601ea3155fefd78a6744310314f5e754b33411/src/integration-tests/test_startup.py#L70) in legacy mode. A couple remarks: 1. Choosing an available peer randomly is **dangerous**, thus I am also guarding this code path behind the retry loop....