Page MenuHomeClusterLabs Projects
Files F3153593

vqsim.h
No OneTemporary
Actions

vqsim.h
View Options

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);

File Metadata

Mime Type
text/x-c
Expires
Tue, Feb 25, 10:40 PM (1 d, 7 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1447883
Default Alt Text
vqsim.h (2 KB)

Event Timeline