conn               82 attrd/attrd_common_alerts.c         lrmd_t *conn = the_lrmd;
conn               85 attrd/attrd_common_alerts.c         lrmd_api_delete(conn); /* will disconnect if necessary */
conn              509 attrd/legacy.c     cib_t *conn = user_data;
conn              511 attrd/legacy.c     conn->cmds->signoff(conn);  /* Ensure IPC is cleaned up */
conn              107 attrd/main.c       cib_t *conn = user_data;
conn              109 attrd/main.c       conn->cmds->signoff(conn);  /* Ensure IPC is cleaned up */
conn              190 cib/cibmon.c       cib_t *conn = user_data;
conn              193 cib/cibmon.c       conn->cmds->signoff(conn);  /* Ensure IPC is cleaned up */
conn               62 crmd/crmd_lrm.h     void *conn;
conn              185 crmd/lrm_state.c     lrmd_api_delete(lrm_state->conn);
conn              346 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              353 crmd/lrm_state.c     ((lrmd_t *) lrm_state->conn)->cmds->disconnect(lrm_state->conn);
conn              364 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              370 crmd/lrm_state.c     lrmd_api_delete(lrm_state->conn);
conn              371 crmd/lrm_state.c     lrm_state->conn = NULL;
conn              377 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              380 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->is_connected(lrm_state->conn);
conn              387 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              390 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->poke_connection(lrm_state->conn);
conn              398 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              399 crmd/lrm_state.c         lrm_state->conn = lrmd_api_new();
conn              400 crmd/lrm_state.c         ((lrmd_t *) lrm_state->conn)->cmds->set_callback(lrm_state->conn, lrm_op_callback);
conn              403 crmd/lrm_state.c     ret = ((lrmd_t *) lrm_state->conn)->cmds->connect(lrm_state->conn, CRM_SYSTEM_CRMD, NULL);
conn              576 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              577 crmd/lrm_state.c         lrm_state->conn = lrmd_remote_api_new(lrm_state->node_name, server, port);
conn              578 crmd/lrm_state.c         if (!lrm_state->conn) {
conn              581 crmd/lrm_state.c         ((lrmd_t *) lrm_state->conn)->cmds->set_callback(lrm_state->conn, remote_lrm_op_callback);
conn              582 crmd/lrm_state.c         lrmd_internal_set_proxy_callback(lrm_state->conn, lrm_state, crmd_remote_proxy_cb);
conn              587 crmd/lrm_state.c         ((lrmd_t *) lrm_state->conn)->cmds->connect_async(lrm_state->conn, lrm_state->node_name,
conn              605 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              608 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->get_metadata(lrm_state->conn, class, provider, agent,
conn              615 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              624 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->cancel(lrm_state->conn, rsc_id, action, interval);
conn              632 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              642 crmd/lrm_state.c         rsc = ((lrmd_t *) lrm_state->conn)->cmds->get_rsc_info(lrm_state->conn, rsc_id, options);
conn              661 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              671 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->exec(lrm_state->conn,
conn              687 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              699 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->register_rsc(lrm_state->conn, rsc_id, class,
conn              707 crmd/lrm_state.c     if (!lrm_state->conn) {
conn              721 crmd/lrm_state.c     return ((lrmd_t *) lrm_state->conn)->cmds->unregister_rsc(lrm_state->conn, rsc_id, options);
conn              751 crmd/lrm_state.c     lrmd_send_node_alert((lrmd_t *) lrm_state->conn, crmd_alert_list,
conn              776 crmd/lrm_state.c     lrmd_send_fencing_alert((lrmd_t *) lrm_state->conn, crmd_alert_list,
conn              795 crmd/lrm_state.c     lrmd_send_resource_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, node,
conn              126 lib/ais/plugin.c int pcmk_ipc_exit(void *conn);
conn              127 lib/ais/plugin.c int pcmk_ipc_connect(void *conn);
conn              128 lib/ais/plugin.c void pcmk_ipc(void *conn, ais_void_ptr * msg);
conn              134 lib/ais/plugin.c void pcmk_nodeid(void *conn, ais_void_ptr * msg);
conn              135 lib/ais/plugin.c void pcmk_nodes(void *conn, ais_void_ptr * msg);
conn              136 lib/ais/plugin.c void pcmk_notify(void *conn, ais_void_ptr * msg);
conn              137 lib/ais/plugin.c void pcmk_remove_member(void *conn, ais_void_ptr * msg);
conn              138 lib/ais/plugin.c void pcmk_quorum(void *conn, ais_void_ptr * msg);
conn              470 lib/ais/plugin.c                 pcmk_children[lpc].conn = NULL;
conn              826 lib/ais/plugin.c pcmk_ipc_exit(void *conn)
conn              830 lib/ais/plugin.c     void *async_conn = conn;
conn              833 lib/ais/plugin.c         if (pcmk_children[lpc].conn == conn) {
conn              838 lib/ais/plugin.c             pcmk_children[lpc].conn = NULL;
conn              849 lib/ais/plugin.c         do_ais_log(LOG_INFO, "Client %s (conn=%p, async-conn=%p) left", client, conn, async_conn);
conn              852 lib/ais/plugin.c                    "unknown-transient", conn, async_conn);
conn              859 lib/ais/plugin.c pcmk_ipc_connect(void *conn)
conn              964 lib/ais/plugin.c send_ipc_ack(void *conn)
conn              973 lib/ais/plugin.c     pcmk_api->ipc_response_send(conn, res_overlay, res_overlay->header.size);
conn              978 lib/ais/plugin.c pcmk_ipc(void *conn, ais_void_ptr * msg)
conn              984 lib/ais/plugin.c     void *async_conn = conn;
conn              986 lib/ais/plugin.c     ais_trace("Message from client %p", conn);
conn              990 lib/ais/plugin.c         send_ipc_ack(conn);
conn             1006 lib/ais/plugin.c          type, mutable->host.local, pcmk_children[type].conn, mutable->host.type, crm_msg_ais,
conn             1027 lib/ais/plugin.c         && pcmk_children[type].conn == NULL && mutable->host.type == crm_msg_ais) {
conn             1032 lib/ais/plugin.c                  conn, pcmk_children[type].name, pcmk_children[type].pid);
conn             1033 lib/ais/plugin.c         pcmk_children[type].conn = conn;
conn             1058 lib/ais/plugin.c     send_ipc_ack(conn);
conn             1073 lib/ais/plugin.c         if (pcmk_children[crm_msg_crmd].conn || pcmk_children[crm_msg_stonith_ng].conn) {
conn             1140 lib/ais/plugin.c             pcmk_children[lpc].conn = NULL;
conn             1207 lib/ais/plugin.c pcmk_nodes(void *conn, ais_void_ptr * msg)
conn             1210 lib/ais/plugin.c     void *async_conn = conn;
conn             1215 lib/ais/plugin.c     send_ipc_ack(conn);
conn             1225 lib/ais/plugin.c pcmk_remove_member(void *conn, ais_void_ptr * msg)
conn             1230 lib/ais/plugin.c     send_ipc_ack(conn);
conn             1245 lib/ais/plugin.c send_quorum_details(void *conn)
conn             1256 lib/ais/plugin.c     send_client_msg(conn, crm_class_quorum, crm_msg_none, data);
conn             1261 lib/ais/plugin.c pcmk_quorum(void *conn, ais_void_ptr * msg)
conn             1267 lib/ais/plugin.c     send_ipc_ack(conn);
conn             1281 lib/ais/plugin.c     send_quorum_details(conn);
conn             1286 lib/ais/plugin.c pcmk_notify(void *conn, ais_void_ptr * msg)
conn             1290 lib/ais/plugin.c     void *async_conn = conn;
conn             1295 lib/ais/plugin.c     send_ipc_ack(conn);
conn             1313 lib/ais/plugin.c pcmk_nodeid(void *conn, ais_void_ptr * msg)
conn             1318 lib/ais/plugin.c     ais_trace("Sending local nodeid: %d to %p[%d]", local_nodeid, conn, counter);
conn             1330 lib/ais/plugin.c     pcmk_api->ipc_response_send(conn, &resp, resp.header.size);
conn             1480 lib/ais/plugin.c         void *conn = NULL;
conn             1528 lib/ais/plugin.c         conn = pcmk_children[children_index].async_conn;
conn             1539 lib/ais/plugin.c         rc = send_client_ipc(conn, mutable);
conn              527 lib/ais/utils.c send_client_ipc(void *conn, const AIS_Message * ais_msg)
conn              531 lib/ais/utils.c     if (conn == NULL) {
conn              534 lib/ais/utils.c     } else if (!libais_connection_active(conn)) {
conn              543 lib/ais/utils.c         rc = pcmk_api->ipc_dispatch_send(conn, ais_msg, ais_msg->header.size);
conn              550 lib/ais/utils.c send_client_msg(void *conn, enum crm_ais_msg_class class, enum crm_ais_msg_types type,
conn              592 lib/ais/utils.c     rc = send_client_ipc(conn, ais_msg);
conn               46 lib/ais/utils.h extern int openais_response_send(void *conn, void *msg, int mlen);
conn               47 lib/ais/utils.h extern int openais_dispatch_send(void *conn, void *msg, int mlen);
conn               77 lib/ais/utils.h     void *conn;
conn              101 lib/ais/utils.h extern int send_client_msg(void *conn, enum crm_ais_msg_class class,
conn              117 lib/ais/utils.h extern int send_client_ipc(void *conn, const AIS_Message * ais_msg);
conn              223 lib/ais/utils.h libais_connection_active(void *conn)
conn              225 lib/ais/utils.h     if (conn != NULL) {
conn              612 lib/cluster/heartbeat.c     ll_cluster_t *conn = cluster;
conn              614 lib/cluster/heartbeat.c     if (conn == NULL) {
conn              621 lib/cluster/heartbeat.c     conn->llc_ops->init_nodewalk(conn);
conn              629 lib/cluster/heartbeat.c         ha_node = conn->llc_ops->nextnode(conn);
conn              634 lib/cluster/heartbeat.c         ha_node_type = conn->llc_ops->node_type(conn, ha_node);
conn              656 lib/cluster/heartbeat.c     conn->llc_ops->end_nodewalk(conn);
conn              771 lib/common/mainloop.c     crm_ipc_t *conn = crm_ipc_new(name, max_size);
conn              773 lib/common/mainloop.c     if (conn && crm_ipc_connect(conn)) {
conn              774 lib/common/mainloop.c         int32_t fd = crm_ipc_get_fd(conn);
conn              781 lib/common/mainloop.c         if (conn) {
conn              782 lib/common/mainloop.c             crm_ipc_close(conn);
conn              783 lib/common/mainloop.c             crm_ipc_destroy(conn);
conn              788 lib/common/mainloop.c     client->ipc = conn;
conn              137 tools/crm_node.c     crm_ipc_t *conn = crm_ipc_new(target, 0);
conn              142 tools/crm_node.c     if (!conn) {
conn              146 tools/crm_node.c     if (!crm_ipc_connect(conn)) {
conn              148 tools/crm_node.c         crm_ipc_destroy(conn);
conn              156 tools/crm_node.c         rc = crm_ipc_send(conn, hello, 0, 0, NULL);
conn              203 tools/crm_node.c     rc = crm_ipc_send(conn, cmd, 0, 0, NULL);
conn              210 tools/crm_node.c     if (conn) {
conn              211 tools/crm_node.c         crm_ipc_close(conn);
conn              212 tools/crm_node.c         crm_ipc_destroy(conn);