const struct ublksrv_io_cmd *ub_cmd,
unsigned int issue_flags)
{
- io_buffer_unregister_bvec(cmd, ub_cmd->addr, issue_flags);
- return 0;
+ return io_buffer_unregister_bvec(cmd, ub_cmd->addr, issue_flags);
}
static int __ublk_ch_uring_cmd(struct io_uring_cmd *cmd,
int io_buffer_register_bvec(struct io_uring_cmd *cmd, struct request *rq,
void (*release)(void *), unsigned int index,
unsigned int issue_flags);
-void io_buffer_unregister_bvec(struct io_uring_cmd *cmd, unsigned int index,
- unsigned int issue_flags);
+int io_buffer_unregister_bvec(struct io_uring_cmd *cmd, unsigned int index,
+ unsigned int issue_flags);
#endif /* _LINUX_IO_URING_CMD_H */
}
EXPORT_SYMBOL_GPL(io_buffer_register_bvec);
-void io_buffer_unregister_bvec(struct io_uring_cmd *cmd, unsigned int index,
- unsigned int issue_flags)
+int io_buffer_unregister_bvec(struct io_uring_cmd *cmd, unsigned int index,
+ unsigned int issue_flags)
{
struct io_ring_ctx *ctx = cmd_to_io_kiocb(cmd)->ctx;
struct io_rsrc_data *data = &ctx->buf_table;
struct io_rsrc_node *node;
+ int ret = 0;
io_ring_submit_lock(ctx, issue_flags);
- if (index >= data->nr)
+ if (index >= data->nr) {
+ ret = -EINVAL;
goto unlock;
+ }
index = array_index_nospec(index, data->nr);
node = data->nodes[index];
- if (!node || !node->buf->is_kbuf)
+ if (!node) {
+ ret = -EINVAL;
goto unlock;
+ }
+ if (!node->buf->is_kbuf) {
+ ret = -EBUSY;
+ goto unlock;
+ }
io_put_rsrc_node(ctx, node);
data->nodes[index] = NULL;
unlock:
io_ring_submit_unlock(ctx, issue_flags);
+ return ret;
}
EXPORT_SYMBOL_GPL(io_buffer_unregister_bvec);