mirror of
https://git.proxmox.com/git/mirror_corosync
synced 2025-10-04 14:57:17 +00:00
71e885d7f9
vqsim is a small program that allows node up/down/split/join operations to be simulated without the use of an actual cluster. Signed-off-by: Christine Caulfield <ccaulfie@redhat.com>
122 lines
2.4 KiB
C
122 lines
2.4 KiB
C
/*
|
|
This is a Votequorum object in the parent process. it's really just a conduit for the forked
|
|
votequorum entity
|
|
*/
|
|
|
|
#include <qb/qblog.h>
|
|
#include <qb/qbloop.h>
|
|
#include <qb/qbipcc.h>
|
|
#include <netinet/in.h>
|
|
|
|
#include "../exec/votequorum.h"
|
|
#include "vqsim.h"
|
|
|
|
struct vq_instance
|
|
{
|
|
int nodeid;
|
|
int vq_socket;
|
|
pid_t pid;
|
|
};
|
|
|
|
vq_object_t vq_create_instance(qb_loop_t *poll_loop, int nodeid)
|
|
{
|
|
struct vq_instance *instance = malloc(sizeof(struct vq_instance));
|
|
if (!instance) {
|
|
return NULL;
|
|
}
|
|
|
|
instance->nodeid = nodeid;
|
|
|
|
if (fork_new_instance(nodeid, &instance->vq_socket, &instance->pid)) {
|
|
free(instance);
|
|
return NULL;
|
|
}
|
|
|
|
return instance;
|
|
}
|
|
|
|
pid_t vq_get_pid(vq_object_t instance)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
return vqi->pid;
|
|
}
|
|
|
|
void vq_quit(vq_object_t instance)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
struct vqsim_msg_header msg;
|
|
int res;
|
|
|
|
msg.type = VQMSG_QUIT;
|
|
msg.from_nodeid = 0;
|
|
msg.param = 0;
|
|
|
|
res = write(vqi->vq_socket, &msg, sizeof(msg));
|
|
if (res <= 0) {
|
|
perror("Quit write failed");
|
|
}
|
|
}
|
|
|
|
int vq_quit_if_inquorate(vq_object_t instance)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
struct vqsim_msg_header msg;
|
|
int res;
|
|
|
|
msg.type = VQMSG_QUORUMQUIT;
|
|
msg.from_nodeid = 0;
|
|
msg.param = 0;
|
|
|
|
res = write(vqi->vq_socket, &msg, sizeof(msg));
|
|
if (res <= 0) {
|
|
perror("Quit write failed");
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int vq_set_nodelist(vq_object_t instance, struct memb_ring_id *ring_id, int *nodeids, int nodeids_entries)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
char msgbuf[sizeof(int)*nodeids_entries + sizeof(struct vqsim_sync_msg)];
|
|
struct vqsim_sync_msg *msg = (void*)msgbuf;
|
|
int res;
|
|
|
|
msg->header.type = VQMSG_SYNC;
|
|
msg->header.from_nodeid = 0;
|
|
msg->header.param = 0;
|
|
msg->view_list_entries = nodeids_entries;
|
|
memcpy(&msg->view_list, nodeids, nodeids_entries*sizeof(int));
|
|
memcpy(&msg->ring_id, ring_id, sizeof(struct memb_ring_id));
|
|
|
|
res = write(vqi->vq_socket, msgbuf, sizeof(msgbuf));
|
|
if (res <= 0) {
|
|
perror("Sync write failed");
|
|
return -1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int vq_set_qdevice(vq_object_t instance, struct memb_ring_id *ring_id, int onoff)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
struct vqsim_msg_header msg;
|
|
int res;
|
|
|
|
msg.type = VQMSG_QDEVICE;
|
|
msg.from_nodeid = 0;
|
|
msg.param = onoff;
|
|
res = write(vqi->vq_socket, &msg, sizeof(msg));
|
|
if (res <= 0) {
|
|
perror("qdevice register write failed");
|
|
return -1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int vq_get_parent_fd(vq_object_t instance)
|
|
{
|
|
struct vq_instance *vqi = instance;
|
|
|
|
return vqi->vq_socket;
|
|
}
|