Infrastructure for multicast/multi_subnet
Notes:
Current design
-
clientrefers to a remote node with memory region. -
serverrefers to this node. On dissemination nodeserverissues the write/push/disseminate command. On delivery nodeserverpolls the cq for write-with-imm data and updateKappaStreamInfowith new serial number. - Each
clienthas its own pd, qp, cq and cq thread. -
KappaStreamInfokeeps track of memory for a stream. -
KappaDeliveryWorker::DeliverVideocalculates the circular buffer metadata on delivery based on last serial number.
Todos:
-
Update KappaStreamInfoto refers to video buffer asiovecs. -
Synchronization mechanism for multicast?