Skip to content

Commit 191216d

Browse files
committed
Fix the definition checks for tool_connected2 and log2 integration
Need to do it based on PMIx capabilities Signed-off-by: Ralph Castain <[email protected]>
1 parent 8451015 commit 191216d

File tree

4 files changed

+17
-6
lines changed

4 files changed

+17
-6
lines changed

config/prte_setup_pmix.m4

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -183,6 +183,16 @@ AC_DEFUN([PRTE_CHECK_PMIX],[
183183
PRTE_FLAGS_APPEND_UNIQ(LDFLAGS, $PRTE_FINAL_LDFLAGS)
184184
PRTE_FLAGS_APPEND_UNIQ(LIBS, $PRTE_FINAL_LIBS)
185185
186+
AC_MSG_CHECKING([for support of version 2 server upcalls])
187+
PRTE_CHECK_PMIX_CAP([UPCALLS2],
188+
[AC_MSG_RESULT([yes])
189+
prte_server2_upcalls=1],
190+
[AC_MSG_RESULT([no])
191+
prte_server2_upcalls=0])
192+
AC_DEFINE_UNQUOTED([PRTE_PMIX_SERVER2_UPCALLS],
193+
[$prte_server2_upcalls],
194+
[Whether or not PMIx supports server2 upcalls])
195+
186196
AC_MSG_CHECKING([for in-memory show-help content compatibility])
187197
PRTE_CHECK_PMIX_CAP([INMEMHELP],
188198
[AC_MSG_RESULT([yes])],

src/prted/pmix/pmix_server.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,11 +114,11 @@ static pmix_server_module_t pmix_server = {
114114
.notify_event = pmix_server_notify_event,
115115
.query = pmix_server_query_fn,
116116
.tool_connected = pmix_tool_connected_fn,
117-
#ifdef pmix_server_tool_connected2_fn
117+
#if PRTE_PMIX_SERVER2_UPCALLS
118118
.tool_connected2 = pmix_tool_connected2_fn,
119119
#endif
120120
.log = pmix_server_log_fn,
121-
#ifdef pmix_server_log2_fn
121+
#if PRTE_PMIX_SERVER2_UPCALLS
122122
.log2 = pmix_server_log2_fn,
123123
#endif
124124
.job_control = pmix_server_job_ctrl_fn,

src/prted/pmix/pmix_server_gen.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -928,7 +928,8 @@ void pmix_tool_connected_fn(pmix_info_t *info, size_t ninfo,
928928
prte_event_active(&(cd->ev), PRTE_EV_WRITE, 1);
929929
}
930930

931-
#ifdef pmix_server_tool_connected2_fn
931+
#if PRTE_PMIX_SERVER2_UPCALLS
932+
932933
pmix_status_t pmix_tool_connected2_fn(pmix_info_t *info, size_t ninfo,
933934
pmix_tool_connection_cbfunc_t cbfunc,
934935
void *cbdata)
@@ -1058,7 +1059,7 @@ void pmix_server_log_fn(const pmix_proc_t *client, const pmix_info_t data[], siz
10581059
PRTE_SERVER_PMIX_THREADSHIFT(PRTE_NAME_WILDCARD, NULL, rc, NULL, NULL, 0, lgcbfn, cbfunc, cbdata);
10591060
}
10601061

1061-
#ifdef pmix_server_log2_fn
1062+
#if PRTE_PMIX_SERVER2_UPCALLS
10621063
pmix_status_t pmix_server_log2_fn(const pmix_proc_t *client, const pmix_info_t data[], size_t ndata,
10631064
const pmix_info_t directives[], size_t ndirs, pmix_op_cbfunc_t cbfunc,
10641065
void *cbdata)

src/prted/pmix/pmix_server_internal.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ PRTE_EXPORT extern pmix_status_t pmix_server_query_fn(pmix_proc_t *proct, pmix_q
266266
PRTE_EXPORT extern void pmix_tool_connected_fn(pmix_info_t *info, size_t ninfo,
267267
pmix_tool_connection_cbfunc_t cbfunc, void *cbdata);
268268

269-
#ifdef pmix_server_tool_connected2_fn
269+
#if PRTE_PMIX_SERVER2_UPCALLS
270270
PRTE_EXPORT extern pmix_status_t pmix_tool_connected2_fn(pmix_info_t *info, size_t ninfo,
271271
pmix_tool_connection_cbfunc_t cbfunc, void *cbdata);
272272
#endif
@@ -275,7 +275,7 @@ PRTE_EXPORT extern void pmix_server_log_fn(const pmix_proc_t *client, const pmix
275275
size_t ndata, const pmix_info_t directives[],
276276
size_t ndirs, pmix_op_cbfunc_t cbfunc, void *cbdata);
277277

278-
#ifdef pmix_server_log2_fn
278+
#if PRTE_PMIX_SERVER2_UPCALLS
279279
PRTE_EXPORT extern pmix_status_t pmix_server_log2_fn(const pmix_proc_t *client, const pmix_info_t data[],
280280
size_t ndata, const pmix_info_t directives[],
281281
size_t ndirs, pmix_op_cbfunc_t cbfunc, void *cbdata);

0 commit comments

Comments
 (0)