MCPcopy Create free account
hub / github.com/corosync/corosync / dispatch

Function dispatch

bindings/rust/src/cpg.rs:391–398  ·  view source on GitHub ↗

Call any/all active CPG callbacks for this [Handle] see [DispatchFlags] for details

(handle: &Handle, flags: DispatchFlags)

Source from the content-addressed store, hash-verified

389
390/// Call any/all active CPG callbacks for this [Handle] see [DispatchFlags] for details
391pub fn dispatch(handle: &Handle, flags: DispatchFlags) -> Result<()> {
392 let res = unsafe { ffi::cpg_dispatch(handle.cpg_handle, flags as u32) };
393 if res == ffi::CS_OK {
394 Ok(())
395 } else {
396 Err(CsError::from_c(res))
397 }
398}
399
400/// Joins a CPG group for sending and receiving messages
401pub fn join(handle: &Handle, group: &str) -> Result<()> {

Callers 6

dispatch_threadFunction · 0.50
mainFunction · 0.50
mainFunction · 0.50
mainFunction · 0.50
mainFunction · 0.50
mainFunction · 0.50

Calls 1

cpg_dispatchFunction · 0.85

Tested by 6

dispatch_threadFunction · 0.40
mainFunction · 0.40
mainFunction · 0.40
mainFunction · 0.40
mainFunction · 0.40
mainFunction · 0.40