src/mca/filem/base/filem_base_receive.c
/*
 * handle message from proxies
 * NOTE: The incoming buffer "buffer" is PRTE_RELEASED by the calling program.
 * DO NOT RELEASE THIS BUFFER IN THIS CODE
 */
handle message from proxies
NOTE: The incoming buffer "buffer" is PRTE_RELEASED by the calling program.
DO NOT RELEASE THIS BUFFER IN THIS CODE
handle message from proxies NOTE : The incoming buffer " buffer " is PRTE_RELEASED by the calling program . DO NOT RELEASE THIS BUFFER IN THIS CODE
void prte_filem_base_recv(int status, pmix_proc_t *sender, pmix_data_buffer_t *buffer,
                          prte_rml_tag_t tag, void *cbdata)
{
    prte_filem_cmd_flag_t command;
    int32_t count;
    int rc;
    PRTE_HIDE_UNUSED_PARAMS(status, tag, cbdata);
    PRTE_OUTPUT_VERBOSE((5, prte_filem_base_framework.framework_output,
                         "%s filem:base: Receive a command message.",
                         PRTE_NAME_PRINT(PRTE_PROC_MY_NAME)));
    count = 1;
    rc = PMIx_Data_unpack(PRTE_PROC_MY_NAME, buffer, &command, &count, PRTE_FILEM_CMD);
    if (PMIX_SUCCESS != rc) {
        PMIX_ERROR_LOG(rc);
        return;
    }
    switch (command) {
    case PRTE_FILEM_GET_PROC_NODE_NAME_CMD:
        PRTE_OUTPUT_VERBOSE((10, prte_filem_base_framework.framework_output,
                             "%s filem:base: Command: Get Proc node name command",
                             PRTE_NAME_PRINT(PRTE_PROC_MY_NAME)));
        filem_base_process_get_proc_node_name_cmd(sender, buffer);
        break;
    case PRTE_FILEM_GET_REMOTE_PATH_CMD:
        PRTE_OUTPUT_VERBOSE((10, prte_filem_base_framework.framework_output,
                             "%s filem:base: Command: Get remote path command",
                             PRTE_NAME_PRINT(PRTE_PROC_MY_NAME)));
        filem_base_process_get_remote_path_cmd(sender, buffer);
        break;
    default:
        PRTE_ERROR_LOG(PRTE_ERR_VALUE_OUT_OF_BOUNDS);
    }
}
void prte_filem_base_recv ( int status , pmix_proc_t * sender , pmix_data_buffer_t * buffer , prte_rml_tag_t tag , void * cbdata ) { prte_filem_cmd_flag_t command ; int32_t count ; int rc ; PRTE_HIDE_UNUSED_PARAMS ( status , tag , cbdata ) ; PRTE_OUTPUT_VERBOSE ( ( 5 , prte_filem_base_framework . framework_output , " " , PRTE_NAME_PRINT ( PRTE_PROC_MY_NAME ) ) ) ; count = 1 ; rc = PMIx_Data_unpack ( PRTE_PROC_MY_NAME , buffer , & command , & count , PRTE_FILEM_CMD ) ; if ( PMIX_SUCCESS != rc ) { PMIX_ERROR_LOG ( rc ) ; return ; } switch ( command ) { case PRTE_FILEM_GET_PROC_NODE_NAME_CMD : PRTE_OUTPUT_VERBOSE ( ( 10 , prte_filem_base_framework . framework_output , " " , PRTE_NAME_PRINT ( PRTE_PROC_MY_NAME ) ) ) ; filem_base_process_get_proc_node_name_cmd ( sender , buffer ) ; break ; case PRTE_FILEM_GET_REMOTE_PATH_CMD : PRTE_OUTPUT_VERBOSE ( ( 10 , prte_filem_base_framework . framework_output , " " , PRTE_NAME_PRINT ( PRTE_PROC_MY_NAME ) ) ) ; filem_base_process_get_remote_path_cmd ( sender , buffer ) ; break ; default : PRTE_ERROR_LOG ( PRTE_ERR_VALUE_OUT_OF_BOUNDS ) ; } }
handle message from proxies
 NOTE: The incoming buffer "buffer" is PRTE_RELEASED by the calling program.
handle message from proxies NOTE : The incoming buffer " buffer " is PRTE_RELEASED by the calling program .