static void io_rsrc_put_work(struct io_rsrc_node *node)
{
- struct io_rsrc_data *data = node->rsrc_data;
struct io_rsrc_put *prsrc = &node->item;
if (prsrc->tag)
- io_post_aux_cqe(data->ctx, prsrc->tag, 0, 0);
+ io_post_aux_cqe(node->ctx, prsrc->tag, 0, 0);
- switch (data->rsrc_type) {
+ switch (node->type) {
case IORING_RSRC_FILE:
- io_rsrc_file_put(data->ctx, prsrc);
+ io_rsrc_file_put(node->ctx, prsrc);
break;
case IORING_RSRC_BUFFER:
- io_rsrc_buf_put(data->ctx, prsrc);
+ io_rsrc_buf_put(node->ctx, prsrc);
break;
default:
WARN_ON_ONCE(1);
}
void io_rsrc_node_ref_zero(struct io_rsrc_node *node)
- __must_hold(&node->rsrc_data->ctx->uring_lock)
+ __must_hold(&node->ctx->uring_lock)
{
- struct io_ring_ctx *ctx = node->rsrc_data->ctx;
+ struct io_ring_ctx *ctx = node->ctx;
while (!list_empty(&ctx->rsrc_ref_list)) {
node = list_first_entry(&ctx->rsrc_ref_list,
return NULL;
}
- ref_node->rsrc_data = NULL;
+ ref_node->ctx = ctx;
ref_node->empty = 0;
ref_node->refs = 1;
return ref_node;
if (!backup)
return -ENOMEM;
ctx->rsrc_node->empty = true;
- ctx->rsrc_node->rsrc_data = data;
+ ctx->rsrc_node->type = -1;
list_add_tail(&ctx->rsrc_node->node, &ctx->rsrc_ref_list);
io_put_rsrc_node(ctx, ctx->rsrc_node);
ctx->rsrc_node = backup;
}
node->item.rsrc = rsrc;
+ node->type = data->rsrc_type;
node->item.tag = *tag_slot;
*tag_slot = 0;
-
- node->rsrc_data = data;
list_add_tail(&node->node, &ctx->rsrc_ref_list);
io_put_rsrc_node(ctx, node);
return 0;