Skip to content

Commit 36c29b3

Browse files
committed
oshmem: Align OSHMEM API with spec v1.3 (update spml/yoda)
1 parent b270032 commit 36c29b3

File tree

2 files changed

+19
-1
lines changed

2 files changed

+19
-1
lines changed

oshmem/mca/spml/yoda/spml_yoda.c

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ mca_spml_yoda_module_t mca_spml_yoda = {
5757
mca_spml_yoda_put,
5858
mca_spml_yoda_put_nb,
5959
mca_spml_yoda_get,
60-
mca_spml_base_get_nb, /* todo: mca_spml_yoda_get_nb, */
60+
mca_spml_yoda_get_nb,
6161
mca_spml_yoda_recv,
6262
mca_spml_yoda_send,
6363
mca_spml_base_wait,
@@ -901,6 +901,8 @@ int mca_spml_yoda_put_nb(void* dst_addr,
901901
{
902902
UNREFERENCED_PARAMETER(handle);
903903

904+
/* TODO: real nonblocking operation is needed
905+
*/
904906
return mca_spml_yoda_put_internal(dst_addr, size, src_addr, dst, 1);
905907
}
906908

@@ -974,6 +976,17 @@ int mca_spml_yoda_enable(bool enable)
974976
return OSHMEM_SUCCESS;
975977
}
976978

979+
int mca_spml_yoda_get_nb(void* src_addr,
980+
size_t size,
981+
void* dst_addr,
982+
int src,
983+
void **handle)
984+
{
985+
/* TODO: real nonblocking operation is needed
986+
*/
987+
return mca_spml_yoda_get(src_addr, size, dst_addr, src);
988+
}
989+
977990
/**
978991
* shmem_get reads data from a remote address
979992
* in the symmetric heap via RDMA READ.

oshmem/mca/spml/yoda/spml_yoda.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,11 @@ extern int mca_spml_yoda_get(void* dst_addr,
102102
size_t size,
103103
void* src_addr,
104104
int src);
105+
extern int mca_spml_yoda_get_nb(void* dst_addr,
106+
size_t size,
107+
void* src_addr,
108+
int dst,
109+
void **handle);
105110
extern int mca_spml_yoda_put(void* dst_addr,
106111
size_t size,
107112
void* src_addr,

0 commit comments

Comments
 (0)