Skip to content

Commit ccfd748

Browse files
UCT/CUDA_IPC: implement device put multi, put partial, atomic (#10884)
1 parent 6b2e361 commit ccfd748

File tree

13 files changed

+898
-133
lines changed

13 files changed

+898
-133
lines changed

src/uct/api/device/uct_device_impl.h

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ UCS_F_DEVICE ucs_status_t uct_device_ep_put_single(
5454
remote_address, length, flags,
5555
comp);
5656
}
57+
5758
return UCS_ERR_UNSUPPORTED;
5859
}
5960

@@ -89,7 +90,12 @@ UCS_F_DEVICE ucs_status_t uct_device_ep_atomic_add(
8990
return uct_rc_mlx5_gda_ep_atomic_add<level>(device_ep, mem_elem,
9091
inc_value, remote_address,
9192
flags, comp);
93+
} else if (device_ep->uct_tl_id == UCT_DEVICE_TL_CUDA_IPC) {
94+
return uct_cuda_ipc_ep_atomic_add<level>(device_ep, mem_elem,
95+
inc_value, remote_address,
96+
flags, comp);
9297
}
98+
9399
return UCS_ERR_UNSUPPORTED;
94100
}
95101

@@ -146,7 +152,15 @@ UCS_F_DEVICE ucs_status_t uct_device_ep_put_multi(
146152
counter_inc_value,
147153
counter_remote_address,
148154
flags, comp);
155+
} else if (device_ep->uct_tl_id == UCT_DEVICE_TL_CUDA_IPC) {
156+
return uct_cuda_ipc_ep_put_multi<level>(device_ep, mem_list,
157+
mem_list_count, addresses,
158+
remote_addresses, lengths,
159+
counter_inc_value,
160+
counter_remote_address,
161+
flags, comp);
149162
}
163+
150164
return UCS_ERR_UNSUPPORTED;
151165
}
152166

@@ -211,6 +225,13 @@ UCS_F_DEVICE ucs_status_t uct_device_ep_put_multi_partial(
211225
device_ep, mem_list, mem_list_indices, mem_list_count,
212226
addresses, remote_addresses, lengths, counter_index,
213227
counter_inc_value, counter_remote_address, flags, comp);
228+
} else if (device_ep->uct_tl_id == UCT_DEVICE_TL_CUDA_IPC) {
229+
return uct_cuda_ipc_ep_put_multi_partial<level>(device_ep, mem_list,
230+
mem_list_indices, mem_list_count,
231+
addresses, remote_addresses,
232+
lengths, counter_index,
233+
counter_inc_value, counter_remote_address,
234+
flags, comp);
214235
}
215236
return UCS_ERR_UNSUPPORTED;
216237
}
@@ -231,7 +252,10 @@ UCS_F_DEVICE ucs_status_t uct_device_ep_progress(uct_device_ep_h device_ep)
231252
{
232253
if (device_ep->uct_tl_id == UCT_DEVICE_TL_RC_MLX5_GDA) {
233254
return uct_rc_mlx5_gda_ep_progress<level>(device_ep);
255+
} else if (device_ep->uct_tl_id == UCT_DEVICE_TL_CUDA_IPC) {
256+
return UCS_OK;
234257
}
258+
235259
return UCS_ERR_UNSUPPORTED;
236260
}
237261

0 commit comments

Comments
 (0)