Lines Matching refs:req
36 struct rpc_blobfs_set_cache_size req; in rpc_blobfs_set_cache_size() local
41 &req)) { in rpc_blobfs_set_cache_size()
49 if (req.size_in_mb == 0) { in rpc_blobfs_set_cache_size()
56 rc = spdk_fs_set_cache_size(req.size_in_mb); in rpc_blobfs_set_cache_size()
75 free_rpc_blobfs_detect(struct rpc_blobfs_detect *req) in free_rpc_blobfs_detect() argument
77 free(req->bdev_name); in free_rpc_blobfs_detect()
78 free(req); in free_rpc_blobfs_detect()
88 struct rpc_blobfs_detect *req = cb_arg; in _rpc_blobfs_detect_done() local
95 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in _rpc_blobfs_detect_done()
97 free_rpc_blobfs_detect(req); in _rpc_blobfs_detect_done()
101 spdk_jsonrpc_send_bool_response(req->request, existed); in _rpc_blobfs_detect_done()
103 free_rpc_blobfs_detect(req); in _rpc_blobfs_detect_done()
110 struct rpc_blobfs_detect *req; in rpc_blobfs_detect() local
112 req = calloc(1, sizeof(*req)); in rpc_blobfs_detect()
113 if (req == NULL) { in rpc_blobfs_detect()
121 req)) { in rpc_blobfs_detect()
126 free_rpc_blobfs_detect(req); in rpc_blobfs_detect()
131 req->request = request; in rpc_blobfs_detect()
132 spdk_blobfs_bdev_detect(req->bdev_name, _rpc_blobfs_detect_done, req); in rpc_blobfs_detect()
145 free_rpc_blobfs_create(struct rpc_blobfs_create *req) in free_rpc_blobfs_create() argument
147 free(req->bdev_name); in free_rpc_blobfs_create()
148 free(req); in free_rpc_blobfs_create()
185 struct rpc_blobfs_create *req = cb_arg; in _rpc_blobfs_create_done() local
188 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in _rpc_blobfs_create_done()
194 spdk_jsonrpc_send_bool_response(req->request, true); in _rpc_blobfs_create_done()
196 free_rpc_blobfs_create(req); in _rpc_blobfs_create_done()
203 struct rpc_blobfs_create *req; in rpc_blobfs_create() local
205 req = calloc(1, sizeof(*req)); in rpc_blobfs_create()
206 if (req == NULL) { in rpc_blobfs_create()
214 req)) { in rpc_blobfs_create()
219 free_rpc_blobfs_create(req); in rpc_blobfs_create()
224 req->request = request; in rpc_blobfs_create()
225 spdk_blobfs_bdev_create(req->bdev_name, req->cluster_sz, _rpc_blobfs_create_done, req); in rpc_blobfs_create()
241 free_rpc_blobfs_mount(struct rpc_blobfs_mount *req) in free_rpc_blobfs_mount() argument
243 free(req->bdev_name); in free_rpc_blobfs_mount()
244 free(req->mountpoint); in free_rpc_blobfs_mount()
245 free(req); in free_rpc_blobfs_mount()
256 struct rpc_blobfs_mount *req = cb_arg; in _rpc_blobfs_mount_done() local
260 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in _rpc_blobfs_mount_done()
265 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in _rpc_blobfs_mount_done()
271 spdk_jsonrpc_send_bool_response(req->request, true); in _rpc_blobfs_mount_done()
273 free_rpc_blobfs_mount(req); in _rpc_blobfs_mount_done()
280 struct rpc_blobfs_mount *req; in rpc_blobfs_mount() local
282 req = calloc(1, sizeof(*req)); in rpc_blobfs_mount()
283 if (req == NULL) { in rpc_blobfs_mount()
291 req)) { in rpc_blobfs_mount()
296 free_rpc_blobfs_mount(req); in rpc_blobfs_mount()
301 req->request = request; in rpc_blobfs_mount()
302 spdk_blobfs_bdev_mount(req->bdev_name, req->mountpoint, _rpc_blobfs_mount_done, req); in rpc_blobfs_mount()