#include <crm_internal.h>
#include <stdio.h>
#include <errno.h>
#include <bzlib.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <crm/crm.h>
#include <crm/common/xml.h>
#include <crm/common/ipc.h>
#include <crm/common/ipc_internal.h>
#include "crmcommon_private.h"

Include dependency graph for ipc_server.c:

Macros
#define	PCMK_IPC_DEFAULT_QUEUE_MAX 500

Functions
guint	pcmk__ipc_client_count (void)

void	pcmk__foreach_ipc_client (GHFunc func, gpointer user_data)

pcmk__client_t *	pcmk__find_client (const qb_ipcs_connection_t *c)

pcmk__client_t *	pcmk__find_client_by_id (const char *id)

const char *	pcmk__client_name (const pcmk__client_t *c)

void	pcmk__client_cleanup (void)

void	pcmk__drop_all_clients (qb_ipcs_service_t *service)

pcmk__client_t *	pcmk__new_unauth_client (void *key)
	Allocate a new pcmk__client_t object and generate its ID. More...

pcmk__client_t *	pcmk__new_client (qb_ipcs_connection_t *c, uid_t uid_client, gid_t gid_client)

void	pcmk_free_ipc_event (struct iovec *event)
	Free an I/O vector created by pcmk__ipc_prepare_iov() More...

void	pcmk__free_client (pcmk__client_t *c)

void	pcmk__set_client_queue_max (pcmk__client_t client, const char qmax)

int	pcmk__client_pid (qb_ipcs_connection_t *c)

xmlNode *	pcmk__client_data2xml (pcmk__client_t c, void data, uint32_t id, uint32_t flags)

int	pcmk__ipc_prepare_iov (uint32_t request, const xmlNode message, uint32_t max_send_size, struct iovec result, ssize_t bytes)

int	pcmk__ipc_send_iov (pcmk__client_t c, struct iovec iov, uint32_t flags)

int	pcmk__ipc_send_xml (pcmk__client_t c, uint32_t request, const xmlNode message, uint32_t flags)

xmlNode *	pcmk__ipc_create_ack_as (const char function, int line, uint32_t flags, const char tag, const char *ver, crm_exit_t status)

int	pcmk__ipc_send_ack_as (const char function, int line, pcmk__client_t c, uint32_t request, uint32_t flags, const char tag, const char ver, crm_exit_t status)

void	pcmk__serve_based_ipc (qb_ipcs_service_t ipcs_ro, qb_ipcs_service_t ipcs_rw, qb_ipcs_service_t *ipcs_shm, struct qb_ipcs_service_handlers ro_cb, struct qb_ipcs_service_handlers *rw_cb)

void	pcmk__stop_based_ipc (qb_ipcs_service_t ipcs_ro, qb_ipcs_service_t ipcs_rw, qb_ipcs_service_t *ipcs_shm)

qb_ipcs_service_t *	pcmk__serve_controld_ipc (struct qb_ipcs_service_handlers *cb)

void	pcmk__serve_attrd_ipc (qb_ipcs_service_t *ipcs, struct qb_ipcs_service_handlers cb)

void	pcmk__serve_fenced_ipc (qb_ipcs_service_t *ipcs, struct qb_ipcs_service_handlers cb)

void	pcmk__serve_pacemakerd_ipc (qb_ipcs_service_t *ipcs, struct qb_ipcs_service_handlers cb)

qb_ipcs_service_t *	pcmk__serve_schedulerd_ipc (struct qb_ipcs_service_handlers *cb)

Macro Definition Documentation

◆ PCMK_IPC_DEFAULT_QUEUE_MAX

#define PCMK_IPC_DEFAULT_QUEUE_MAX 500

Definition at line 25 of file ipc_server.c.

Function Documentation

◆ pcmk__client_cleanup()

void pcmk__client_cleanup ( void )

Definition at line 115 of file ipc_server.c.

◆ pcmk__client_data2xml()

xmlNode* pcmk__client_data2xml	(	pcmk__client_t *	c,
		void *	data,
		uint32_t *	id,
		uint32_t *	flags
	)

Definition at line 396 of file ipc_server.c.

◆ pcmk__client_name()

const char* pcmk__client_name ( const pcmk__client_t * c )

Definition at line 98 of file ipc_server.c.

◆ pcmk__client_pid()

int pcmk__client_pid ( qb_ipcs_connection_t * c )

Definition at line 375 of file ipc_server.c.

◆ pcmk__drop_all_clients()

void pcmk__drop_all_clients ( qb_ipcs_service_t * service )

Definition at line 130 of file ipc_server.c.

◆ pcmk__find_client()

pcmk__client_t* pcmk__find_client ( const qb_ipcs_connection_t * c )

Definition at line 59 of file ipc_server.c.

◆ pcmk__find_client_by_id()

pcmk__client_t* pcmk__find_client_by_id ( const char * id )

Definition at line 70 of file ipc_server.c.

◆ pcmk__foreach_ipc_client()

void pcmk__foreach_ipc_client	(	GHFunc	func,
		gpointer	user_data
	)

Definition at line 51 of file ipc_server.c.

◆ pcmk__free_client()

void pcmk__free_client ( pcmk__client_t * c )

Definition at line 284 of file ipc_server.c.

◆ pcmk__ipc_client_count()

guint pcmk__ipc_client_count ( void )

Definition at line 36 of file ipc_server.c.

◆ pcmk__ipc_create_ack_as()

xmlNode* pcmk__ipc_create_ack_as	(	const char *	function,
		int	line,
		uint32_t	flags,
		const char *	tag,
		const char *	ver,
		crm_exit_t	status
	)

Definition at line 804 of file ipc_server.c.

◆ pcmk__ipc_prepare_iov()

int pcmk__ipc_prepare_iov	(	uint32_t	request,
		const xmlNode *	message,
		uint32_t	max_send_size,
		struct iovec **	result,
		ssize_t *	bytes
	)

Definition at line 592 of file ipc_server.c.

◆ pcmk__ipc_send_ack_as()

int pcmk__ipc_send_ack_as	(	const char *	function,
		int	line,
		pcmk__client_t *	c,
		uint32_t	request,
		uint32_t	flags,
		const char *	tag,
		const char *	ver,
		crm_exit_t	status
	)

Definition at line 835 of file ipc_server.c.

◆ pcmk__ipc_send_iov()

int pcmk__ipc_send_iov	(	pcmk__client_t *	c,
		struct iovec *	iov,
		uint32_t	flags
	)

Definition at line 686 of file ipc_server.c.

◆ pcmk__ipc_send_xml()

int pcmk__ipc_send_xml	(	pcmk__client_t *	c,
		uint32_t	request,
		const xmlNode *	message,
		uint32_t	flags
	)

Definition at line 765 of file ipc_server.c.

◆ pcmk__new_client()

pcmk__client_t* pcmk__new_client	(	qb_ipcs_connection_t *	c,
		uid_t	uid_client,
		gid_t	gid_client
	)

Definition at line 209 of file ipc_server.c.

◆ pcmk__new_unauth_client()

pcmk__client_t* pcmk__new_unauth_client ( void * key )

Allocate a new pcmk__client_t object and generate its ID.

Parameters

[in] key What to use as connections hash table key (NULL to use ID)

Returns: Pointer to new pcmk__client_t (asserts on failure)

Definition at line 203 of file ipc_server.c.

◆ pcmk__serve_attrd_ipc()

void pcmk__serve_attrd_ipc	(	qb_ipcs_service_t **	ipcs,
		struct qb_ipcs_service_handlers *	cb
	)

Definition at line 934 of file ipc_server.c.

◆ pcmk__serve_based_ipc()

void pcmk__serve_based_ipc	(	qb_ipcs_service_t **	ipcs_ro,
		qb_ipcs_service_t **	ipcs_rw,
		qb_ipcs_service_t **	ipcs_shm,
		struct qb_ipcs_service_handlers *	ro_cb,
		struct qb_ipcs_service_handlers *	rw_cb
	)

Definition at line 867 of file ipc_server.c.

◆ pcmk__serve_controld_ipc()

qb_ipcs_service_t* pcmk__serve_controld_ipc ( struct qb_ipcs_service_handlers * cb )

Definition at line 919 of file ipc_server.c.

◆ pcmk__serve_fenced_ipc()

void pcmk__serve_fenced_ipc	(	qb_ipcs_service_t **	ipcs,
		struct qb_ipcs_service_handlers *	cb
	)

Definition at line 957 of file ipc_server.c.

◆ pcmk__serve_pacemakerd_ipc()

void pcmk__serve_pacemakerd_ipc	(	qb_ipcs_service_t **	ipcs,
		struct qb_ipcs_service_handlers *	cb
	)

Definition at line 980 of file ipc_server.c.

◆ pcmk__serve_schedulerd_ipc()

qb_ipcs_service_t* pcmk__serve_schedulerd_ipc ( struct qb_ipcs_service_handlers * cb )

Definition at line 1007 of file ipc_server.c.

◆ pcmk__set_client_queue_max()

void pcmk__set_client_queue_max	(	pcmk__client_t *	client,
		const char *	qmax
	)

Definition at line 339 of file ipc_server.c.

◆ pcmk__stop_based_ipc()

void pcmk__stop_based_ipc	(	qb_ipcs_service_t *	ipcs_ro,
		qb_ipcs_service_t *	ipcs_rw,
		qb_ipcs_service_t *	ipcs_shm
	)

Definition at line 901 of file ipc_server.c.

◆ pcmk_free_ipc_event()

void pcmk_free_ipc_event ( struct iovec * event )

Free an I/O vector created by pcmk__ipc_prepare_iov()