#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.
|
void | crm_client_init (void) |
|
void | crm_client_cleanup (void) |
|
crm_client_t * | crm_client_get (qb_ipcs_connection_t *c) |
|
crm_client_t * | crm_client_get_by_id (const char *id) |
|
const char * | crm_client_name (crm_client_t *c) |
|
crm_client_t * | crm_client_alloc (void *key) |
| Allocate a new crm_client_t object and generate its ID. More...
|
|
crm_client_t * | crm_client_new (qb_ipcs_connection_t *c, uid_t uid, gid_t gid) |
|
void | crm_client_destroy (crm_client_t *c) |
|
void | crm_client_disconnect_all (qb_ipcs_service_t *s) |
|
bool | crm_set_client_queue_max (crm_client_t *client, const char *qmax) |
| Raise IPC eviction threshold for a client, if allowed. More...
|
|
void | crm_ipcs_send_ack (crm_client_t *c, uint32_t request, uint32_t flags, const char *tag, const char *function, int line) |
|
ssize_t | crm_ipc_prepare (uint32_t request, xmlNode *message, struct iovec **result, uint32_t max_send_size) |
|
ssize_t | crm_ipcs_send (crm_client_t *c, uint32_t request, xmlNode *message, enum crm_ipc_flags flags) |
|
ssize_t | crm_ipcs_sendv (crm_client_t *c, struct iovec *iov, enum crm_ipc_flags flags) |
|
xmlNode * | crm_ipcs_recv (crm_client_t *c, void *data, size_t size, uint32_t *id, uint32_t *flags) |
|
int | crm_ipcs_client_pid (qb_ipcs_connection_t *c) |
|
Enumerator |
---|
CRM_CLIENT_IPC |
|
CRM_CLIENT_TCP |
|
Definition at line 34 of file ipcs.h.
Enumerator |
---|
crm_client_flag_ipc_proxied |
|
crm_client_flag_ipc_privileged |
|
Definition at line 62 of file ipcs.h.
Allocate a new crm_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 crm_client_t (asserts on failure)
Definition at line 304 of file ipc.c.
void crm_client_cleanup |
( |
void |
| ) |
|
void crm_client_disconnect_all |
( |
qb_ipcs_service_t * |
s | ) |
|
void crm_client_init |
( |
void |
| ) |
|
crm_client_t* crm_client_new |
( |
qb_ipcs_connection_t * |
c, |
|
|
uid_t |
uid, |
|
|
gid_t |
gid |
|
) |
| |
ssize_t crm_ipc_prepare |
( |
uint32_t |
request, |
|
|
xmlNode * |
message, |
|
|
struct iovec ** |
result, |
|
|
uint32_t |
max_send_size |
|
) |
| |
int crm_ipcs_client_pid |
( |
qb_ipcs_connection_t * |
c | ) |
|
bool crm_set_client_queue_max |
( |
crm_client_t * |
client, |
|
|
const char * |
qmax |
|
) |
| |
Raise IPC eviction threshold for a client, if allowed.
- Parameters
-
[in,out] | client | Client to modify |
[in] | queue_max | New threshold (as string) |
- Returns
- TRUE if change was allowed, FALSE otherwise
Definition at line 421 of file ipc.c.
GHashTable* client_connections |