diff --git a/CMakeLists.txt b/CMakeLists.txt index b3fcf6c..036040f 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -80,10 +80,12 @@ ENDIF(ENABLE_CRAY_DW) ## DataMover IF(ENABLE_HPE_NNFDM) - FIND_PACKAGE(NNFDM) + FIND_PACKAGE(NNFDM REQUIRED) IF(NNFDM_FOUND) SET(HAVE_NNFDM TRUE) INCLUDE_DIRECTORIES(${NNFDM_INCLUDE_DIR}) + MESSAGE(STATUS "NNFDM_INCLUDE_DIR: ${NNFDM_INCLUDE_DIR}") + MESSAGE(STATUS "NNFDM_LIBRARIES: ${NNFDM_LIBRARIES}") LIST(APPEND AXL_EXTERNAL_LIBS ${NNFDM_LIBRARIES}) LIST(APPEND AXL_EXTERNAL_STATIC_LIBS ${NNFDM_LIBRARIES}) ENDIF(NNFDM_FOUND) diff --git a/src/nnfdm.cpp b/src/nnfdm.cpp index 4758297..33480ce 100644 --- a/src/nnfdm.cpp +++ b/src/nnfdm.cpp @@ -170,6 +170,7 @@ int nnfdm_start(int id) { char* src_filename = kvtree_elem_key(elem); kvtree* elem_hash = kvtree_elem_hash(elem); + const std::string dm_profile{"scr"}; /* get the destination for this file */ char* dst_filename; @@ -185,9 +186,11 @@ int nnfdm_start(int id) , true // If true, store stdout in DataMovementStatusResponse.Message when the command is successful. Failure output is always contained in the message. , -1 // The number of slots specified in the MPI hostfile. A value of 0 disables the use of slots in the hostfile. -1 will defer to the server side configuration. , -1 // The number of max_slots specified in the MPI hostfile. A value of 0 disables the use of max_slots in the hostfile. -1 will defer to the server side configuration. - , "scr" // Data movement profile. Empty will default to the default profile. + , dm_profile // Data movement profile. Empty will default to the default profile. ); + AXL_DBG(1, "create_request(%s, %s, ..., %s)", src_filename, dst_filename, dm_profile.c_str() ); + nnfdm::CreateResponse create_response; nnfdm::RPCStatus rpc_status = nnfdm_client->Create( *nnfdm_workflow, create_request, &create_response); if (!rpc_status.ok()) {