1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
typedef enum {VQMSG_QUIT=1,
VQMSG_SYNC, /* set nodelist */
VQMSG_QUORUM, /* quorum state of this 'node' */
VQMSG_EXEC, /* message for exec_handler */
VQMSG_QDEVICE, /* quorum device enable/disable */
VQMSG_QUORUMQUIT, /* quit if you don't have quorum */
} vqsim_msg_type_t;
typedef struct vq_instance *vq_object_t;
struct vqsim_msg_header
{
vqsim_msg_type_t type;
int from_nodeid;
int param;
};
/* This is the sync sent from the controller process */
struct vqsim_sync_msg
{
struct vqsim_msg_header header;
struct memb_ring_id ring_id;
size_t view_list_entries;
unsigned int view_list[];
};
/* This is just info sent from each VQ instance */
struct vqsim_quorum_msg
{
struct vqsim_msg_header header;
int quorate;
struct memb_ring_id ring_id;
size_t view_list_entries;
unsigned int view_list[];
};
struct vqsim_exec_msg
{
struct vqsim_msg_header header;
char execmsg[];
};
struct vqsim_lib_msg
{
struct vqsim_msg_header header;
char libmsg[];
};
#define MAX_NODES 1024
#define MAX_PARTITIONS 16
/* In vq_object.c */
vq_object_t vq_create_instance(qb_loop_t *poll_loop, int nodeid);
void vq_quit(vq_object_t instance);
int vq_set_nodelist(vq_object_t instance, struct memb_ring_id *ring_id, int *nodeids, int nodeids_entries);
int vq_get_parent_fd(vq_object_t instance);
int vq_set_qdevice(vq_object_t instance, struct memb_ring_id *ring_id, int onoff);
int vq_quit_if_inquorate(vq_object_t instance);
pid_t vq_get_pid(vq_object_t instance);
/* in vqsim_vq_engine.c - effectively the constructor */
int fork_new_instance(int nodeid, int *vq_sock, pid_t *child_pid);
/* In parser.c */
void parse_input_command(char *cmd);
/* These are in vqmain.c */
int cmd_stop_node(int nodeid);
void cmd_stop_all_nodes(void);
int cmd_start_new_node(int nodeid, int partition);
void cmd_set_autofence(int onoff);
void cmd_set_sync(int onoff);
void cmd_set_assert(int onoff);
void cmd_move_nodes(int partition, int num_nodes, int *nodelist);
void cmd_join_partitions(int part1, int part2);
void cmd_update_all_partitions(int newring);
void cmd_qdevice_poll(int nodeid, int onoff);
void cmd_show_node_states(void);
void cmd_set_timeout(uint64_t seconds);
void cmd_start_sync_command(void);
void resume_kb_input(int show_state);
|
