msg_ref 160 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t **msg_ref); msg_ref 165 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_start(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 175 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_move(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 188 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_grab_content(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 196 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_find_mark_persistent(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 241 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t **msg_ref); msg_ref 247 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref, msg_ref 288 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_copy_remove(ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref, msg_ref 374 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t*msg_ref, msg_ref 567 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_msg_indv(ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref, char * msg, bool vshort); msg_ref 570 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_drain_msg_indv(ompi_crcp_bkmrk_pml_drain_message_ref_t * msg_ref, char * msg, bool vshort); msg_ref 651 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_TRAFFIC_MSG_REF_ALLOC(msg_ref) \ msg_ref 653 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*) \ msg_ref 657 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_TRAFFIC_MSG_REF_RETURN(msg_ref) \ msg_ref 660 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (opal_free_list_item_t*)msg_ref); \ msg_ref 664 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_DRAIN_MSG_REF_ALLOC(msg_ref) \ msg_ref 666 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ref_t *) \ msg_ref 670 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_DRAIN_MSG_REF_RETURN(msg_ref) \ msg_ref 673 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (opal_free_list_item_t*)msg_ref); \ msg_ref 677 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_DRAIN_ACK_MSG_REF_ALLOC(msg_ref) \ msg_ref 679 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ack_ref_t *) \ msg_ref 683 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_DRAIN_ACK_MSG_REF_RETURN(msg_ref) \ msg_ref 686 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (opal_free_list_item_t*)msg_ref); \ msg_ref 823 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_traffic_message_ref_construct(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref) { msg_ref 824 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = 0; msg_ref 825 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = COORD_MSG_TYPE_UNKNOWN; msg_ref 827 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = 0; msg_ref 828 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = 0; msg_ref 829 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = 0; msg_ref 830 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = 0; msg_ref 831 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = NULL; msg_ref 833 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&msg_ref->msg_contents, opal_list_t); msg_ref 835 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = ORTE_JOBID_INVALID; msg_ref 836 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = ORTE_VPID_INVALID; msg_ref 838 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = INVALID_INT; msg_ref 839 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = INVALID_INT; msg_ref 840 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = INVALID_INT; msg_ref 841 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->posted = INVALID_INT; msg_ref 842 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain = INVALID_INT; msg_ref 845 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_traffic_message_ref_destruct( ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref) { msg_ref 848 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = 0; msg_ref 849 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = COORD_MSG_TYPE_UNKNOWN; msg_ref 851 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = 0; msg_ref 852 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = 0; msg_ref 853 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = 0; msg_ref 854 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = 0; msg_ref 855 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = NULL; msg_ref 857 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&(msg_ref->msg_contents)) ) ) { msg_ref 860 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&(msg_ref->msg_contents)); msg_ref 862 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = ORTE_JOBID_INVALID; msg_ref 863 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = ORTE_VPID_INVALID; msg_ref 865 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = INVALID_INT; msg_ref 866 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = INVALID_INT; msg_ref 867 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = INVALID_INT; msg_ref 868 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->posted = INVALID_INT; msg_ref 869 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain = INVALID_INT; msg_ref 880 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_drain_message_ref_construct(ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref) { msg_ref 881 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = 0; msg_ref 882 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = COORD_MSG_TYPE_UNKNOWN; msg_ref 884 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = 0; msg_ref 886 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->datatype = NULL; msg_ref 887 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = 0; msg_ref 889 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = 0; msg_ref 890 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = 0; msg_ref 891 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = NULL; msg_ref 893 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&msg_ref->msg_contents, opal_list_t); msg_ref 895 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = ORTE_JOBID_INVALID; msg_ref 896 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = ORTE_VPID_INVALID; msg_ref 898 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = INVALID_INT; msg_ref 899 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = INVALID_INT; msg_ref 900 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->already_posted = INVALID_INT; msg_ref 903 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_drain_message_ref_destruct( ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref) { msg_ref 906 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = 0; msg_ref 907 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = COORD_MSG_TYPE_UNKNOWN; msg_ref 909 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = 0; msg_ref 911 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != msg_ref->datatype ) { msg_ref 912 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_RELEASE(msg_ref->datatype); msg_ref 913 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->datatype = NULL; msg_ref 915 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = 0; msg_ref 917 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = 0; msg_ref 918 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = 0; msg_ref 919 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = NULL; msg_ref 921 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&(msg_ref->msg_contents)) ) ) { msg_ref 924 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&(msg_ref->msg_contents)); msg_ref 926 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = ORTE_JOBID_INVALID; msg_ref 927 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = ORTE_VPID_INVALID; msg_ref 929 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = INVALID_INT; msg_ref 930 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = INVALID_INT; msg_ref 931 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->already_posted = INVALID_INT; msg_ref 993 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c coord_state->msg_ref = v_msg_ref; \ msg_ref 1001 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c v_msg_ref = v_coord_state->msg_ref; \ msg_ref 1005 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define CREATE_NEW_MSG(msg_ref, v_type, v_count, v_ddt_size, v_tag, v_rank, v_comm, p_jobid, p_vpid) \ msg_ref 1007 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c HOKE_TRAFFIC_MSG_REF_ALLOC(msg_ref); \ msg_ref 1009 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = message_seq_num; \ msg_ref 1012 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = v_type; \ msg_ref 1014 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = v_count; \ msg_ref 1016 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = v_ddt_size; \ msg_ref 1018 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = v_tag; \ msg_ref 1019 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = v_rank; \ msg_ref 1020 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = v_comm; \ msg_ref 1022 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = p_jobid; \ msg_ref 1023 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = p_vpid; \ msg_ref 1025 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; \ msg_ref 1026 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; \ msg_ref 1027 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = 0; \ msg_ref 1028 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->posted = 0; \ msg_ref 1029 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain = 0; \ msg_ref 1032 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define CREATE_NEW_DRAIN_MSG(msg_ref, v_type, v_count, v_ddt_size, v_tag, v_rank, v_comm, p_jobid, p_vpid) \ msg_ref 1034 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c HOKE_DRAIN_MSG_REF_ALLOC(msg_ref); \ msg_ref 1036 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_id = message_seq_num; \ msg_ref 1039 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->msg_type = v_type; \ msg_ref 1041 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count = v_count; \ msg_ref 1043 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->datatype = NULL; \ msg_ref 1044 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size = ddt_size; \ msg_ref 1046 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag = v_tag; \ msg_ref 1047 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank = v_rank; \ msg_ref 1048 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm = v_comm; \ msg_ref 1050 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.jobid = p_jobid; \ msg_ref 1051 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->proc_name.vpid = p_vpid; \ msg_ref 1511 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1540 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 1544 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1557 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1570 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(msg_ref->msg_contents), &(new_content->super) ); msg_ref 1587 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1614 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 1623 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 1628 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_start(msg_ref, msg_ref 1650 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1661 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 1670 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 1691 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_find_mark_persistent(msg_ref, &request, msg_ref 1699 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 1700 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 1702 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain--; msg_ref 1724 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1753 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 1760 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1773 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1786 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(msg_ref->msg_contents), &(new_content->super) ); msg_ref 1807 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1818 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 1827 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 1852 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_grab_content(msg_ref, &content_ref, true, true); /* Remove, prefer already_drained */ msg_ref 1855 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 1856 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 1858 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain--; msg_ref 1882 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1911 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 1915 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c current_msg_id = msg_ref->msg_id; msg_ref 1920 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1932 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 1937 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 1938 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 1966 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 1997 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2000 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c NULL, msg_ref); msg_ref 2016 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2019 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2034 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2047 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(msg_ref->msg_contents), &(new_content->super) ); msg_ref 2064 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 2094 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2113 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2126 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2137 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->count, msg_ref->tag, msg_ref->rank, msg_ref 2138 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm->c_contextid, msg_ref->ddt_size, msg_ref 2146 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = drain_message_find_any(msg_ref->count, msg_ref->tag, msg_ref->rank, msg_ref 2147 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->comm, msg_ref->ddt_size, msg_ref 2167 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref, msg_ref 2186 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 2212 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2221 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != msg_ref ) { msg_ref 2222 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_start(msg_ref, msg_ref 2239 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2248 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != msg_ref ) { msg_ref 2249 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_start(msg_ref, msg_ref 2257 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2273 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL, *new_msg_ref = NULL; msg_ref 2286 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2298 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2305 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2314 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != msg_ref ) { msg_ref 2315 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_move(msg_ref, msg_ref 2322 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = new_msg_ref; msg_ref 2329 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2353 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_find_mark_persistent(msg_ref, &request, msg_ref 2364 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 2365 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 2367 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain--; msg_ref 2396 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL; msg_ref 2446 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2449 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c NULL, msg_ref); msg_ref 2465 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2468 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2484 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2497 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(msg_ref->msg_contents), &(new_content->super) ); msg_ref 2518 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL, *new_msg_ref = NULL; msg_ref 2531 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2543 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2550 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref, msg_ref 2559 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != msg_ref ) { msg_ref 2560 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_move(msg_ref, msg_ref 2567 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = new_msg_ref; msg_ref 2574 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == msg_ref ) { msg_ref 2597 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_grab_content(msg_ref, &content_ref, true, true); /* Remove, prefer already_drained */ msg_ref 2601 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 2602 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 2604 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain--; msg_ref 2633 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref = NULL, *new_msg_ref = NULL; msg_ref 2682 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2685 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c NULL, msg_ref); msg_ref 2698 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &msg_ref); msg_ref 2701 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2705 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c current_msg_id = msg_ref->msg_id; msg_ref 2720 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); msg_ref 2737 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_move(msg_ref, msg_ref 2750 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done++; msg_ref 2751 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active--; msg_ref 3187 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t **msg_ref) msg_ref 3209 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref, msg_ref 3217 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != *msg_ref ) { msg_ref 3220 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->posted++; msg_ref 3222 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->active++; msg_ref 3226 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c CREATE_NEW_MSG((*msg_ref), msg_type, msg_ref 3231 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c CREATE_NEW_MSG((*msg_ref), msg_type, msg_ref 3238 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->matched = 0; msg_ref 3239 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->done = 0; msg_ref 3240 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->active = 0; msg_ref 3241 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->posted = 1; msg_ref 3243 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->matched = 0; msg_ref 3244 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->done = 0; msg_ref 3245 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->active = 1; msg_ref 3246 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->posted = 0; msg_ref 3249 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(append_list, &((*msg_ref)->super)); msg_ref 3276 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_start(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 3285 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active++; msg_ref 3287 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_find_mark_persistent(msg_ref, request, msg_ref 3372 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_find_mark_persistent(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 3383 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 3384 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 3400 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->msg_id, msg_ref 3416 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_grab_content(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref, msg_ref 3428 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 >= opal_list_get_size(&msg_ref->msg_contents) ) { msg_ref 3437 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 3441 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 3442 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 3457 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_remove_item(&msg_ref->msg_contents, &(new_content->super)); msg_ref 3730 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref; msg_ref 3731 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)item; msg_ref 3735 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 >= msg_ref->posted ) { msg_ref 3739 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c else if( (active == FIND_MSG_TRUE && 0 >= (msg_ref->active + msg_ref->active_drain) ) || msg_ref 3740 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (active == FIND_MSG_FALSE && 0 <= (msg_ref->active + msg_ref->active_drain) ) ) { msg_ref 3745 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if(msg_ref->count == count && msg_ref 3746 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (NULL != msg_ref->comm && msg_ref->comm->c_contextid == comm_id) && msg_ref 3747 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (msg_ref->tag == MPI_ANY_TAG || msg_ref->tag == tag) && msg_ref 3748 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (peer == INVALID_INT || msg_ref->rank == peer) && msg_ref 3749 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->ddt_size == ddt_size) { msg_ref 3755 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *found_msg_ref = msg_ref; msg_ref 3772 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t **msg_ref) msg_ref 3786 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref, msg_ref 3793 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == *msg_ref ) { msg_ref 3794 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c CREATE_NEW_DRAIN_MSG((*msg_ref), msg_type, msg_ref 3799 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->done = 0; msg_ref 3800 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->active = 0; msg_ref 3801 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (*msg_ref)->already_posted = 0; msg_ref 3803 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(peer_ref->drained_list), &((*msg_ref)->super)); msg_ref 3811 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref, msg_ref 3817 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_remove_item(&(msg_ref->msg_contents), &(content_ref->super)); msg_ref 3824 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 >= opal_list_get_size(&(msg_ref->msg_contents) ) ) { msg_ref 3825 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_DRAIN_MSG_INDV(10, (msg_ref, "D*remove", true)); msg_ref 3826 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_remove_item(&(peer_ref->drained_list), &(msg_ref->super)); msg_ref 3827 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c HOKE_DRAIN_MSG_REF_RETURN(msg_ref); msg_ref 3829 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_DRAIN_MSG_INDV(10, (msg_ref, "Dremove", true)); msg_ref 4303 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref; msg_ref 4334 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4335 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4336 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 4337 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain += msg_ref->active; msg_ref 4338 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = 0; msg_ref 4340 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(cont_item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 4341 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cont_item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 4354 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4355 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4356 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 4357 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain += msg_ref->active; msg_ref 4358 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = 0; msg_ref 4360 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(cont_item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 4361 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cont_item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 4374 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4375 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4376 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 4377 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain += msg_ref->active; msg_ref 4378 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active = 0; msg_ref 4380 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(cont_item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 4381 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cont_item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 4394 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4395 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4396 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 4403 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4404 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4405 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 4412 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)rm_item; msg_ref 4413 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched = 0; msg_ref 4414 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done = 0; msg_ref 5416 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref; msg_ref 5417 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)msg_item; msg_ref 5423 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched, msg_ref->active, msg_ref->done, msg_ref->active_drain, msg_ref 5424 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (msg_ref->msg_type == COORD_MSG_TYPE_B_SEND ? " Send" : msg_ref 5425 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (msg_ref->msg_type == COORD_MSG_TYPE_I_SEND ? "iSend" : "pSend")) msg_ref 5429 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 >= (msg_ref->active + msg_ref->done) ) { msg_ref 5434 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if(OMPI_SUCCESS != (ret = do_send_msg_detail(peer_ref, msg_ref, &num_matches, &p_total_found, &finished)) ) { msg_ref 5444 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched, msg_ref->active, msg_ref->done, msg_ref->active_drain, msg_ref 5445 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (msg_ref->msg_type == COORD_MSG_TYPE_B_SEND ? " Send" : msg_ref 5446 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (msg_ref->msg_type == COORD_MSG_TYPE_I_SEND ? "iSend" : "pSend")), msg_ref 5510 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t*msg_ref, msg_ref 5543 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c comm_my_rank = ompi_comm_rank(msg_ref->comm); msg_ref 5545 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, msg_ref->comm->c_contextid, 1, OPAL_UINT32, msg_ref 5556 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, msg_ref->tag, 1, OPAL_INT, msg_ref 5558 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, msg_ref->count, 1, OPAL_SIZE, msg_ref 5560 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, msg_ref->ddt_size, 1, OPAL_SIZE, msg_ref 5568 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c total_sent = msg_ref->done + msg_ref->active; msg_ref 5605 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched += num_resolv; msg_ref 5625 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done, msg_ref->active)); msg_ref 5626 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_MSG_INDV(15, (msg_ref, "", false)); msg_ref 6320 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_msg_indv(ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref, char * msg, bool vshort) msg_ref 6326 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c switch(msg_ref->msg_type) { msg_ref 6354 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->msg_id, msg_ref 6355 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched, msg_ref 6356 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done, msg_ref 6357 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active, msg_ref 6358 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain, msg_ref 6359 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->posted, msg_ref 6360 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)opal_list_get_size(&msg_ref->msg_contents), msg_ref 6361 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->count, msg_ref 6362 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag, msg_ref 6363 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank); msg_ref 6368 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->msg_id, msg_ref 6369 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->matched, msg_ref 6370 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done, msg_ref 6371 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active, msg_ref 6372 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active_drain, msg_ref 6373 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->posted, msg_ref 6374 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)opal_list_get_size(&msg_ref->msg_contents), msg_ref 6375 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->count); msg_ref 6380 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(cont_item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 6381 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cont_item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 6389 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_drain_msg_indv(ompi_crcp_bkmrk_pml_drain_message_ref_t * msg_ref, char * msg, bool vshort) msg_ref 6395 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c switch(msg_ref->msg_type) { msg_ref 6423 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->msg_id, msg_ref 6424 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done, msg_ref 6425 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active, msg_ref 6426 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)opal_list_get_size(&msg_ref->msg_contents), msg_ref 6427 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->count, msg_ref 6428 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->tag, msg_ref 6429 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->rank); msg_ref 6434 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->msg_id, msg_ref 6435 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->done, msg_ref 6436 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref->active, msg_ref 6437 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)opal_list_get_size(&msg_ref->msg_contents), msg_ref 6438 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)msg_ref->count); msg_ref 6443 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(cont_item = opal_list_get_first(&(msg_ref->msg_contents)); msg_ref 6444 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cont_item != opal_list_get_end( &(msg_ref->msg_contents)); msg_ref 6455 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_traffic_message_ref_t * msg_ref = NULL; msg_ref 6462 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c msg_ref = (ompi_crcp_bkmrk_pml_traffic_message_ref_t*)item; msg_ref 6463 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_indv(msg_ref, "", false); msg_ref 260 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h void ompi_crcp_bkmrk_pml_drain_message_ref_construct(ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref); msg_ref 261 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h void ompi_crcp_bkmrk_pml_drain_message_ref_destruct( ompi_crcp_bkmrk_pml_drain_message_ref_t *msg_ref); msg_ref 367 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h void ompi_crcp_bkmrk_pml_traffic_message_ref_construct(ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref); msg_ref 368 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h void ompi_crcp_bkmrk_pml_traffic_message_ref_destruct( ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref); msg_ref 442 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ompi_crcp_bkmrk_pml_traffic_message_ref_t *msg_ref;