![]() |
pacemaker
2.0.4-2deceaa3ae
Scalable High-Availability cluster resource manager
|
#include <stdbool.h>
#include <qb/qbipcs.h>
#include <crm/common/ipc.h>
#include <crm/common/mainloop.h>
Go to the source code of this file.
Data Structures | |
struct | pcmk__remote_s |
struct | pcmk__client_s |
Macros | |
#define | pcmk__ipc_send_ack(c, req, flags, tag) pcmk__ipc_send_ack_as(__FUNCTION__, __LINE__, (c), (req), (flags), (tag)) |
Typedefs | |
typedef struct pcmk__client_s | pcmk__client_t |
Enumerations | |
enum | pcmk__client_type { PCMK__CLIENT_IPC = 1, PCMK__CLIENT_TCP = 2 } |
enum | pcmk__client_flags { pcmk__client_proxied = 0x00001, pcmk__client_privileged = 0x00002 } |
Functions | |
guint | pcmk__ipc_client_count (void) |
void | pcmk__foreach_ipc_client (GHFunc func, gpointer user_data) |
void | pcmk__foreach_ipc_client_remove (GHRFunc func, gpointer user_data) |
void | pcmk__client_cleanup (void) |
pcmk__client_t * | pcmk__find_client (qb_ipcs_connection_t *c) |
pcmk__client_t * | pcmk__find_client_by_id (const char *id) |
const char * | pcmk__client_name (pcmk__client_t *c) |
const char * | pcmk__client_type_str (enum pcmk__client_type 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) |
bool | pcmk__set_client_queue_max (pcmk__client_t *client, const char *qmax) |
void | pcmk__ipc_send_ack_as (const char *function, int line, pcmk__client_t *c, uint32_t request, uint32_t flags, const char *tag) |
int | pcmk__ipc_prepare_iov (uint32_t request, 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, 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) |
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) |
#define pcmk__ipc_send_ack | ( | c, | |
req, | |||
flags, | |||
tag | |||
) | pcmk__ipc_send_ack_as(__FUNCTION__, __LINE__, (c), (req), (flags), (tag)) |
Definition at line 115 of file ipcs_internal.h.
typedef struct pcmk__client_s pcmk__client_t |
Definition at line 27 of file ipcs_internal.h.
enum pcmk__client_flags |
Enumerator | |
---|---|
pcmk__client_proxied | |
pcmk__client_privileged |
Definition at line 57 of file ipcs_internal.h.
enum pcmk__client_type |
Enumerator | |
---|---|
PCMK__CLIENT_IPC | |
PCMK__CLIENT_TCP |
Definition at line 29 of file ipcs_internal.h.
xmlNode* pcmk__client_data2xml | ( | pcmk__client_t * | c, |
void * | data, | ||
uint32_t * | id, | ||
uint32_t * | flags | ||
) |
const char* pcmk__client_name | ( | pcmk__client_t * | c | ) |
const char* pcmk__client_type_str | ( | enum pcmk__client_type | client_type | ) |
pcmk__client_t* pcmk__find_client | ( | qb_ipcs_connection_t * | c | ) |
pcmk__client_t* pcmk__find_client_by_id | ( | const char * | id | ) |
void pcmk__foreach_ipc_client | ( | GHFunc | func, |
gpointer | user_data | ||
) |
void pcmk__foreach_ipc_client_remove | ( | GHRFunc | func, |
gpointer | user_data | ||
) |
void pcmk__free_client | ( | pcmk__client_t * | c | ) |
int pcmk__ipc_prepare_iov | ( | uint32_t | request, |
xmlNode * | message, | ||
uint32_t | max_send_size, | ||
struct iovec ** | result, | ||
ssize_t * | bytes | ||
) |
void pcmk__ipc_send_ack_as | ( | const char * | function, |
int | line, | ||
pcmk__client_t * | c, | ||
uint32_t | request, | ||
uint32_t | flags, | ||
const char * | tag | ||
) |
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, | ||
xmlNode * | message, | ||
uint32_t | flags | ||
) |
pcmk__client_t* pcmk__new_client | ( | qb_ipcs_connection_t * | c, |
uid_t | uid, | ||
gid_t | gid | ||
) |
pcmk__client_t* pcmk__new_unauth_client | ( | void * | key | ) |
void pcmk__serve_attrd_ipc | ( | qb_ipcs_service_t ** | ipcs, |
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 | ||
) |
qb_ipcs_service_t* pcmk__serve_controld_ipc | ( | struct qb_ipcs_service_handlers * | cb | ) |
void pcmk__serve_fenced_ipc | ( | qb_ipcs_service_t ** | ipcs, |
struct qb_ipcs_service_handlers * | cb | ||
) |
bool pcmk__set_client_queue_max | ( | pcmk__client_t * | client, |
const char * | qmax | ||
) |