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

Function sync_abort

exec/sync.c:535–549  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

533}
534
535void sync_abort (void)
536{
537 ENTER();
538 if (my_state == SYNC_PROCESS) {
539 schedwrk_destroy (my_schedwrk_handle);
540 if (my_sync_callbacks_retrieve(my_service_list[my_processing_idx].service_id, NULL) != -1) {
541 my_service_list[my_processing_idx].sync_abort ();
542 }
543 }
544
545 /* this will cause any "old" barrier messages from causing
546 * problems.
547 */
548 memset (&my_ring_id, 0, sizeof (struct memb_ring_id));
549}

Callers 1

confchg_fnFunction · 0.85

Calls 1

schedwrk_destroyFunction · 0.85

Tested by

no test coverage detected