UCT: outstanding purge implementation

src/uct/api/v2/uct_v2.h

@@ -1888,6 +1888,19 @@ typedef struct {
 } uct_ep_outstanding_purge_params_t;
 
 
+/**
+ * @ingroup UCT_RESOURCE
+ * @brief Purge outstanding (undelivered) operations from an endpoint.
+ *
+ * @note On success, this function takes ownership of classified outstanding
+ *       operations and reports undelivered operations through the callback for
+ *       replay by the caller.
+ */
+ucs_status_t
+uct_ep_outstanding_purge(uct_ep_h ep,
+                         const uct_ep_outstanding_purge_params_t *params);
+
+
 END_C_DECLS
 
 #endif

src/uct/base/uct_iface.c

@@ -582,13 +582,11 @@ uct_iface_base_query_v2(uct_iface_h iface, uct_iface_attr_v2_t *iface_attr)
         iface_attr->max_put_sgl_zcopy_count = 0;
     }
 
-    if (!(iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN) &&
-        (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN_LENGTH)) {
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN_LENGTH) {
         iface_attr->tx_token_length = 0;
     }
 
-    if (!(iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN) &&
-        (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN_LENGTH)) {
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN_LENGTH) {
         iface_attr->rx_token_length = 0;
     }
 
@@ -691,6 +689,7 @@ UCS_CLASS_INIT_FUNC(uct_base_iface_t, uct_iface_ops_t *ops,
     ucs_assert(internal_ops->iface_vfs_refresh != NULL);
     ucs_assert(internal_ops->ep_query != NULL);
     ucs_assert(internal_ops->ep_invalidate != NULL);
+    ucs_assert(internal_ops->ep_outstanding_purge != NULL);
 
     UCS_STATIC_ASSERT(ucs_offsetof(uct_base_iface_t, internal_ops) ==
                       sizeof(uct_iface_t));
@@ -834,6 +833,15 @@ ucs_status_t uct_ep_invalidate(uct_ep_h ep,
     return iface->internal_ops->ep_invalidate(ep, params);
 }
 
+ucs_status_t
+uct_ep_outstanding_purge(uct_ep_h ep,
+                         const uct_ep_outstanding_purge_params_t *params)
+{
+    const uct_base_iface_t *iface = ucs_derived_of(ep->iface, uct_base_iface_t);
+
+    return iface->internal_ops->ep_outstanding_purge(ep, params);
+}
+
 void uct_ep_set_iface(uct_ep_h ep, uct_iface_t *iface)
 {
     ep->iface = iface;

src/uct/cuda/cuda_copy/cuda_copy_iface.c

@@ -272,7 +272,8 @@ static uct_iface_internal_ops_t uct_cuda_copy_iface_internal_ops = {
     .ep_connect_to_ep_v2   = (uct_ep_connect_to_ep_v2_func_t)ucs_empty_function_return_unsupported,
     .iface_is_reachable_v2 = uct_cuda_copy_iface_is_reachable_v2,
     .ep_is_connected       = uct_base_ep_is_connected,
-    .ep_get_device_ep      = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+    .ep_get_device_ep      = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+    .ep_outstanding_purge  = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
 };
 
 static uct_cuda_ctx_rsc_t * uct_cuda_copy_ctx_rsc_create(uct_iface_h tl_iface)

src/uct/cuda/cuda_ipc/cuda_ipc_iface.c

@@ -507,10 +507,11 @@ static uct_iface_internal_ops_t uct_cuda_ipc_iface_internal_ops = {
     .ep_is_connected        = uct_cuda_ipc_ep_is_connected,
     .ep_get_device_ep       = uct_cuda_ipc_ep_get_device_ep,
 #if CUDA_VERSION >= 13000
-    .ep_put_sgl_zcopy       = uct_cuda_ipc_ep_put_sgl_zcopy
+    .ep_put_sgl_zcopy       = uct_cuda_ipc_ep_put_sgl_zcopy,
 #else
-    .ep_put_sgl_zcopy       = (uct_ep_put_sgl_zcopy_func_t)ucs_empty_function_return_unsupported
+    .ep_put_sgl_zcopy       = (uct_ep_put_sgl_zcopy_func_t)ucs_empty_function_return_unsupported,
 #endif
+    .ep_outstanding_purge = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
 };
 
 static uct_cuda_ctx_rsc_t * uct_cuda_ipc_ctx_rsc_create(uct_iface_h tl_iface)

src/uct/cuda/gdr_copy/gdr_copy_iface.c

@@ -218,7 +218,8 @@ static uct_iface_internal_ops_t uct_gdr_copy_iface_internal_ops = {
     .ep_connect_to_ep_v2   = (uct_ep_connect_to_ep_v2_func_t)ucs_empty_function_return_unsupported,
     .iface_is_reachable_v2 = uct_gdr_copy_iface_is_reachable_v2,
     .ep_is_connected       = uct_base_ep_is_connected,
-    .ep_get_device_ep      = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+    .ep_get_device_ep      = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+    .ep_outstanding_purge  = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
 };
 
 static UCS_CLASS_INIT_FUNC(uct_gdr_copy_iface_t, uct_md_h md, uct_worker_h worker,

src/uct/gaudi/gaudi_gdr/gaudi_gdr_iface.c

@@ -97,7 +97,9 @@ static uct_iface_internal_ops_t uct_gaudi_gdr_iface_internal_ops = {
     .iface_is_reachable_v2 = (uct_iface_is_reachable_v2_func_t)
             ucs_empty_function_return_zero,
     .ep_is_connected       = (uct_ep_is_connected_func_t)
-            ucs_empty_function_return_zero_int
+            ucs_empty_function_return_zero_int,
+    .ep_outstanding_purge  = (uct_ep_outstanding_purge_func_t)
+            ucs_empty_function_return_unsupported
 };
 
 static UCS_CLASS_INIT_FUNC(uct_gaudi_gdr_iface_t, uct_md_h md,

src/uct/ib/efa/srd/srd_iface.c

@@ -236,6 +236,8 @@ static uct_ib_iface_ops_t uct_srd_iface_ops = {
         .iface_is_reachable_v2 = uct_ib_iface_is_reachable_v2,
         .ep_is_connected       = uct_srd_ep_is_connected,
         .ep_get_device_ep      = (uct_ep_get_device_ep_func_t)
+            ucs_empty_function_return_unsupported,
+        .ep_outstanding_purge = (uct_ep_outstanding_purge_func_t)
             ucs_empty_function_return_unsupported
     },
     .create_cq      = uct_ib_verbs_create_cq,

src/uct/ib/mlx5/dc/dc_mlx5.c

@@ -1452,7 +1452,8 @@ static uct_rc_iface_ops_t uct_dc_mlx5_iface_ops = {
             .ep_connect_to_ep_v2    = (uct_ep_connect_to_ep_v2_func_t)ucs_empty_function_return_unsupported,
             .iface_is_reachable_v2  = uct_dc_mlx5_iface_is_reachable_v2,
             .ep_is_connected        = uct_dc_mlx5_ep_is_connected,
-            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+            .ep_outstanding_purge = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq      = uct_rc_mlx5_iface_common_create_cq,
         .destroy_cq     = uct_rc_mlx5_iface_common_destroy_cq,

src/uct/ib/mlx5/gdaki/gdaki.c

@@ -1068,6 +1068,7 @@ static uct_rc_iface_ops_t uct_rc_gdaki_internal_ops = {
             .iface_is_reachable_v2  = (uct_iface_is_reachable_v2_func_t)ucs_empty_function_return_one_int,
             .ep_is_connected        = uct_rc_gdaki_ep_is_connected,
             .ep_get_device_ep       = uct_rc_gdaki_ep_get_device_ep,
+            .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq  = uct_rc_gdaki_create_cq,
         .destroy_cq = (uct_ib_iface_destroy_cq_func_t)ucs_empty_function_return_success,

src/uct/ib/mlx5/gga/gga_mlx5.c

@@ -737,7 +737,8 @@ static uct_rc_iface_ops_t uct_gga_mlx5_iface_ops = {
             .ep_connect_to_ep_v2    = uct_gga_mlx5_ep_connect_to_ep_v2,
             .iface_is_reachable_v2  = uct_gga_mlx5_iface_is_reachable_v2,
             .ep_is_connected        = uct_gga_mlx5_ep_is_connected,
-            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+            .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq      = uct_rc_mlx5_iface_common_create_cq,
         .destroy_cq     = uct_rc_mlx5_iface_common_destroy_cq,

src/uct/ib/mlx5/ib_mlx5_ext.c

@@ -178,6 +178,44 @@ uct_ib_mlx5_ext_ep_put_sgl_zcopy(uct_ep_h ep, void * const *buffers,
     return UCS_ERR_UNSUPPORTED;
 }
 
+static ucs_status_t uct_ib_mlx5_ext_ep_outstanding_purge_check_param(
+        const uct_ep_outstanding_purge_params_t *params)
+{
+    if (params == NULL) {
+        return UCS_ERR_INVALID_PARAM;
+    }
+
+    if (!(params->field_mask & UCT_EP_OUTSTANDING_FIELD_RX_TOKEN) ||
+        !(params->field_mask & UCT_EP_OUTSTANDING_FIELD_CB) ||
+        (params->rx_token == NULL) || (params->cb == NULL)) {
+        return UCS_ERR_INVALID_PARAM;
+    }
+
+    return UCS_OK;
+}
+
+ucs_status_t uct_ib_mlx5_ext_ep_outstanding_purge(
+        uct_ep_h ep, const uct_ep_outstanding_purge_params_t *params)
+{
+    uct_ib_mlx5_ext_plugin_t *plugin;
+
+    if (ucs_unlikely(uct_ib_mlx5_ext_ep_outstanding_purge_check_param(params) !=
+                     UCS_OK)) {
+        return UCS_ERR_INVALID_PARAM;
+    }
+
+    ucs_list_for_each(plugin, &uct_ib_mlx5_ext_plugins, list) {
+        if (ucs_unlikely(uct_ib_mlx5_ext_is_unsupported_op(
+                    (const void*)plugin->ops.ep_outstanding_purge))) {
+            continue;
+        }
+
+        return plugin->ops.ep_outstanding_purge(ep, params);
+    }
+
+    return UCS_ERR_UNSUPPORTED;
+}
+
 void uct_ib_mlx5_ext_cleanup(void)
 {
     uct_ib_mlx5_ext_plugin_t *plugin, *tmp;

src/uct/ib/mlx5/ib_mlx5_ext.h

@@ -193,6 +193,9 @@ ucs_status_t uct_ib_mlx5_ext_ep_put_sgl_zcopy(uct_ep_h ep,
                                               size_t count,
                                               uct_completion_t *comp);
 
+ucs_status_t uct_ib_mlx5_ext_ep_outstanding_purge(
+        uct_ep_h ep, const uct_ep_outstanding_purge_params_t *params);
+
 END_C_DECLS
 
 #endif /* UCT_IB_MLX5_EXT_H_ */

src/uct/ib/mlx5/rc/rc_mlx5.h

@@ -248,6 +248,8 @@ ucs_status_t uct_rc_mlx5_ep_tag_rndv_request(uct_ep_h tl_ep, uct_tag_t tag,
 
 ucs_status_t uct_rc_mlx5_ep_get_address(uct_ep_h tl_ep, uct_ep_addr_t *addr);
 
+ucs_status_t uct_rc_mlx5_base_ep_query(uct_ep_h tl_ep, uct_ep_attr_t *ep_attr);
+
 unsigned uct_rc_mlx5_ep_cleanup_qp(void *arg);
 
 ucs_status_t uct_rc_mlx5_iface_event_fd_get(uct_iface_h tl_iface, int *fd_p);

src/uct/ib/mlx5/rc/rc_mlx5_ep.c

@@ -14,6 +14,7 @@
 #endif
 
 #include <uct/ib/mlx5/ib_mlx5_log.h>
+#include <uct/ib/mlx5/ib_mlx5_ext.h>
 #include <ucs/vfs/base/vfs_cb.h>
 #include <ucs/vfs/base/vfs_obj.h>
 #include <ucs/arch/cpu.h>
@@ -24,6 +25,33 @@
 #include "rc_mlx5.inl"
 
 
+ucs_status_t uct_rc_mlx5_base_ep_query(uct_ep_h tl_ep, uct_ep_attr_t *ep_attr)
+{
+    uct_ib_mlx5_ext_ep_query_attr_t attr = {};
+    const uint64_t ext_mask              = UCT_EP_ATTR_FIELD_TX_TOKEN;
+    ucs_status_t status;
+
+    if (ep_attr->field_mask & (UCT_EP_ATTR_FIELD_LOCAL_SOCKADDR |
+                               UCT_EP_ATTR_FIELD_REMOTE_SOCKADDR)) {
+        return UCS_ERR_UNSUPPORTED;
+    }
+
+    if (ep_attr->field_mask & ext_mask) {
+        if (ep_attr->field_mask & UCT_EP_ATTR_FIELD_TX_TOKEN) {
+            attr.field_mask |= UCT_IB_MLX5_EXT_EP_QUERY_ATTR_FIELD_TX_TOKEN;
+            attr.tx_token    = ep_attr->tx_token;
+        }
+
+        status = uct_ib_mlx5_ext_ep_query(tl_ep, &attr);
+        if (status != UCS_OK) {
+            return status;
+        }
+    }
+
+    return UCS_OK;
+}
+
+
 static ucs_status_t UCS_F_ALWAYS_INLINE uct_rc_mlx5_base_ep_put_short_inline(
         uct_ep_h tl_ep, const void *buffer, unsigned length,
         uint64_t remote_addr, uct_rkey_t rkey)

src/uct/ib/mlx5/rc/rc_mlx5_iface.c

@@ -1015,14 +1015,72 @@ static ucs_status_t
 uct_rc_mlx5_iface_query_v2(uct_iface_h UCS_V_UNUSED iface,
                            uct_iface_attr_v2_t *iface_attr)
 {
-    size_t max_sgl = uct_ib_mlx5_ext_max_put_sgl_zcopy_count();
+    uct_ib_mlx5_ext_iface_query_attr_t ext_attr = {};
+    const uint64_t sgl_mask  = UCT_IFACE_ATTR_FIELD_CAP_FLAGS |
+                               UCT_IFACE_ATTR_FIELD_MAX_PUT_SGL_ZCOPY_COUNT;
+    size_t max_sgl;
+    ucs_status_t status;
+
+    status = uct_iface_base_query_v2(iface, iface_attr);
+    if (status != UCS_OK) {
+        return status;
+    }
+
+    if (iface_attr->field_mask & sgl_mask) {
+        max_sgl = uct_ib_mlx5_ext_max_put_sgl_zcopy_count();
+        if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_CAP_FLAGS) {
+            iface_attr->cap.flags |= (max_sgl > 0) ?
+                                             UCT_IFACE_FLAG_V2_PUT_SGL_ZCOPY :
+                                             0;
+        }
+
+        if (iface_attr->field_mask &
+            UCT_IFACE_ATTR_FIELD_MAX_PUT_SGL_ZCOPY_COUNT) {
+            iface_attr->max_put_sgl_zcopy_count = max_sgl;
+        }
+    }
 
     if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_CAP_FLAGS) {
-        iface_attr->cap.flags = (max_sgl > 0) ? UCT_IFACE_FLAG_V2_PUT_SGL_ZCOPY : 0;
+        ext_attr.field_mask |= UCT_IB_MLX5_EXT_IFACE_QUERY_ATTR_FIELD_CAP_FLAGS;
+    }
+
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN_LENGTH) {
+        ext_attr.field_mask |=
+                UCT_IB_MLX5_EXT_IFACE_QUERY_ATTR_FIELD_TX_TOKEN_LEN;
+    }
+
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN_LENGTH) {
+        ext_attr.field_mask |=
+                UCT_IB_MLX5_EXT_IFACE_QUERY_ATTR_FIELD_RX_TOKEN_LEN;
     }
 
-    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_MAX_PUT_SGL_ZCOPY_COUNT) {
-        iface_attr->max_put_sgl_zcopy_count = max_sgl;
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN) {
+        ext_attr.field_mask |= UCT_IB_MLX5_EXT_IFACE_QUERY_ATTR_FIELD_TX_TOKEN;
+        ext_attr.tx_token    = (void*)iface_attr->tx_token;
+    }
+
+    if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN) {
+        ext_attr.field_mask |= UCT_IB_MLX5_EXT_IFACE_QUERY_ATTR_FIELD_RX_TOKEN;
+        ext_attr.rx_token    = iface_attr->rx_token;
+    }
+
+    if (ext_attr.field_mask != 0) {
+        status = uct_ib_mlx5_ext_iface_query(iface, &ext_attr);
+        if (status != UCS_OK) {
+            return status;
+        }
+
+        if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_CAP_FLAGS) {
+            iface_attr->cap.flags |= ext_attr.cap.flags;
+        }
+
+        if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_TX_TOKEN_LENGTH) {
+            iface_attr->tx_token_length = ext_attr.tx_token_len;
+        }
+
+        if (iface_attr->field_mask & UCT_IFACE_ATTR_FIELD_RX_TOKEN_LENGTH) {
+            iface_attr->rx_token_length = ext_attr.rx_token_len;
+        }
     }
 
     return UCS_OK;
@@ -1034,13 +1092,14 @@ static uct_rc_iface_ops_t uct_rc_mlx5_iface_ops = {
             .iface_query_v2         = uct_rc_mlx5_iface_query_v2,
             .iface_estimate_perf    = uct_rc_iface_estimate_perf,
             .iface_vfs_refresh      = uct_rc_iface_vfs_refresh,
-            .ep_query               = (uct_ep_query_func_t)ucs_empty_function_return_unsupported,
+            .ep_query               = uct_rc_mlx5_base_ep_query,
             .ep_invalidate          = uct_rc_mlx5_base_ep_invalidate,
             .ep_connect_to_ep_v2    = uct_rc_mlx5_ep_connect_to_ep_v2,
             .iface_is_reachable_v2  = uct_rc_mlx5_iface_is_reachable_v2,
             .ep_is_connected        = uct_rc_mlx5_base_ep_is_connected,
             .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
-            .ep_put_sgl_zcopy       = uct_ib_mlx5_ext_ep_put_sgl_zcopy
+            .ep_put_sgl_zcopy       = uct_ib_mlx5_ext_ep_put_sgl_zcopy,
+            .ep_outstanding_purge   = uct_ib_mlx5_ext_ep_outstanding_purge
         },
         .create_cq      = uct_rc_mlx5_iface_common_create_cq,
         .destroy_cq     = uct_rc_mlx5_iface_common_destroy_cq,

src/uct/ib/mlx5/ud/ud_mlx5.c

@@ -864,7 +864,8 @@ static uct_ud_iface_ops_t uct_ud_mlx5_iface_ops = {
             .ep_connect_to_ep_v2    = uct_ud_ep_connect_to_ep_v2,
             .iface_is_reachable_v2  = uct_ib_iface_is_reachable_v2,
             .ep_is_connected        = uct_ud_mlx5_ep_is_connected,
-            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+            .ep_outstanding_purge  = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq      = uct_ud_mlx5_create_cq,
         .destroy_cq     = uct_ib_verbs_destroy_cq,

src/uct/ib/rc/verbs/rc_verbs_iface.c

@@ -503,7 +503,8 @@ static uct_rc_iface_ops_t uct_rc_verbs_iface_ops = {
             .ep_connect_to_ep_v2    = uct_rc_verbs_ep_connect_to_ep_v2,
             .iface_is_reachable_v2  = uct_ib_iface_is_reachable_v2,
             .ep_is_connected        = uct_rc_verbs_ep_is_connected,
-            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+            .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq      = uct_ib_verbs_create_cq,
         .destroy_cq     = uct_ib_verbs_destroy_cq,

src/uct/ib/rdmacm/rdmacm_cm.c

@@ -887,7 +887,8 @@ static uct_iface_internal_ops_t uct_rdmacm_cm_iface_internal_ops = {
     .ep_connect_to_ep_v2    = (uct_ep_connect_to_ep_v2_func_t)ucs_empty_function_return_unsupported,
     .iface_is_reachable_v2  = (uct_iface_is_reachable_v2_func_t)ucs_empty_function_return_zero,
     .ep_is_connected        = (uct_ep_is_connected_func_t)ucs_empty_function_return_zero_int,
-    .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+    .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+    .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
 };
 
 static ucs_status_t

src/uct/ib/ud/verbs/ud_verbs.c

@@ -672,7 +672,8 @@ static uct_ud_iface_ops_t uct_ud_verbs_iface_ops = {
             .ep_connect_to_ep_v2    = uct_ud_ep_connect_to_ep_v2,
             .iface_is_reachable_v2  = uct_ib_iface_is_reachable_v2,
             .ep_is_connected        = uct_ud_verbs_ep_is_connected,
-            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+            .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+            .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
         },
         .create_cq      = uct_ib_verbs_create_cq,
         .destroy_cq     = uct_ib_verbs_destroy_cq,

src/uct/rocm/copy/rocm_copy_iface.c

@@ -311,7 +311,8 @@ static uct_iface_internal_ops_t uct_rocm_copy_iface_internal_ops = {
     .ep_connect_to_ep_v2    = (uct_ep_connect_to_ep_v2_func_t)ucs_empty_function_return_unsupported,
     .iface_is_reachable_v2  = uct_rocm_copy_iface_is_reachable_v2,
     .ep_is_connected        = uct_base_ep_is_connected,
-    .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported
+    .ep_get_device_ep       = (uct_ep_get_device_ep_func_t)ucs_empty_function_return_unsupported,
+    .ep_outstanding_purge   = (uct_ep_outstanding_purge_func_t)ucs_empty_function_return_unsupported
 };
 
 static UCS_CLASS_INIT_FUNC(uct_rocm_copy_iface_t, uct_md_h md, uct_worker_h worker,