@@ -118,7 +118,7 @@ void mca_spml_ucx_peer_mkey_cache_init(mca_spml_ucx_ctx_t *ucx_ctx, int pe)
118
118
int mca_spml_ucx_peer_mkey_cache_add (ucp_peer_t * ucp_peer , int index )
119
119
{
120
120
/* Allocate an array to hold the pointers to the ucx_cached_mkey */
121
- if (index >= ucp_peer -> mkeys_cnt ){
121
+ if (index >= ( int ) ucp_peer -> mkeys_cnt ){
122
122
int old_size = ucp_peer -> mkeys_cnt ;
123
123
if (MCA_MEMHEAP_MAX_SEGMENTS <= (index + 1 )) {
124
124
SPML_UCX_ERROR ("Failed to get new mkey for segment: max number (%d) of segment descriptor is exhausted" ,
@@ -153,7 +153,7 @@ int mca_spml_ucx_peer_mkey_cache_add(ucp_peer_t *ucp_peer, int index)
153
153
/* Release individual mkeys */
154
154
int mca_spml_ucx_peer_mkey_cache_del (ucp_peer_t * ucp_peer , int segno )
155
155
{
156
- if ((ucp_peer -> mkeys_cnt <= segno ) || (segno < 0 )) {
156
+ if ((( int ) ucp_peer -> mkeys_cnt <= segno ) || (segno < 0 )) {
157
157
return OSHMEM_ERR_NOT_AVAILABLE ;
158
158
}
159
159
if (NULL != ucp_peer -> mkeys [segno ]) {
@@ -166,7 +166,7 @@ int mca_spml_ucx_peer_mkey_cache_del(ucp_peer_t *ucp_peer, int segno)
166
166
/* Release the memkey map from a ucp_peer if it has any element in memkey */
167
167
void mca_spml_ucx_peer_mkey_cache_release (ucp_peer_t * ucp_peer )
168
168
{
169
- int i ;
169
+ size_t i ;
170
170
if (ucp_peer -> mkeys_cnt ) {
171
171
for (i = 0 ; i < ucp_peer -> mkeys_cnt ; i ++ ) {
172
172
assert (NULL == ucp_peer -> mkeys [i ]);
@@ -239,7 +239,6 @@ int mca_spml_ucx_ctx_mkey_add(mca_spml_ucx_ctx_t *ucx_ctx, int pe, uint32_t segn
239
239
int mca_spml_ucx_ctx_mkey_del (mca_spml_ucx_ctx_t * ucx_ctx , int pe , uint32_t segno , spml_ucx_mkey_t * ucx_mkey )
240
240
{
241
241
ucp_peer_t * ucp_peer ;
242
- spml_ucx_cached_mkey_t * ucx_cached_mkey ;
243
242
int rc ;
244
243
ucp_peer = & (ucx_ctx -> ucp_peers [pe ]);
245
244
ucp_rkey_destroy (ucx_mkey -> rkey );
@@ -398,8 +397,6 @@ static int oshmem_shmem_xchng(
398
397
}
399
398
400
399
401
- static char spml_ucx_transport_ids [1 ] = { 0 };
402
-
403
400
int mca_spml_ucx_init_put_op_mask (mca_spml_ucx_ctx_t * ctx , size_t nprocs )
404
401
{
405
402
int res ;
@@ -442,7 +439,7 @@ int mca_spml_ucx_add_procs(oshmem_group_t* group, size_t nprocs)
442
439
unsigned int * wk_roffs = NULL ;
443
440
unsigned int * wk_rsizes = NULL ;
444
441
char * wk_raddrs = NULL ;
445
- size_t i , j , w , n ;
442
+ size_t i , w , n ;
446
443
ucs_status_t err ;
447
444
ucp_address_t * * wk_local_addr ;
448
445
unsigned int * wk_addr_len ;
@@ -979,7 +976,7 @@ void mca_spml_ucx_ctx_destroy(shmem_ctx_t ctx)
979
976
980
977
int mca_spml_ucx_get (shmem_ctx_t ctx , void * src_addr , size_t size , void * dst_addr , int src )
981
978
{
982
- void * rva ;
979
+ void * rva = NULL ;
983
980
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , src , src_addr , & rva , & mca_spml_ucx );
984
981
assert (NULL != ucx_mkey );
985
982
mca_spml_ucx_ctx_t * ucx_ctx = (mca_spml_ucx_ctx_t * )ctx ;
@@ -1006,7 +1003,7 @@ int mca_spml_ucx_get(shmem_ctx_t ctx, void *src_addr, size_t size, void *dst_add
1006
1003
1007
1004
int mca_spml_ucx_get_nb (shmem_ctx_t ctx , void * src_addr , size_t size , void * dst_addr , int src , void * * handle )
1008
1005
{
1009
- void * rva ;
1006
+ void * rva = NULL ;
1010
1007
ucs_status_t status ;
1011
1008
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , src , src_addr , & rva , & mca_spml_ucx );
1012
1009
assert (NULL != ucx_mkey );
@@ -1034,7 +1031,7 @@ int mca_spml_ucx_get_nb(shmem_ctx_t ctx, void *src_addr, size_t size, void *dst_
1034
1031
int mca_spml_ucx_get_nb_wprogress (shmem_ctx_t ctx , void * src_addr , size_t size , void * dst_addr , int src , void * * handle )
1035
1032
{
1036
1033
unsigned int i ;
1037
- void * rva ;
1034
+ void * rva = NULL ;
1038
1035
ucs_status_t status ;
1039
1036
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , src , src_addr , & rva , & mca_spml_ucx );
1040
1037
assert (NULL != ucx_mkey );
@@ -1072,7 +1069,7 @@ int mca_spml_ucx_get_nb_wprogress(shmem_ctx_t ctx, void *src_addr, size_t size,
1072
1069
1073
1070
int mca_spml_ucx_put (shmem_ctx_t ctx , void * dst_addr , size_t size , void * src_addr , int dst )
1074
1071
{
1075
- void * rva ;
1072
+ void * rva = NULL ;
1076
1073
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , dst , dst_addr , & rva , & mca_spml_ucx );
1077
1074
assert (NULL != ucx_mkey );
1078
1075
mca_spml_ucx_ctx_t * ucx_ctx = (mca_spml_ucx_ctx_t * )ctx ;
@@ -1106,7 +1103,7 @@ int mca_spml_ucx_put(shmem_ctx_t ctx, void* dst_addr, size_t size, void* src_add
1106
1103
1107
1104
int mca_spml_ucx_put_nb (shmem_ctx_t ctx , void * dst_addr , size_t size , void * src_addr , int dst , void * * handle )
1108
1105
{
1109
- void * rva ;
1106
+ void * rva = NULL ;
1110
1107
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , dst , dst_addr , & rva , & mca_spml_ucx );
1111
1108
assert (NULL != ucx_mkey );
1112
1109
mca_spml_ucx_ctx_t * ucx_ctx = (mca_spml_ucx_ctx_t * )ctx ;
@@ -1139,7 +1136,7 @@ int mca_spml_ucx_put_nb(shmem_ctx_t ctx, void* dst_addr, size_t size, void* src_
1139
1136
int mca_spml_ucx_put_nb_wprogress (shmem_ctx_t ctx , void * dst_addr , size_t size , void * src_addr , int dst , void * * handle )
1140
1137
{
1141
1138
unsigned int i ;
1142
- void * rva ;
1139
+ void * rva = NULL ;
1143
1140
ucs_status_t status ;
1144
1141
spml_ucx_mkey_t * ucx_mkey = mca_spml_ucx_ctx_mkey_by_va (ctx , dst , dst_addr , & rva , & mca_spml_ucx );
1145
1142
assert (NULL != ucx_mkey );
0 commit comments