Skip to content

Commit

Permalink
Work with nnfdm SCR profile
Browse files Browse the repository at this point in the history
  • Loading branch information
mcfadden8 committed Aug 29, 2024
1 parent 2608e22 commit e59fc12
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 2 deletions.
4 changes: 3 additions & 1 deletion CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
5 changes: 4 additions & 1 deletion src/nnfdm.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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()) {
Expand Down

0 comments on commit e59fc12

Please sign in to comment.