diff --git a/src/uct/api/v2/uct_v2.h b/src/uct/api/v2/uct_v2.h index cfc7c5deef2..89b4ed68e3f 100644 --- a/src/uct/api/v2/uct_v2.h +++ b/src/uct/api/v2/uct_v2.h @@ -1916,8 +1916,12 @@ typedef struct uct_ep_op_info { /** * @ingroup UCT_RESOURCE * @brief Callback invoked for each undelivered outstanding operation. + * + * @return @ref UCS_OK - The purged operation was handled successfully. + * Otherwise - The purged operation was handled with error + * and returned back to the transport. */ -typedef void (*uct_ep_outstanding_purge_callback_t)( +typedef ucs_status_t (*uct_ep_outstanding_purge_callback_t)( const uct_ep_op_info_t *op_info, void *arg); diff --git a/test/gtest/uct/ib/test_ib_mlx5_ext.cc b/test/gtest/uct/ib/test_ib_mlx5_ext.cc index 0f747b40b45..e2f8692132e 100644 --- a/test/gtest/uct/ib/test_ib_mlx5_ext.cc +++ b/test/gtest/uct/ib/test_ib_mlx5_ext.cc @@ -73,9 +73,10 @@ class test_uct_ib_mlx5_ext_rc : public test_rc { return UCS_OK; } - static void purge_cb(const uct_ep_op_info_t*, void *arg) + static ucs_status_t purge_cb(const uct_ep_op_info_t*, void *arg) { *static_cast(arg) = true; + return UCS_OK; } static void