ais_msg 111 lib/ais/plugin.c int send_plugin_msg_raw(const AIS_Message * ais_msg); ais_msg 873 lib/ais/plugin.c AIS_Message *ais_msg = msg; ais_msg 876 lib/ais/plugin.c ais_msg->id = swab32(ais_msg->id); ais_msg 877 lib/ais/plugin.c ais_msg->size = swab32(ais_msg->size); ais_msg 878 lib/ais/plugin.c ais_msg->is_compressed = swab32(ais_msg->is_compressed); ais_msg 879 lib/ais/plugin.c ais_msg->compressed_size = swab32(ais_msg->compressed_size); ais_msg 881 lib/ais/plugin.c ais_msg->host.id = swab32(ais_msg->host.id); ais_msg 882 lib/ais/plugin.c ais_msg->host.pid = swab32(ais_msg->host.pid); ais_msg 883 lib/ais/plugin.c ais_msg->host.type = swab32(ais_msg->host.type); ais_msg 884 lib/ais/plugin.c ais_msg->host.size = swab32(ais_msg->host.size); ais_msg 885 lib/ais/plugin.c ais_msg->host.local = swab32(ais_msg->host.local); ais_msg 887 lib/ais/plugin.c ais_msg->sender.id = swab32(ais_msg->sender.id); ais_msg 888 lib/ais/plugin.c ais_msg->sender.pid = swab32(ais_msg->sender.pid); ais_msg 889 lib/ais/plugin.c ais_msg->sender.type = swab32(ais_msg->sender.type); ais_msg 890 lib/ais/plugin.c ais_msg->sender.size = swab32(ais_msg->sender.size); ais_msg 891 lib/ais/plugin.c ais_msg->sender.local = swab32(ais_msg->sender.local); ais_msg 893 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); ais_msg 894 lib/ais/plugin.c ais_msg->header.id = swab32(ais_msg->header.id); ais_msg 895 lib/ais/plugin.c ais_msg->header.error = swab32(ais_msg->header.error); ais_msg 901 lib/ais/plugin.c const AIS_Message *ais_msg = message; ais_msg 909 lib/ais/plugin.c if (ais_msg->host.size == 0 || ais_str_eq(ais_msg->host.uname, local_uname)) { ais_msg 910 lib/ais/plugin.c route_ais_message(ais_msg, FALSE); ais_msg 914 lib/ais/plugin.c ais_msg->id, ais_dest(&(ais_msg->host)), ais_msg 915 lib/ais/plugin.c msg_type2text(ais_msg->host.type), ais_msg 916 lib/ais/plugin.c ais_dest(&(ais_msg->sender)), msg_type2text(ais_msg->sender.type)); ais_msg 923 lib/ais/plugin.c struct crm_identify_msg_s *ais_msg = msg; ais_msg 926 lib/ais/plugin.c ais_msg->id = swab32(ais_msg->id); ais_msg 927 lib/ais/plugin.c ais_msg->pid = swab32(ais_msg->pid); ais_msg 928 lib/ais/plugin.c ais_msg->votes = swab32(ais_msg->votes); ais_msg 929 lib/ais/plugin.c ais_msg->processes = swab32(ais_msg->processes); ais_msg 930 lib/ais/plugin.c ais_msg->born_on = swab64(ais_msg->born_on); ais_msg 932 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); ais_msg 933 lib/ais/plugin.c ais_msg->header.id = swab32(ais_msg->header.id); ais_msg 983 lib/ais/plugin.c const AIS_Message *ais_msg = (const AIS_Message *)msg; ais_msg 1000 lib/ais/plugin.c mutable = ais_msg_copy(ais_msg); ais_msg 1227 lib/ais/plugin.c const AIS_Message *ais_msg = msg; ais_msg 1228 lib/ais/plugin.c char *data = get_ais_data(ais_msg); ais_msg 1264 lib/ais/plugin.c const AIS_Message *ais_msg = msg; ais_msg 1265 lib/ais/plugin.c char *data = get_ais_data(ais_msg); ais_msg 1288 lib/ais/plugin.c const AIS_Message *ais_msg = msg; ais_msg 1289 lib/ais/plugin.c char *data = get_ais_data(ais_msg); ais_msg 1293 lib/ais/plugin.c int sender = ais_msg->sender.pid; ais_msg 1560 lib/ais/plugin.c send_plugin_msg_raw(const AIS_Message * ais_msg) ais_msg 1565 lib/ais/plugin.c AIS_Message *mutable = ais_msg_copy(ais_msg); ais_msg 1568 lib/ais/plugin.c AIS_ASSERT(ais_msg->header.size == (sizeof(AIS_Message) + ais_data_len(ais_msg))); ais_msg 23 lib/ais/plugin.h extern int send_plugin_msg_raw(const AIS_Message * ais_msg); ais_msg 483 lib/ais/utils.c AIS_Message *ais_msg = NULL; ais_msg 492 lib/ais/utils.c ais_malloc0(ais_msg, total_size); ais_msg 494 lib/ais/utils.c ais_msg->header.size = total_size; ais_msg 495 lib/ais/utils.c ais_msg->header.error = CS_OK; ais_msg 496 lib/ais/utils.c ais_msg->header.id = 0; ais_msg 498 lib/ais/utils.c ais_msg->size = data_len; ais_msg 499 lib/ais/utils.c ais_msg->sender.type = crm_msg_ais; ais_msg 501 lib/ais/utils.c memcpy(ais_msg->data, data, data_len); ais_msg 504 lib/ais/utils.c ais_msg->host.type = type; ais_msg 505 lib/ais/utils.c ais_msg->host.id = 0; ais_msg 507 lib/ais/utils.c ais_msg->host.size = strlen(host); ais_msg 508 lib/ais/utils.c memset(ais_msg->host.uname, 0, MAX_NAME); ais_msg 509 lib/ais/utils.c memcpy(ais_msg->host.uname, host, ais_msg->host.size); ais_msg 513 lib/ais/utils.c ais_msg->host.type = type; ais_msg 514 lib/ais/utils.c ais_msg->host.size = 0; ais_msg 515 lib/ais/utils.c memset(ais_msg->host.uname, 0, MAX_NAME); ais_msg 518 lib/ais/utils.c rc = send_plugin_msg_raw(ais_msg); ais_msg 519 lib/ais/utils.c ais_free(ais_msg); ais_msg 527 lib/ais/utils.c send_client_ipc(void *conn, const AIS_Message * ais_msg) ais_msg 543 lib/ais/utils.c rc = pcmk_api->ipc_dispatch_send(conn, ais_msg, ais_msg->header.size); ais_msg 556 lib/ais/utils.c AIS_Message *ais_msg = NULL; ais_msg 569 lib/ais/utils.c ais_malloc0(ais_msg, total_size); ais_msg 571 lib/ais/utils.c ais_msg->id = msg_id; ais_msg 572 lib/ais/utils.c ais_msg->header.id = class; ais_msg 573 lib/ais/utils.c ais_msg->header.size = total_size; ais_msg 574 lib/ais/utils.c ais_msg->header.error = CS_OK; ais_msg 576 lib/ais/utils.c ais_msg->size = data_len; ais_msg 578 lib/ais/utils.c memcpy(ais_msg->data, data, data_len); ais_msg 581 lib/ais/utils.c ais_msg->host.size = 0; ais_msg 582 lib/ais/utils.c ais_msg->host.type = type; ais_msg 583 lib/ais/utils.c memset(ais_msg->host.uname, 0, MAX_NAME); ais_msg 584 lib/ais/utils.c ais_msg->host.id = 0; ais_msg 586 lib/ais/utils.c ais_msg->sender.type = crm_msg_ais; ais_msg 587 lib/ais/utils.c ais_msg->sender.size = local_uname_len; ais_msg 588 lib/ais/utils.c memset(ais_msg->sender.uname, 0, MAX_NAME); ais_msg 589 lib/ais/utils.c memcpy(ais_msg->sender.uname, local_uname, ais_msg->sender.size); ais_msg 590 lib/ais/utils.c ais_msg->sender.id = local_nodeid; ais_msg 592 lib/ais/utils.c rc = send_client_ipc(conn, ais_msg); ais_msg 596 lib/ais/utils.c log_ais_message(LOG_DEBUG, ais_msg); ais_msg 599 lib/ais/utils.c ais_free(ais_msg); ais_msg 117 lib/ais/utils.h extern int send_client_ipc(void *conn, const AIS_Message * ais_msg); ais_msg 141 lib/cluster/legacy.c AIS_Message *ais_msg = (AIS_Message*)iov[0].iov_base; ais_msg 170 lib/cluster/legacy.c ais_msg->header.id)); ais_msg 175 lib/cluster/legacy.c ais_msg->id, ais_error2text(rc), rc);