6
6
* reserved.
7
7
* Copyright (c) 2018-2020 Amazon.com, Inc. or its affiliates. All rights
8
8
* reserved.
9
- *
9
+ * Copyright (c) 2021 Cisco Systems, Inc. All rights reserved
10
10
* $COPYRIGHT$
11
11
*
12
12
* Additional copyrights may follow
@@ -68,16 +68,16 @@ extern int ompi_mtl_ofi_del_procs(struct mca_mtl_base_module_t *mtl,
68
68
int ompi_mtl_ofi_progress_no_inline (void );
69
69
70
70
#if OPAL_HAVE_THREAD_LOCAL
71
- extern opal_thread_local int per_thread_ctx ;
72
- extern opal_thread_local struct fi_cq_tagged_entry wc [MTL_OFI_MAX_PROG_EVENT_COUNT ];
71
+ extern opal_thread_local int ompi_mtl_ofi_per_thread_ctx ;
72
+ extern opal_thread_local struct fi_cq_tagged_entry ompi_mtl_ofi_wc [MTL_OFI_MAX_PROG_EVENT_COUNT ];
73
73
#endif
74
74
75
75
/* Set OFI context for operations which generate completion events */
76
76
__opal_attribute_always_inline__ static inline void
77
77
set_thread_context (int ctxt )
78
78
{
79
79
#if OPAL_HAVE_THREAD_LOCAL
80
- per_thread_ctx = ctxt ;
80
+ ompi_mtl_ofi_per_thread_ctx = ctxt ;
81
81
return ;
82
82
#endif
83
83
}
@@ -87,7 +87,7 @@ __opal_attribute_always_inline__ static inline void
87
87
get_thread_context (int * ctxt )
88
88
{
89
89
#if OPAL_HAVE_THREAD_LOCAL
90
- * ctxt = per_thread_ctx ;
90
+ * ctxt = ompi_mtl_ofi_per_thread_ctx ;
91
91
#endif
92
92
return ;
93
93
}
@@ -106,24 +106,24 @@ ompi_mtl_ofi_context_progress(int ctxt_id)
106
106
struct fi_cq_err_entry error = { 0 };
107
107
ssize_t ret ;
108
108
#if !OPAL_HAVE_THREAD_LOCAL
109
- struct fi_cq_tagged_entry wc [MTL_OFI_MAX_PROG_EVENT_COUNT ];
109
+ struct fi_cq_tagged_entry ompi_mtl_ofi_wc [MTL_OFI_MAX_PROG_EVENT_COUNT ];
110
110
#endif
111
111
112
112
/**
113
113
* Read the work completions from the CQ.
114
114
* From the completion's op_context, we get the associated OFI request.
115
115
* Call the request's callback.
116
116
*/
117
- ret = fi_cq_read (ompi_mtl_ofi .ofi_ctxt [ctxt_id ].cq , (void * )& wc ,
117
+ ret = fi_cq_read (ompi_mtl_ofi .ofi_ctxt [ctxt_id ].cq , (void * )& ompi_mtl_ofi_wc ,
118
118
ompi_mtl_ofi .ofi_progress_event_count );
119
119
if (ret > 0 ) {
120
120
count += ret ;
121
121
events_read = ret ;
122
122
for (i = 0 ; i < events_read ; i ++ ) {
123
- if (NULL != wc [i ].op_context ) {
124
- ofi_req = TO_OFI_REQ (wc [i ].op_context );
123
+ if (NULL != ompi_mtl_ofi_wc [i ].op_context ) {
124
+ ofi_req = TO_OFI_REQ (ompi_mtl_ofi_wc [i ].op_context );
125
125
assert (ofi_req );
126
- ret = ofi_req -> event_callback (& wc [i ], ofi_req );
126
+ ret = ofi_req -> event_callback (& ompi_mtl_ofi_wc [i ], ofi_req );
127
127
if (OMPI_SUCCESS != ret ) {
128
128
opal_output (0 , "%s:%d: Error returned by request event callback: %zd.\n"
129
129
"*** The Open MPI OFI MTL is aborting the MPI job (via exit(3)).\n" ,
0 commit comments