msg_hdr            82 opal/mca/pmix/pmix4x/pmix/test/test_server.c static int server_fwd_msg(msg_hdr_t *msg_hdr, char *buf, size_t size);
msg_hdr            83 opal/mca/pmix/pmix4x/pmix/test/test_server.c static int server_send_msg(msg_hdr_t *msg_hdr, char *data, size_t size);
msg_hdr           343 opal/mca/pmix/pmix4x/pmix/test/test_server.c static int server_fwd_msg(msg_hdr_t *msg_hdr, char *buf, size_t size)
msg_hdr           349 opal/mca/pmix/pmix4x/pmix/test/test_server.c         if (tmp_server->idx == msg_hdr->dst_id) {
msg_hdr           357 opal/mca/pmix/pmix4x/pmix/test/test_server.c     rc = write(server->wr_fd, msg_hdr, sizeof(msg_hdr_t));
msg_hdr           368 opal/mca/pmix/pmix4x/pmix/test/test_server.c static int server_send_msg(msg_hdr_t *msg_hdr, char *data, size_t size)
msg_hdr           374 opal/mca/pmix/pmix4x/pmix/test/test_server.c             if (server_tmp->idx == msg_hdr->dst_id) {
msg_hdr           386 opal/mca/pmix/pmix4x/pmix/test/test_server.c     ret += write(server->wr_fd, msg_hdr, sizeof(msg_hdr_t));
msg_hdr           388 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (ret != (sizeof(*msg_hdr) + size)) {
msg_hdr           408 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           418 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.cmd = CMD_FENCE_CONTRIB;
msg_hdr           419 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.dst_id = 0;
msg_hdr           420 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.src_id = my_server_id;
msg_hdr           421 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.size = server_pack_procs(my_server_id, &buf, 0);
msg_hdr           427 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (PMIX_SUCCESS != (rc = server_send_msg(&msg_hdr, buf, msg_hdr.size))) {
msg_hdr           444 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           453 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.cmd = CMD_BARRIER_REQUEST;
msg_hdr           454 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.dst_id = 0;
msg_hdr           455 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.src_id = my_server_id;
msg_hdr           456 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.size = 0;
msg_hdr           460 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (PMIX_SUCCESS != (rc = server_send_msg(&msg_hdr, NULL, 0))) {
msg_hdr           479 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           487 opal/mca/pmix/pmix4x/pmix/test/test_server.c     rc = read(server->rd_fd, &msg_hdr, sizeof(msg_hdr_t));
msg_hdr           491 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (msg_hdr.size) {
msg_hdr           492 opal/mca/pmix/pmix4x/pmix/test/test_server.c         msg_buf = (char*) malloc(sizeof(char) * msg_hdr.size);
msg_hdr           493 opal/mca/pmix/pmix4x/pmix/test/test_server.c         rc += read(server->rd_fd, msg_buf, msg_hdr.size);
msg_hdr           495 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (rc != (int)(sizeof(msg_hdr_t) + msg_hdr.size)) {
msg_hdr           499 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (my_server_id != msg_hdr.dst_id) {
msg_hdr           500 opal/mca/pmix/pmix4x/pmix/test/test_server.c         server_fwd_msg(&msg_hdr, msg_buf, msg_hdr.size);
msg_hdr           505 opal/mca/pmix/pmix4x/pmix/test/test_server.c     switch(msg_hdr.cmd) {
msg_hdr           508 opal/mca/pmix/pmix4x/pmix/test/test_server.c             TEST_VERBOSE(("CMD_BARRIER_REQ req from %d cnt %d", msg_hdr.src_id,
msg_hdr           529 opal/mca/pmix/pmix4x/pmix/test/test_server.c             if (msg_hdr.size > 0) {
msg_hdr           531 opal/mca/pmix/pmix4x/pmix/test/test_server.c                                            fence_buf_offset + msg_hdr.size);
msg_hdr           532 opal/mca/pmix/pmix4x/pmix/test/test_server.c                 memcpy(fence_buf + fence_buf_offset, msg_buf, msg_hdr.size);
msg_hdr           533 opal/mca/pmix/pmix4x/pmix/test/test_server.c                 fence_buf_offset += msg_hdr.size;
msg_hdr           539 opal/mca/pmix/pmix4x/pmix/test/test_server.c                         msg_hdr.src_id, contrib_cnt, msg_hdr.size));
msg_hdr           562 opal/mca/pmix/pmix4x/pmix/test/test_server.c                         msg_hdr.size));
msg_hdr           563 opal/mca/pmix/pmix4x/pmix/test/test_server.c             server->modex_cbfunc(PMIX_SUCCESS, msg_buf, msg_hdr.size,
msg_hdr           582 opal/mca/pmix/pmix4x/pmix/test/test_server.c             server->modex_cbfunc(PMIX_SUCCESS, msg_buf, msg_hdr.size,
msg_hdr           596 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           604 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.cmd = CMD_FENCE_CONTRIB;
msg_hdr           605 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.dst_id = 0;
msg_hdr           606 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.src_id = my_server_id;
msg_hdr           607 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.size = ndata;
msg_hdr           611 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (PMIX_SUCCESS != (rc = server_send_msg(&msg_hdr, data, ndata))) {
msg_hdr           667 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           670 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.cmd = CMD_DMDX_RESPONSE;
msg_hdr           671 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.src_id = my_server_id;
msg_hdr           672 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.size = sz;
msg_hdr           673 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.dst_id = *sender_id;
msg_hdr           676 opal/mca/pmix/pmix4x/pmix/test/test_server.c     server_send_msg(&msg_hdr, data, sz);
msg_hdr           683 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr_t msg_hdr;
msg_hdr           688 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (0 > (msg_hdr.dst_id = server_find_id(nspace, rank))) {
msg_hdr           695 opal/mca/pmix/pmix4x/pmix/test/test_server.c             if (tmp->idx == msg_hdr.dst_id) {
msg_hdr           708 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.cmd = CMD_DMDX_REQUEST;
msg_hdr           709 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.src_id = my_server_id;
msg_hdr           710 opal/mca/pmix/pmix4x/pmix/test/test_server.c     msg_hdr.size = server_pack_dmdx(my_server_id, nspace, rank, &buf);
msg_hdr           714 opal/mca/pmix/pmix4x/pmix/test/test_server.c     if (PMIX_SUCCESS != (rc = server_send_msg(&msg_hdr, buf, msg_hdr.size))) {