1 /*
2  * Copyright (C) by Argonne National Laboratory
3  *     See COPYRIGHT in top-level directory
4  */
5 
6 #include "mpidimpl.h"
7 #include "ucx_impl.h"
8 
MPIDI_UCX_mpi_open_port(MPIR_Info * info_ptr,char * port_name)9 int MPIDI_UCX_mpi_open_port(MPIR_Info * info_ptr, char *port_name)
10 {
11     int mpi_errno = MPI_SUCCESS;
12 
13     MPIR_ERR_SET(mpi_errno, MPI_ERR_OTHER, "**ucx_nm_notsupported");
14 
15   fn_exit:
16     return mpi_errno;
17   fn_fail:
18     goto fn_exit;
19 
20 }
21 
MPIDI_UCX_mpi_close_port(const char * port_name)22 int MPIDI_UCX_mpi_close_port(const char *port_name)
23 {
24     int mpi_errno = MPI_SUCCESS;
25 
26     MPIR_ERR_SET(mpi_errno, MPI_ERR_OTHER, "**ucx_nm_notsupported");
27 
28   fn_exit:
29     return mpi_errno;
30   fn_fail:
31     goto fn_exit;
32 
33 }
34 
MPIDI_UCX_mpi_comm_connect(const char * port_name,MPIR_Info * info,int root,int timeout,MPIR_Comm * comm_ptr,MPIR_Comm ** newcomm)35 int MPIDI_UCX_mpi_comm_connect(const char *port_name, MPIR_Info * info, int root, int timeout,
36                                MPIR_Comm * comm_ptr, MPIR_Comm ** newcomm)
37 {
38     int mpi_errno = MPI_SUCCESS;
39 
40     MPIR_ERR_SET(mpi_errno, MPI_ERR_OTHER, "**ucx_nm_notsupported");
41 
42   fn_exit:
43     return mpi_errno;
44   fn_fail:
45     goto fn_exit;
46 
47 
48 
49 }
50 
MPIDI_UCX_mpi_comm_disconnect(MPIR_Comm * comm_ptr)51 int MPIDI_UCX_mpi_comm_disconnect(MPIR_Comm * comm_ptr)
52 {
53     int mpi_errno = MPI_SUCCESS;
54 
55     MPIR_FUNC_VERBOSE_STATE_DECL(MPID_STATE_MPIDI_UCX_MPI_COMM_DISCONNECT);
56     MPIR_FUNC_VERBOSE_ENTER(MPID_STATE_MPIDI_UCX_MPI_COMM_DISCONNECT);
57 
58     mpi_errno = MPIR_Comm_free_impl(comm_ptr);
59     MPIR_ERR_CHECK(mpi_errno);
60 
61   fn_exit:
62     MPIR_FUNC_VERBOSE_EXIT(MPID_STATE_MPIDI_UCX_MPI_COMM_DISCONNECT);
63     return mpi_errno;
64   fn_fail:
65     goto fn_exit;
66 }
67 
MPIDI_UCX_mpi_comm_accept(const char * port_name,MPIR_Info * info,int root,MPIR_Comm * comm_ptr,MPIR_Comm ** newcomm)68 int MPIDI_UCX_mpi_comm_accept(const char *port_name, MPIR_Info * info, int root,
69                               MPIR_Comm * comm_ptr, MPIR_Comm ** newcomm)
70 {
71     int mpi_errno = MPI_SUCCESS;
72 
73     MPIR_ERR_SET(mpi_errno, MPI_ERR_OTHER, "**ucx_nm_notsupported");
74 
75   fn_exit:
76     return mpi_errno;
77   fn_fail:
78     goto fn_exit;
79 }
80