iov 45 cib/notify.c struct iovec *iov; iov 119 cib/notify.c if (crm_ipcs_sendv(client, update->iov, crm_ipc_server_event) < 0) { iov 140 cib/notify.c struct iovec *iov; iov 143 cib/notify.c ssize_t rc = crm_ipc_prepare(0, xml, &iov, 0); iov 149 cib/notify.c update.iov = iov; iov 157 cib/notify.c if (iov) { iov 158 cib/notify.c free(iov[0].iov_base); iov 159 cib/notify.c free(iov[1].iov_base); iov 160 cib/notify.c free(iov); iov 411 include/crm/cluster/internal.h gboolean send_cpg_iov(struct iovec * iov); iov 416 include/crm/cluster/internal.h bool send_plugin_text(int class, struct iovec *iov); iov 123 include/crm/common/ipcs.h ssize_t crm_ipcs_sendv(crm_client_t * c, struct iovec *iov, enum crm_ipc_flags flags); iov 158 lib/cluster/cpg.c struct iovec *iov = cs_message_queue->data; iov 161 lib/cluster/cpg.c rc = cpg_mcast_joined(*handle, CPG_TYPE_AGREED, iov, 1); iov 170 lib/cluster/cpg.c (unsigned long long) iov->iov_len); iov 172 lib/cluster/cpg.c cs_message_queue = g_list_remove(cs_message_queue, iov); iov 173 lib/cluster/cpg.c free(iov->iov_base); iov 174 lib/cluster/cpg.c free(iov); iov 201 lib/cluster/cpg.c send_cpg_iov(struct iovec * iov) iov 207 lib/cluster/cpg.c queued, (unsigned long long) iov->iov_len); iov 208 lib/cluster/cpg.c cs_message_queue = g_list_append(cs_message_queue, iov); iov 530 lib/cluster/cpg.c struct iovec *iov; iov 624 lib/cluster/cpg.c iov = calloc(1, sizeof(struct iovec)); iov 625 lib/cluster/cpg.c iov->iov_base = msg; iov 626 lib/cluster/cpg.c iov->iov_len = msg->header.size; iov 630 lib/cluster/cpg.c msg->id, target, (unsigned long long) iov->iov_len, iov 634 lib/cluster/cpg.c msg->id, target, (unsigned long long) iov->iov_len, iov 642 lib/cluster/cpg.c return send_plugin_text(class, iov); iov 646 lib/cluster/cpg.c send_cpg_iov(iov); iov 75 lib/cluster/legacy.c struct iovec iov; iov 94 lib/cluster/legacy.c iov.iov_base = &header; iov 95 lib/cluster/legacy.c iov.iov_len = header.size; iov 99 lib/cluster/legacy.c rc = coroipcc_msg_send_reply_receive(ais_ipc_handle, &iov, 1, &answer, sizeof(answer)); iov 135 lib/cluster/legacy.c send_plugin_text(int class, struct iovec *iov) iov 141 lib/cluster/legacy.c AIS_Message *ais_msg = (AIS_Message*)iov[0].iov_base; iov 158 lib/cluster/legacy.c rc = coroipcc_msg_send_reply_receive(ais_ipc_handle, iov, 1, buf, buf_len); iov 178 lib/cluster/legacy.c free(iov[0].iov_base); iov 179 lib/cluster/legacy.c free(iov); iov 612 lib/common/ipc.c struct iovec *iov; iov 629 lib/common/ipc.c iov = calloc(2, sizeof(struct iovec)); iov 632 lib/common/ipc.c iov[0].iov_len = hdr_offset; iov 633 lib/common/ipc.c iov[0].iov_base = header; iov 637 lib/common/ipc.c total = iov[0].iov_len + header->size_uncompressed; iov 640 lib/common/ipc.c iov[1].iov_base = buffer; iov 641 lib/common/ipc.c iov[1].iov_len = header->size_uncompressed; iov 652 lib/common/ipc.c iov[1].iov_len = header->size_compressed; iov 653 lib/common/ipc.c iov[1].iov_base = compressed; iov 673 lib/common/ipc.c free(iov); iov 679 lib/common/ipc.c header->qb.size = iov[0].iov_len + iov[1].iov_len; iov 682 lib/common/ipc.c *result = iov; iov 688 lib/common/ipc.c crm_ipcs_sendv(crm_client_t * c, struct iovec * iov, enum crm_ipc_flags flags) iov 692 lib/common/ipc.c struct crm_ipc_response_header *header = iov[0].iov_base; iov 710 lib/common/ipc.c c->event_queue = g_list_append(c->event_queue, iov); iov 716 lib/common/ipc.c iov_copy[0].iov_len = iov[0].iov_len; iov 717 lib/common/ipc.c iov_copy[0].iov_base = malloc(iov[0].iov_len); iov 718 lib/common/ipc.c memcpy(iov_copy[0].iov_base, iov[0].iov_base, iov[0].iov_len); iov 720 lib/common/ipc.c iov_copy[1].iov_len = iov[1].iov_len; iov 721 lib/common/ipc.c iov_copy[1].iov_base = malloc(iov[1].iov_len); iov 722 lib/common/ipc.c memcpy(iov_copy[1].iov_base, iov[1].iov_base, iov[1].iov_len); iov 730 lib/common/ipc.c rc = qb_ipcs_response_sendv(c->ipcs, iov, 2); iov 741 lib/common/ipc.c free(iov[0].iov_base); iov 742 lib/common/ipc.c free(iov[1].iov_base); iov 743 lib/common/ipc.c free(iov); iov 764 lib/common/ipc.c struct iovec *iov = NULL; iov 772 lib/common/ipc.c rc = crm_ipc_prepare(request, message, &iov, ipc_buffer_max); iov 774 lib/common/ipc.c rc = crm_ipcs_sendv(c, iov, flags | crm_ipc_server_free); iov 777 lib/common/ipc.c free(iov); iov 1124 lib/common/ipc.c internal_ipc_send_recv(crm_ipc_t * client, const void *iov) iov 1129 lib/common/ipc.c rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, client->buf_size, -1); iov 1136 lib/common/ipc.c internal_ipc_send_request(crm_ipc_t * client, const void *iov, int ms_timeout) iov 1142 lib/common/ipc.c rc = qb_ipcc_sendv(client->ipc, iov, 2); iov 1203 lib/common/ipc.c struct iovec *iov; iov 1241 lib/common/ipc.c rc = crm_ipc_prepare(id, message, &iov, client->max_buf_size); iov 1246 lib/common/ipc.c header = iov[0].iov_base; iov 1268 lib/common/ipc.c rc = internal_ipc_send_request(client, iov, ms_timeout); iov 1295 lib/common/ipc.c rc = internal_ipc_send_recv(client, iov); iov 1327 lib/common/ipc.c free(iov[1].iov_base); iov 1328 lib/common/ipc.c free(iov); iov 311 lib/common/remote.c crm_remote_sendv(crm_remote_t * remote, struct iovec * iov, int iovs) iov 320 lib/common/remote.c rc = crm_send_tls(remote->tls_session, iov[lpc].iov_base, iov[lpc].iov_len); iov 325 lib/common/remote.c rc = crm_send_plaintext(remote->tcp_socket, iov[lpc].iov_base, iov[lpc].iov_len); iov 341 lib/common/remote.c struct iovec iov[2]; iov 350 lib/common/remote.c iov[0].iov_base = header; iov 351 lib/common/remote.c iov[0].iov_len = sizeof(struct crm_remote_header_v0); iov 353 lib/common/remote.c iov[1].iov_base = xml_text; iov 354 lib/common/remote.c iov[1].iov_len = 1 + strlen(xml_text); iov 360 lib/common/remote.c header->payload_offset = iov[0].iov_len; iov 361 lib/common/remote.c header->payload_uncompressed = iov[1].iov_len; iov 362 lib/common/remote.c header->size_total = iov[0].iov_len + iov[1].iov_len; iov 365 lib/common/remote.c (int)iov[0].iov_len, *(int*)(void*)xml_text); iov 366 lib/common/remote.c rc = crm_remote_sendv(remote, iov, 2); iov 372 lib/common/remote.c free(iov[0].iov_base); iov 373 lib/common/remote.c free(iov[1].iov_base); iov 504 mcp/pacemaker.c struct iovec *iov; iov 512 mcp/pacemaker.c iov = calloc(1, sizeof(struct iovec)); iov 513 mcp/pacemaker.c iov->iov_base = dump_xml_unformatted(msg); iov 514 mcp/pacemaker.c iov->iov_len = 1 + strlen(iov->iov_base); iov 515 mcp/pacemaker.c send_cpg_iov(iov); iov 606 mcp/pacemaker.c struct iovec *iov; iov 617 mcp/pacemaker.c iov = calloc(1, sizeof(struct iovec)); iov 618 mcp/pacemaker.c iov->iov_base = strdup(buffer); iov 619 mcp/pacemaker.c iov->iov_len = rc + 1; iov 620 mcp/pacemaker.c send_cpg_iov(iov);