Commit Graph

6 Commits (b66ef12c2ef1fd6d0b7d81c1f3eaa6ac380ab36e)

Author SHA1 Message Date
Guillermo Rodriguez 8f400f6524
Better APIs for ringd and pubsub
Pubsub:
Remove un-necesary ChannelManager locking mechanism
Make ChannelManager.close wait for all channel removals
Make publisher turn switch configurable with `msgs_per_turn` variable
Fix batch_size setter on publisher
Add broadcast to publisher
Add endpoints on pubsub for remote actors to dynamically add and remove channels

Ringd:
Add fifo lock and use it on methods that modify _rings state
Add comments
Break up ringd.open_ringbuf apis into attach_, open_ & maybe_open_
When attaching its no longer a long running context, only on opens
Adapt ringd test to new apis
2025-04-10 13:13:08 -03:00
Guillermo Rodriguez 5fbd6aced7
Fix test docstring 2025-04-04 02:59:50 -03:00
Guillermo Rodriguez 1c5bebfca6
Enable ordering assertion & simplify some parts of test 2025-04-04 02:57:38 -03:00
Guillermo Rodriguez 3c1873c68a
Fully test and fix bugs on _ringbuf._pubsub
Add generic channel orderer
2025-04-04 02:44:45 -03:00
Guillermo Rodriguez 0b9c2de3ad
Improve ringd ringbuf lifecycle
Unlink sock after use in fdshare
2025-04-04 02:41:50 -03:00
Guillermo Rodriguez 739e728065
Add ringd test, which also tests fd share 2025-04-02 14:45:21 -03:00