MCPcopy Create free account
hub / github.com/ClusterLabs/pacemaker / mainloop_add_ipc_client

Function mainloop_add_ipc_client

lib/common/mainloop.c:664–686  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

662}
663
664mainloop_io_t *
665mainloop_add_ipc_client(
666 const char *name, int priority, size_t max_size, void *userdata, struct ipc_client_callbacks *callbacks)
667{
668 mainloop_io_t *client = NULL;
669 crm_ipc_t *conn = crm_ipc_new(name, max_size);
670
671 if(conn && crm_ipc_connect(conn)) {
672 int32_t fd = crm_ipc_get_fd(conn);
673 client = mainloop_add_fd(name, priority, fd, userdata, NULL);
674 client->ipc = conn;
675 client->destroy_fn = callbacks->destroy;
676 client->dispatch_fn_ipc = callbacks->dispatch;
677 }
678
679 if(conn && client == NULL) {
680 crm_trace("Connection to %s failed", name);
681 crm_ipc_close(conn);
682 crm_ipc_destroy(conn);
683 }
684
685 return client;
686}
687
688void
689mainloop_del_ipc_client(mainloop_io_t *client)

Callers 8

mainFunction · 0.85
do_initFunction · 0.85
try_corosyncFunction · 0.85
cib_native_signon_rawFunction · 0.85
lrmd_api_connectFunction · 0.85
stonith_api_signonFunction · 0.85
init_cs_connectionFunction · 0.85
do_pe_controlFunction · 0.85

Calls 6

crm_ipc_newFunction · 0.85
crm_ipc_connectFunction · 0.85
crm_ipc_get_fdFunction · 0.85
mainloop_add_fdFunction · 0.85
crm_ipc_closeFunction · 0.85
crm_ipc_destroyFunction · 0.85

Tested by

no test coverage detected