Lines Matching refs:ctx
198 free_rpc_bdev_raid_create_ctx(struct rpc_bdev_raid_create_ctx *ctx)
203 if (!ctx) {
207 req = &ctx->req;
214 free(ctx);
220 struct rpc_bdev_raid_create_ctx *ctx = _ctx;
223 ctx->status = status;
226 assert(ctx->remaining != 0);
227 if (--ctx->remaining > 0) {
231 if (ctx->status != 0) {
232 raid_bdev_delete(ctx->raid_bdev, NULL, NULL);
233 spdk_jsonrpc_send_error_response_fmt(ctx->request, ctx->status,
235 ctx->req.name,
236 spdk_strerror(-ctx->status));
238 spdk_jsonrpc_send_bool_response(ctx->request, true);
241 free_rpc_bdev_raid_create_ctx(ctx);
262 struct rpc_bdev_raid_create_ctx *ctx;
265 ctx = calloc(1, sizeof(*ctx));
266 if (ctx == NULL) {
270 req = &ctx->req;
299 ctx->raid_bdev = raid_bdev;
300 ctx->request = request;
301 ctx->remaining = num_base_bdevs;
309 rpc_bdev_raid_create_add_base_bdev_cb, ctx);
312 assert(ctx->remaining > 1 || i + 1 == num_base_bdevs);
313 rpc_bdev_raid_create_add_base_bdev_cb(ctx, 0);
317 ctx->remaining -= (num_base_bdevs - i - 1);
318 rpc_bdev_raid_create_add_base_bdev_cb(ctx, rc);
324 free_rpc_bdev_raid_create_ctx(ctx);
373 struct rpc_bdev_raid_delete_ctx *ctx = cb_arg;
374 struct spdk_jsonrpc_request *request = ctx->request;
378 ctx->req.name, rc, spdk_strerror(-rc));
386 free_rpc_bdev_raid_delete(&ctx->req);
387 free(ctx);
405 struct rpc_bdev_raid_delete_ctx *ctx;
408 ctx = calloc(1, sizeof(*ctx));
409 if (!ctx) {
416 &ctx->req)) {
422 raid_bdev = raid_bdev_find_by_name(ctx->req.name);
426 ctx->req.name);
430 ctx->request = request;
432 raid_bdev_delete(raid_bdev, bdev_raid_delete_done, ctx);
437 free_rpc_bdev_raid_delete(&ctx->req);
438 free(ctx);
478 rpc_bdev_raid_add_base_bdev_done(void *ctx, int status)
480 struct spdk_jsonrpc_request *request = ctx;
551 rpc_bdev_raid_remove_base_bdev_done(void *ctx, int status)
553 struct spdk_jsonrpc_request *request = ctx;