4
4
* reserved.
5
5
* Copyright (c) 2020-2021 Google, LLC. All rights reserved.
6
6
* Copyright (c) 2021-2022 Cisco Systems, Inc. All rights reserved
7
+ * Copyright (c) 2022 Amazon.com, Inc. or its affiliates.
8
+ * All Rights reserved.
7
9
* $COPYRIGHT$
8
10
*
9
11
* Additional copyrights may follow
10
12
*
11
13
* $HEADER$
12
14
*/
13
15
16
+ #include "opal_config.h"
17
+
14
18
#include "opal/mca/btl/base/btl_base_am_rdma.h"
15
19
#include "opal/mca/btl/base/base.h"
16
20
#include "opal/mca/btl/base/btl_base_error.h"
17
21
#include "opal/mca/threads/mutex.h"
22
+ #include "opal/util/minmax.h"
18
23
19
24
/**
20
25
* @brief data for active-message atomics
@@ -210,11 +215,6 @@ typedef struct mca_btl_base_rdma_operation_t mca_btl_base_rdma_operation_t;
210
215
211
216
static OBJ_CLASS_INSTANCE (mca_btl_base_rdma_operation_t , opal_list_item_t , NULL, NULL) ;
212
217
213
- static inline size_t size_t_min (size_t a , size_t b )
214
- {
215
- return (a < b ) ? a : b ;
216
- }
217
-
218
218
static mca_btl_base_am_rdma_module_t default_module ;
219
219
220
220
static inline bool mca_btl_base_rdma_use_rdma_get (mca_btl_base_module_t * btl )
@@ -239,12 +239,12 @@ static inline size_t mca_btl_base_rdma_operation_size(mca_btl_base_module_t *btl
239
239
switch (type ) {
240
240
case MCA_BTL_BASE_AM_PUT :
241
241
if (mca_btl_base_rdma_use_rdma_get (btl )) {
242
- return size_t_min (remaining , btl -> btl_get_limit );
242
+ return opal_min (remaining , btl -> btl_get_limit );
243
243
}
244
244
break ;
245
245
case MCA_BTL_BASE_AM_GET :
246
246
if (mca_btl_base_rdma_use_rdma_put (btl )) {
247
- return size_t_min (remaining , btl -> btl_put_limit );
247
+ return opal_min (remaining , btl -> btl_put_limit );
248
248
}
249
249
break ;
250
250
case MCA_BTL_BASE_AM_ATOMIC :
@@ -253,7 +253,7 @@ static inline size_t mca_btl_base_rdma_operation_size(mca_btl_base_module_t *btl
253
253
return remaining ;
254
254
}
255
255
256
- return size_t_min (remaining , btl -> btl_max_send_size - sizeof (mca_btl_base_rdma_hdr_t ));
256
+ return opal_min (remaining , btl -> btl_max_send_size - sizeof (mca_btl_base_rdma_hdr_t ));
257
257
}
258
258
259
259
static inline int mca_btl_base_rdma_tag (mca_btl_base_rdma_type_t type )
@@ -318,7 +318,7 @@ static void mca_btl_base_copy_to_segments(uint64_t addr, size_t max_len, size_t
318
318
mca_btl_base_segment_t * segments , size_t segment_count )
319
319
{
320
320
void * seg0_data = (void * ) ((uintptr_t ) segments [0 ].seg_addr .pval + skip_bytes );
321
- size_t seg0_len = size_t_min (max_len , segments [0 ].seg_len - skip_bytes );
321
+ size_t seg0_len = opal_min (max_len , segments [0 ].seg_len - skip_bytes );
322
322
323
323
if (seg0_len > 0 ) {
324
324
BTL_VERBOSE (
@@ -330,7 +330,7 @@ static void mca_btl_base_copy_to_segments(uint64_t addr, size_t max_len, size_t
330
330
}
331
331
332
332
for (size_t i = 1 ; i < segment_count && max_len ; ++ i ) {
333
- size_t seg_len = size_t_min (segments [i ].seg_len , max_len );
333
+ size_t seg_len = opal_min (segments [i ].seg_len , max_len );
334
334
335
335
BTL_VERBOSE (("packing %" PRIsize_t " bytes from 0x%" PRIx64 " to segment %" PRIsize_t ,
336
336
seg_len , addr , i ));
@@ -458,13 +458,13 @@ mca_btl_base_rdma_start(mca_btl_base_module_t *btl, struct mca_btl_base_endpoint
458
458
/* just go ahead and send the data */
459
459
packet_size += size ;
460
460
} else if (!mca_btl_base_rdma_use_rdma_get (btl )) {
461
- packet_size += size_t_min (size , btl -> btl_max_send_size - sizeof (* hdr ));
461
+ packet_size += opal_min (size , btl -> btl_max_send_size - sizeof (* hdr ));
462
462
} else {
463
463
use_rdma = true;
464
464
}
465
465
} else if (MCA_BTL_BASE_AM_GET == type ) {
466
466
if (!mca_btl_base_rdma_use_rdma_put (btl )) {
467
- packet_size += size_t_min (size , btl -> btl_max_send_size - sizeof (* hdr ));
467
+ packet_size += opal_min (size , btl -> btl_max_send_size - sizeof (* hdr ));
468
468
} else {
469
469
use_rdma = true;
470
470
}
0 commit comments