#include <stdbool.h>
#include <stdint.h>
#include <sys/uio.h>
#include <sys/types.h>
#include <gnutls/gnutls.h>
#include <glib.h>
#include <libxml/tree.h>
#include <qb/qbipcs.h>
#include <crm_config.h>
#include <crm/common/ipc.h>
#include <crm/common/ipc_controld.h>
#include <crm/common/ipc_pacemakerd.h>
#include <crm/common/mainloop.h>

Include dependency graph for ipc_internal.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	pcmk__remote_s

struct	pcmk__client_s

Macros
#define	PCMK__SPECIAL_PID 1

#define	PCMK__IPC_TIMEOUT 120

#define	PCMK__SPECIAL_PID_AS_0(p) (p)

#define	PCMK__CLIENT_TYPE(client) ((client)->flags & UINT64_C(0xff00000000))

#define	pcmk__set_client_flags(client, flags_to_set)

#define	pcmk__clear_client_flags(client, flags_to_clear)

#define	pcmk__set_ipc_flags(ipc_flags, ipc_name, flags_to_set)

#define	pcmk__clear_ipc_flags(ipc_flags, ipc_name, flags_to_clear)

#define	pcmk__ipc_create_ack(flags, tag, ver, st) pcmk__ipc_create_ack_as(__func__, __LINE__, (flags), (tag), (ver), (st))

#define	pcmk__ipc_send_ack(c, req, flags, tag, ver, st) pcmk__ipc_send_ack_as(__func__, __LINE__, (c), (req), (flags), (tag), (ver), (st))

Typedefs
typedef struct pcmk__client_s	pcmk__client_t

Enumerations
enum	pcmk__client_flags { pcmk__client_ipc = (UINT64_C(1) << 32), pcmk__client_tcp = (UINT64_C(1) << 33), pcmk__client_tls = (UINT64_C(1) << 34), pcmk__client_proxied = (UINT64_C(1) << 40), pcmk__client_privileged = (UINT64_C(1) << 41), pcmk__client_to_proxy = (UINT64_C(1) << 42), pcmk__client_authenticated = (UINT64_C(1) << 43), pcmk__client_tls_handshake_complete = (UINT64_C(1) << 44) }

Functions
int	pcmk__ipc_is_authentic_process_active (const char name, uid_t refuid, gid_t refgid, pid_t gotpid)

int	pcmk__connect_generic_ipc (crm_ipc_t *ipc)

int	pcmk__ipc_fd (crm_ipc_t ipc, int fd)

int	pcmk__connect_ipc (pcmk_ipc_api_t *api, enum pcmk_ipc_dispatch dispatch_type, int attempts)

guint	pcmk__ipc_client_count (void)

void	pcmk__foreach_ipc_client (GHFunc func, gpointer user_data)

void	pcmk__client_cleanup (void)

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)

const char *	pcmk__client_type_str (uint64_t client_type)

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, gid_t gid)

void	pcmk__free_client (pcmk__client_t *c)

void	pcmk__drop_all_clients (qb_ipcs_service_t *s)

void	pcmk__set_client_queue_max (pcmk__client_t client, const char qmax)

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)

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_xml (pcmk__client_t c, uint32_t request, const xmlNode message, uint32_t flags)

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

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

int	pcmk__client_pid (qb_ipcs_connection_t *c)

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)

qb_ipcs_service_t *	pcmk__serve_controld_ipc (struct qb_ipcs_service_handlers *cb)

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)

const char *	pcmk__pcmkd_state_enum2friendly (enum pcmk_pacemakerd_state state)

const char *	pcmk__controld_api_reply2str (enum pcmk_controld_api_reply reply)

const char *	pcmk__pcmkd_api_reply2str (enum pcmk_pacemakerd_api_reply reply)

Macro Definition Documentation

◆ pcmk__clear_client_flags

#define pcmk__clear_client_flags	(	client,
		flags_to_clear
	)

Value:

do {           \
        (client)->flags = pcmk__clear_flags_as(__func__, __LINE__,      \
            LOG_TRACE,                                                  \
            "Client", pcmk__client_name(client),                        \
            (client)->flags, (flags_to_clear), #flags_to_clear);        \
    } while (0)

Definition at line 191 of file ipc_internal.h.

◆ pcmk__clear_ipc_flags

#define pcmk__clear_ipc_flags	(	ipc_flags,
		ipc_name,
		flags_to_clear
	)

Value:

do {     \
        ipc_flags = pcmk__clear_flags_as(__func__, __LINE__, LOG_TRACE,     \
                                         "IPC", (ipc_name),                 \
                                         (ipc_flags), (flags_to_clear),     \
                                         #flags_to_clear);                  \
    } while (0)

Definition at line 205 of file ipc_internal.h.

◆ PCMK__CLIENT_TYPE

#define PCMK__CLIENT_TYPE ( client ) ((client)->flags & UINT64_C(0xff00000000))

Definition at line 156 of file ipc_internal.h.

◆ pcmk__ipc_create_ack

#define pcmk__ipc_create_ack	(	flags,
		tag,
		ver,
		st
	)	pcmk__ipc_create_ack_as(__func__, __LINE__, (flags), (tag), (ver), (st))

Definition at line 230 of file ipc_internal.h.

◆ pcmk__ipc_send_ack

#define pcmk__ipc_send_ack	(	c,
		req,
		flags,
		tag,
		ver,
		st
	)	pcmk__ipc_send_ack_as(__func__, __LINE__, (c), (req), (flags), (tag), (ver), (st))

Definition at line 236 of file ipc_internal.h.

◆ PCMK__IPC_TIMEOUT

#define PCMK__IPC_TIMEOUT 120

Definition at line 44 of file ipc_internal.h.

◆ pcmk__set_client_flags

#define pcmk__set_client_flags	(	client,
		flags_to_set
	)

Value:

do {               \
        (client)->flags = pcmk__set_flags_as(__func__, __LINE__,        \
            LOG_TRACE,                                                  \
            "Client", pcmk__client_name(client),                        \
            (client)->flags, (flags_to_set), #flags_to_set);            \
    } while (0)

Definition at line 184 of file ipc_internal.h.

◆ pcmk__set_ipc_flags

#define pcmk__set_ipc_flags	(	ipc_flags,
		ipc_name,
		flags_to_set
	)

Value:

do {         \
        ipc_flags = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE,       \
                                       "IPC", (ipc_name),                   \
                                       (ipc_flags), (flags_to_set),         \
                                       #flags_to_set);                      \
    } while (0)

Definition at line 198 of file ipc_internal.h.

◆ PCMK__SPECIAL_PID

#define PCMK__SPECIAL_PID 1

Definition at line 41 of file ipc_internal.h.

◆ PCMK__SPECIAL_PID_AS_0

#define PCMK__SPECIAL_PID_AS_0 ( p ) (p)

Definition at line 53 of file ipc_internal.h.

Typedef Documentation

◆ pcmk__client_t

typedef struct pcmk__client_s pcmk__client_t

Definition at line 100 of file ipc_internal.h.

Enumeration Type Documentation

◆ pcmk__client_flags

enum pcmk__client_flags

Enumerator
pcmk__client_ipc	Client uses plain IPC.
pcmk__client_tcp	Client uses TCP connection.
pcmk__client_tls	Client uses TCP with TLS.
pcmk__client_proxied	Client IPC is proxied.
pcmk__client_privileged	Client is run by root or cluster user.
pcmk__client_to_proxy	Local client to be proxied.
pcmk__client_authenticated	Client IPC connection accepted. Used only for remote CIB connections via `PCMK_XA_REMOTE_TLS_PORT`.
pcmk__client_tls_handshake_complete	Client TLS handshake is complete.

Definition at line 120 of file ipc_internal.h.

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__client_type_str()

const char* pcmk__client_type_str ( uint64_t client_type )

Definition at line 122 of file ipc_common.c.

◆ pcmk__connect_generic_ipc()

int pcmk__connect_generic_ipc ( crm_ipc_t * ipc )

Definition at line 890 of file ipc_client.c.

◆ pcmk__connect_ipc()

int pcmk__connect_ipc	(	pcmk_ipc_api_t *	api,
		enum pcmk_ipc_dispatch	dispatch_type,
		int	attempts
	)

Definition at line 491 of file ipc_client.c.

◆ pcmk__controld_api_reply2str()

const char* pcmk__controld_api_reply2str ( enum pcmk_controld_api_reply reply )

Definition at line 45 of file ipc_controld.c.

◆ pcmk__drop_all_clients()

void pcmk__drop_all_clients ( qb_ipcs_service_t * s )

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_fd()

int pcmk__ipc_fd	(	crm_ipc_t *	ipc,
		int *	fd
	)

Definition at line 1001 of file ipc_client.c.

◆ pcmk__ipc_is_authentic_process_active()

int pcmk__ipc_is_authentic_process_active	(	const char *	name,
		uid_t	refuid,
		gid_t	refgid,
		pid_t *	gotpid
	)

Definition at line 1549 of file ipc_client.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,
		gid_t	gid
	)

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__pcmkd_api_reply2str()

const char* pcmk__pcmkd_api_reply2str ( enum pcmk_pacemakerd_api_reply reply )

Definition at line 110 of file ipc_pacemakerd.c.

◆ pcmk__pcmkd_state_enum2friendly()

const char* pcmk__pcmkd_state_enum2friendly ( enum pcmk_pacemakerd_state state )

Definition at line 75 of file ipc_pacemakerd.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.

Data Structures

Macros

Typedefs

Enumerations

Functions

Macro Definition Documentation

◆ pcmk__clear_client_flags

◆ pcmk__clear_ipc_flags

◆ PCMK__CLIENT_TYPE

◆ pcmk__ipc_create_ack

◆ pcmk__ipc_send_ack

◆ PCMK__IPC_TIMEOUT

◆ pcmk__set_client_flags

◆ pcmk__set_ipc_flags

◆ PCMK__SPECIAL_PID

◆ PCMK__SPECIAL_PID_AS_0

Typedef Documentation

◆ pcmk__client_t

Enumeration Type Documentation

◆ pcmk__client_flags

Function Documentation

◆ pcmk__client_cleanup()

◆ pcmk__client_data2xml()

◆ pcmk__client_name()

◆ pcmk__client_pid()

◆ pcmk__client_type_str()

◆ pcmk__connect_generic_ipc()

◆ pcmk__connect_ipc()

◆ pcmk__controld_api_reply2str()

◆ pcmk__drop_all_clients()

◆ pcmk__find_client()

◆ pcmk__find_client_by_id()

◆ pcmk__foreach_ipc_client()

◆ pcmk__free_client()

◆ pcmk__ipc_client_count()

◆ pcmk__ipc_create_ack_as()

◆ pcmk__ipc_fd()

◆ pcmk__ipc_is_authentic_process_active()

◆ pcmk__ipc_prepare_iov()

◆ pcmk__ipc_send_ack_as()

◆ pcmk__ipc_send_iov()

◆ pcmk__ipc_send_xml()

◆ pcmk__new_client()

◆ pcmk__new_unauth_client()

◆ pcmk__pcmkd_api_reply2str()

◆ pcmk__pcmkd_state_enum2friendly()

◆ pcmk__serve_attrd_ipc()

◆ pcmk__serve_based_ipc()

◆ pcmk__serve_controld_ipc()

◆ pcmk__serve_fenced_ipc()

◆ pcmk__serve_pacemakerd_ipc()

◆ pcmk__serve_schedulerd_ipc()

◆ pcmk__set_client_queue_max()

◆ pcmk__stop_based_ipc()