orte_rml 280 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (0 > (ret = orte_rml.send_buffer_nb(&jdata->originator, answer, orte_rml 207 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 305 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 510 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 617 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 672 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 672 orte/mca/ess/base/ess_base_std_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_NAME, cmd, orte_rml 272 orte/mca/ess/base/ess_base_std_tool.c ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, orte_rml 612 orte/mca/ess/hnp/ess_hnp_module.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SHOW_HELP, orte_rml 85 orte/mca/filem/base/filem_base_receive.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 111 orte/mca/filem/base/filem_base_receive.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_FILEM_BASE); orte_rml 211 orte/mca/filem/base/filem_base_receive.c if (0 > (rc = orte_rml.send_buffer_nb(sender, answer, orte_rml 303 orte/mca/filem/base/filem_base_receive.c if (0 > (rc = orte_rml.send_buffer_nb(sender, answer, orte_rml 117 orte/mca/filem/raw/filem_raw_module.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 127 orte/mca/filem/raw/filem_raw_module.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 873 orte/mca/filem/raw/filem_raw_module.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 67 orte/mca/grpcomm/base/grpcomm_base_frame.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_XCAST); orte_rml 81 orte/mca/grpcomm/direct/grpcomm_direct.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 85 orte/mca/grpcomm/direct/grpcomm_direct.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 90 orte/mca/grpcomm/direct/grpcomm_direct.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 115 orte/mca/grpcomm/direct/grpcomm_direct.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, ORTE_RML_TAG_XCAST, orte_rml 155 orte/mca/grpcomm/direct/grpcomm_direct.c rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_NAME, relay, orte_rml 246 orte/mca/grpcomm/direct/grpcomm_direct.c rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_PARENT, reply, orte_rml 565 orte/mca/grpcomm/direct/grpcomm_direct.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(&nm->name, rly, ORTE_RML_TAG_XCAST, orte_rml 106 orte/mca/iof/hnp/iof_hnp.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 112 orte/mca/iof/hnp/iof_hnp_send.c if (0 > (rc = orte_rml.send_buffer_nb(host, buf, ORTE_RML_TAG_IOF_PROXY, orte_rml 152 orte/mca/iof/iof.h orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, \ orte_rml 109 orte/mca/iof/orted/iof_orted.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 371 orte/mca/iof/orted/iof_orted.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_IOF_PROXY); orte_rml 516 orte/mca/iof/orted/iof_orted.c orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, ORTE_RML_TAG_IOF_HNP, orte_rml 143 orte/mca/iof/orted/iof_orted_read.c orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, ORTE_RML_TAG_IOF_HNP, orte_rml 75 orte/mca/iof/orted/iof_orted_receive.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, ORTE_RML_TAG_IOF_HNP, orte_rml 78 orte/mca/iof/tool/iof_tool.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 173 orte/mca/iof/tool/iof_tool.c orte_rml.send_buffer_nb(&hnp, buf, ORTE_RML_TAG_IOF_HNP, orte_rml 222 orte/mca/iof/tool/iof_tool.c orte_rml.send_buffer_nb(&hnp, buf, ORTE_RML_TAG_IOF_HNP, orte_rml 276 orte/mca/iof/tool/iof_tool.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_IOF_PROXY); orte_rml 815 orte/mca/plm/base/plm_base_launch_support.c if (0 > (ret = orte_rml.send_buffer_nb(&jdata->originator, answer, orte_rml 1348 orte/mca/plm/base/plm_base_launch_support.c orte_rml.send_buffer_nb(&dname, relay, orte_rml 76 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 82 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 86 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 90 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 111 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_PLM); orte_rml 113 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_ORTED_CALLBACK); orte_rml 114 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_REPORT_REMOTE_LAUNCH); orte_rml 115 orte/mca/plm/base/plm_base_receive.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_TOPOLOGY_REPORT); orte_rml 281 orte/mca/plm/base/plm_base_receive.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_LAUNCH_RESP, orte_rml 292 orte/mca/plm/rsh/plm_rsh_module.c orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 911 orte/mca/plm/rsh/plm_rsh_module.c orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 43 orte/mca/rml/base/rml_base_frame.c orte_rml_base_module_t orte_rml = {0}; orte_rml 111 orte/mca/rml/base/rml_base_frame.c orte_rml = *best_module; orte_rml 192 orte/mca/rml/base/rml_base_msg_handlers.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(&msg->sender, buffer, orte_rml 314 orte/mca/rml/rml.h ORTE_DECLSPEC extern orte_rml_base_module_t orte_rml; orte_rml 309 orte/mca/snapc/base/snapc_base_fns.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 770 orte/mca/snapc/base/snapc_base_fns.c if (0 > (ret = orte_rml.send_buffer_nb(peer, loc_buffer, orte_rml 186 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 257 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 278 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); orte_rml 819 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 1244 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 1451 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, ORTE_RML_TAG_SNAPC_FULL, orte_rml 1505 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); orte_rml 1570 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); orte_rml 887 orte/mca/snapc/full/snapc_full_global.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC_FULL, orte_rml 904 orte/mca/snapc/full/snapc_full_global.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC_FULL); orte_rml 922 orte/mca/snapc/full/snapc_full_global.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_CKPT, 0, orte_rml 938 orte/mca/snapc/full/snapc_full_global.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_CKPT); orte_rml 1245 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(sender, buffer, ORTE_RML_TAG_SNAPC_FULL, orte_rml 1300 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(sender, buffer, ORTE_RML_TAG_SNAPC_FULL, orte_rml 1443 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(sender, buffer, ORTE_RML_TAG_SNAPC_FULL, orte_rml 357 orte/mca/snapc/full/snapc_full_local.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC_FULL, orte_rml 381 orte/mca/snapc/full/snapc_full_local.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC_FULL); orte_rml 399 orte/mca/snapc/full/snapc_full_local.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC, orte_rml 416 orte/mca/snapc/full/snapc_full_local.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SNAPC); orte_rml 687 orte/mca/snapc/full/snapc_full_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, ORTE_RML_TAG_SNAPC_FULL, orte_rml 1338 orte/mca/snapc/full/snapc_full_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 465 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 486 orte/mca/sstore/central/sstore_central_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_DAEMON, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 591 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 803 orte/mca/sstore/central/sstore_central_global.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 812 orte/mca/sstore/central/sstore_central_global.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL); orte_rml 925 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 625 orte/mca/sstore/central/sstore_central_local.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 634 orte/mca/sstore/central/sstore_central_local.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL); orte_rml 762 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 885 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 965 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 454 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 475 orte/mca/sstore/stage/sstore_stage_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_DAEMON, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 572 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_DAEMON, buffer, orte_rml 998 orte/mca/sstore/stage/sstore_stage_global.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 1007 orte/mca/sstore/stage/sstore_stage_global.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL); orte_rml 1153 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 1052 orte/mca/sstore/stage/sstore_stage_local.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 1061 orte/mca/sstore/stage/sstore_stage_local.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SSTORE_INTERNAL); orte_rml 1315 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 1399 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 1677 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, orte_rml 1770 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buffer, ORTE_RML_TAG_SSTORE_INTERNAL, orte_rml 511 orte/mca/state/base/state_base_fns.c rc = orte_rml.send_buffer_nb(&orte_pmix_server_globals.server, buf, orte_rml 619 orte/mca/state/base/state_base_fns.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(&daemon, buf, orte_rml 329 orte/mca/state/hnp/state_hnp.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(&daemon, buf, orte_rml 242 orte/mca/state/orted/state_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 334 orte/mca/state/orted/state_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 430 orte/mca/state/orted/state_orted.c if (0 > (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, alert, orte_rml 526 orte/orted/orted_comm.c orte_rml.send_buffer_nb(ORTE_PROC_MY_NAME, iofbuf, ORTE_RML_TAG_IOF_HNP, orte_rml 717 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOPOLOGY_REPORT, orte_rml 747 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 772 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 841 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 867 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 936 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 962 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 1080 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_TOOL, orte_rml 1138 orte/orted/orted_comm.c if (0 > orte_rml.send_buffer_nb(&proc2, relay_msg, orte_rml 1189 orte/orted/orted_comm.c if (0 > orte_rml.send_buffer_nb(&proc2, relay_msg, orte_rml 1253 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(return_addr, answer, ORTE_RML_TAG_TOOL, orte_rml 1331 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, answer, orte_rml 1369 orte/orted/orted_comm.c if (0 > (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, answer, orte_rml 493 orte/orted/orted_main.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DAEMON, orte_rml 741 orte/orted/orted_main.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_ORTED_CALLBACK, orte_rml 755 orte/orted/orted_main.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_PARENT, ORTE_RML_TAG_NODE_REGEX_REPORT, orte_rml 757 orte/orted/orted_main.c if (0 > (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_PARENT, buffer, orte_rml 957 orte/orted/orted_main.c if (0 > (ret = orte_rml.send_buffer_nb(&target, buffer, orte_rml 1150 orte/orted/orted_main.c if (0 > (ret = orte_rml.send_buffer_nb(ORTE_PROC_MY_PARENT, mybucket, orte_rml 588 orte/orted/orted_submit.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_NOTIFY_COMPLETE, orte_rml 590 orte/orted/orted_submit.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_LAUNCH_RESP, orte_rml 703 orte/orted/orted_submit.c rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, req, ORTE_RML_TAG_DAEMON, orte_rml 726 orte/orted/orted_submit.c rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, req, orte_rml 1022 orte/orted/orted_submit.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_MEMPROFILE, orte_rml 1147 orte/orted/orted_submit.c orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, req, ORTE_RML_TAG_DAEMON, orte_rml 3225 orte/orted/orted_submit.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_STACK_TRACE, orte_rml 3378 orte/orted/orted_submit.c if (0 > (rc = orte_rml.send_buffer_nb(&name, buffer, orte_rml 321 orte/orted/pmix/pmix_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DIRECT_MODEX, orte_rml 325 orte/orted/pmix/pmix_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DIRECT_MODEX_RESP, orte_rml 329 orte/orted/pmix/pmix_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_LAUNCH_RESP, orte_rml 333 orte/orted/pmix/pmix_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DATA_CLIENT, orte_rml 337 orte/orted/pmix/pmix_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_NOTIFICATION, orte_rml 352 orte/orted/pmix/pmix_server.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DIRECT_MODEX); orte_rml 353 orte/orted/pmix/pmix_server.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DIRECT_MODEX_RESP); orte_rml 354 orte/orted/pmix/pmix_server.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_LAUNCH_RESP); orte_rml 355 orte/orted/pmix/pmix_server.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DATA_CLIENT); orte_rml 356 orte/orted/pmix/pmix_server.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_NOTIFICATION); orte_rml 394 orte/orted/pmix/pmix_server.c orte_rml.send_buffer_nb(remote, reply, orte_rml 437 orte/orted/pmix/pmix_server.c orte_rml.send_buffer_nb(&req->proxy, reply, orte_rml 147 orte/orted/pmix/pmix_server_dyn.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 266 orte/orted/pmix/pmix_server_fence.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(&dmn->name, buf, ORTE_RML_TAG_DIRECT_MODEX, orte_rml 1083 orte/orted/pmix/pmix_server_gen.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 135 orte/orted/pmix/pmix_server_pub.c if (ORTE_SUCCESS != (rc = orte_rml.ping(server, &timeout))) { orte_rml 137 orte/orted/pmix/pmix_server_pub.c if (ORTE_SUCCESS != (rc = orte_rml.ping(server, &timeout))) { orte_rml 208 orte/orted/pmix/pmix_server_pub.c rc = orte_rml.send_buffer_nb(target, xfer, orte_rml 150 orte/runtime/orte_data_server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 339 orte/runtime/orte_data_server.c if (0 > (rc = orte_rml.send_buffer_nb(&req->requestor, reply, ORTE_RML_TAG_DATA_CLIENT, orte_rml 718 orte/runtime/orte_data_server.c if (0 > (rc = orte_rml.send_buffer_nb(sender, answer, ORTE_RML_TAG_DATA_CLIENT, orte_rml 83 orte/test/system/ofi_big_msg.c orte_rml.send_buffer_transport_nb(sock_conduit_id,&peer, buf, MY_TAG, orte_rml_send_callback, NULL); orte_rml 88 orte/test/system/ofi_big_msg.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 99 orte/test/system/ofi_big_msg.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 111 orte/test/system/ofi_big_msg.c orte_rml.send_buffer_transport_nb(sock_conduit_id,&peer, buf, MY_TAG, send_callback, NULL); orte_rml 105 orte/test/system/ofi_conduit_stress.c orte_rml.send_buffer_nb(conduit_id,&peer, buf, MY_TAG, orte_rml_send_callback, NULL); orte_rml 110 orte/test/system/ofi_conduit_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 121 orte/test/system/ofi_conduit_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 133 orte/test/system/ofi_conduit_stress.c orte_rml.send_buffer_nb(conduit_id,&peer, buf, MY_TAG, send_callback, NULL); orte_rml 60 orte/test/system/ofi_query_test.c if( ORTE_SUCCESS == orte_rml.query_transports(&providers)) { orte_rml 83 orte/test/system/ofi_stress.c orte_rml.send_buffer_transport_nb(sock_conduit_id,&peer, buf, MY_TAG, orte_rml_send_callback, NULL); orte_rml 88 orte/test/system/ofi_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 99 orte/test/system/ofi_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 111 orte/test/system/ofi_stress.c orte_rml.send_buffer_transport_nb(sock_conduit_id,&peer, buf, MY_TAG, send_callback, NULL); orte_rml 82 orte/test/system/oob_stress.c orte_rml.send_buffer_nb(&peer, buf, MY_TAG, orte_rml_send_callback, NULL); orte_rml 87 orte/test/system/oob_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 98 orte/test/system/oob_stress.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 108 orte/test/system/oob_stress.c orte_rml.send_buffer_nb(&peer, buf, MY_TAG, send_callback, NULL); orte_rml 163 orte/test/system/oob_stress_channel.c orte_rml.open_channel ( &peer, qos_attributes, open_channel_callback, NULL); orte_rml 186 orte/test/system/oob_stress_channel.c orte_rml.send_buffer_channel_nb(channel, buf, MY_TAG, channel_send_callback, NULL); orte_rml 189 orte/test/system/oob_stress_channel.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 206 orte/test/system/oob_stress_channel.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, MY_TAG, orte_rml 216 orte/test/system/oob_stress_channel.c orte_rml.send_buffer_channel_nb(channel, buf, MY_TAG, channel_send_callback, NULL); orte_rml 224 orte/test/system/oob_stress_channel.c orte_rml.close_channel ( channel,close_channel_callback, NULL); orte_rml 82 orte/test/system/orte_spawn.c if (0 > (rc = orte_rml.send(&name, &msg, 1, MY_TAG, 0))) { orte_rml 238 orte/tools/orte-server/orte-server.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DAEMON, orte_rml 167 orte/tools/orterun/orterun.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_DAEMON, orte_rml 64 orte/util/comm/comm.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_TOOL); orte_rml 204 orte/util/comm/comm.c if (0 > (rc = orte_rml.send_buffer_nb(&tool, buf, ORTE_RML_TAG_TOOL, send_cbfunc, NULL))) { orte_rml 227 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 294 orte/util/comm/comm.c if (0 > (ret = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, cmd, orte_rml 313 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 402 orte/util/comm/comm.c if (0 > (ret = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, cmd, orte_rml 424 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 519 orte/util/comm/comm.c if (0 > (ret = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, cmd, ORTE_RML_TAG_DAEMON, orte_rml 541 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 668 orte/util/comm/comm.c if (0 > (rc = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, buf, orte_rml 684 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_TOOL, 0, orte_rml 749 orte/util/comm/comm.c if (0 > (rc = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, buf, orte_rml 766 orte/util/comm/comm.c orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, orte_rml 806 orte/util/comm/comm.c if (0 > (rc = orte_rml.send_buffer_nb((orte_process_name_t*)hnp, buf, orte_rml 589 orte/util/show_help.c orte_rml.recv_cancel(ORTE_NAME_WILDCARD, ORTE_RML_TAG_SHOW_HELP); orte_rml 662 orte/util/show_help.c if (NULL == orte_rml.send_buffer_nb || orte_rml 697 orte/util/show_help.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf, orte_rml 758 orte/util/show_help.c NULL == orte_rml.send_buffer_nb || orte_rml 789 orte/util/show_help.c if (ORTE_SUCCESS != (rc = orte_rml.send_buffer_nb(ORTE_PROC_MY_HNP, buf,