#include <config.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <sys/ioctl.h>
#include <netinet/in.h>
#include <sys/uio.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <time.h>
#include <arpa/inet.h>
#include <corosync/corotypes.h>
#include <corosync/swab.h>
#include <corosync/totem/totempg.h>
#include <corosync/totem/totem.h>
#include <corosync/logsys.h>
#include <qb/qbipc_common.h>
#include "schedwrk.h"
#include "quorum.h"
#include "sync.h"
#include "main.h"
Go to the source code of this file.
#define MESSAGE_REQ_SYNC_BARRIER 0 |
#define MESSAGE_REQ_SYNC_MEMB_DETERMINE 2 |
#define MESSAGE_REQ_SYNC_SERVICE_BUILD 1 |
Enumerator |
---|
INIT |
|
PROCESS |
|
ACTIVATE |
|
Definition at line 69 of file sync.c.
Enumerator |
---|
SYNC_SERVICELIST_BUILD |
|
SYNC_PROCESS |
|
SYNC_BARRIER |
|
Definition at line 75 of file sync.c.
LOGSYS_DECLARE_SUBSYS |
( |
"SYNC" |
| ) |
|
int sync_init |
( |
int(*)(int service_id, struct sync_callbacks *callbacks) |
sync_callbacks_retrieve, |
|
|
void(*)(void) |
synchronization_completed |
|
) |
| |
Definition at line 175 of file sync.c.
References ACTIVATE, header, INIT, log_printf, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, MESSAGE_REQ_SYNC_BARRIER, MESSAGE_REQ_SYNC_MEMB_DETERMINE, MESSAGE_REQ_SYNC_SERVICE_BUILD, my_sync_callbacks_retrieve, sync_callbacks::name, service_entry::name, nodeid, processor_entry::nodeid, PROCESS, PROCESSOR_COUNT_MAX, processor_entry::received, ring_id, schedwrk_create(), service_entry::service_id, SERVICES_COUNT_MAX, service_entry::state, sync_callbacks::sync_abort, service_entry::sync_abort, sync_callbacks::sync_activate, service_entry::sync_activate, SYNC_BARRIER, sync_callbacks::sync_init, service_entry::sync_init, sync_callbacks::sync_process, SYNC_PROCESS, service_entry::sync_process, SYNC_SERVICELIST_BUILD, TOTEMPG_AGREED, totempg_groups_initialize(), totempg_groups_join(), and totempg_groups_mcast_joined().
void sync_memb_list_abort |
( |
void |
| ) |
|
void sync_memb_list_determine |
( |
const struct memb_ring_id * |
ring_id | ) |
|
void sync_save_transitional |
( |
const unsigned int * |
member_list, |
|
|
size_t |
member_list_entries, |
|
|
const struct memb_ring_id * |
ring_id |
|
) |
| |
void sync_start |
( |
const unsigned int * |
member_list, |
|
|
size_t |
member_list_entries, |
|
|
const struct memb_ring_id * |
ring_id |
|
) |
| |
int(* my_sync_callbacks_retrieve) (int service_id, struct sync_callbacks *callbacks) |