/kernel/linux/linux-5.10/fs/orangefs/ |
H A D | devorangefs-req.c | 423 if (!copy_from_iter_full(&op->downcall, downcall_size, iter)) { in orangefs_devreq_write_iter() 424 gossip_err("%s: failed to copy downcall.\n", __func__); in orangefs_devreq_write_iter() 428 if (op->downcall.status) in orangefs_devreq_write_iter() 432 * We've successfully peeled off the head and the downcall. in orangefs_devreq_write_iter() 436 if ((head_size + downcall_size + op->downcall.trailer_size) != total) { in orangefs_devreq_write_iter() 443 op->downcall.trailer_size, in orangefs_devreq_write_iter() 449 if ((op->downcall.type != ORANGEFS_VFS_OP_READDIR) && in orangefs_devreq_write_iter() 450 (op->downcall.trailer_size != 0)) { in orangefs_devreq_write_iter() 453 op->downcall.type); in orangefs_devreq_write_iter() 458 if ((op->downcall in orangefs_devreq_write_iter() [all...] |
H A D | super.c | 188 if (new_op->downcall.status < 0) in orangefs_statfs() 196 (long)new_op->downcall.resp.statfs.blocks_avail, in orangefs_statfs() 197 (long)new_op->downcall.resp.statfs.blocks_total, in orangefs_statfs() 198 (long)new_op->downcall.resp.statfs.block_size, in orangefs_statfs() 199 (long)new_op->downcall.resp.statfs.files_total, in orangefs_statfs() 200 (long)new_op->downcall.resp.statfs.files_avail); in orangefs_statfs() 204 buf->f_bsize = new_op->downcall.resp.statfs.block_size; in orangefs_statfs() 207 buf->f_blocks = (sector_t) new_op->downcall.resp.statfs.blocks_total; in orangefs_statfs() 208 buf->f_bfree = (sector_t) new_op->downcall.resp.statfs.blocks_avail; in orangefs_statfs() 209 buf->f_bavail = (sector_t) new_op->downcall in orangefs_statfs() [all...] |
H A D | waitqueue.c | 58 * Note op->downcall.status will contain the status of the operation (in 63 * Returns contents of op->downcall.status for convenience 78 op->downcall.status = 0; in service_operation() 103 op->downcall.status = ret; in service_operation() 153 /* got matching downcall; make sure status is in errno format */ in service_operation() 156 op->downcall.status = in service_operation() 157 orangefs_normalize_to_errno(op->downcall.status); in service_operation() 158 ret = op->downcall.status; in service_operation() 162 /* failed to get matching downcall */ in service_operation() 175 op->downcall in service_operation() [all...] |
H A D | xattr.c | 188 length = new_op->downcall.resp.getxattr.val_sz; in orangefs_inode_getxattr() 206 memcpy(buffer, new_op->downcall.resp.getxattr.val, length); in orangefs_inode_getxattr() 449 total = new_op->downcall.resp.listxattr.returned_count * in orangefs_listxattr() 454 returned_count = new_op->downcall.resp.listxattr.returned_count; in orangefs_listxattr() 468 if (new_op->downcall.resp.listxattr.lengths[i] < 0 || in orangefs_listxattr() 469 new_op->downcall.resp.listxattr.lengths[i] > in orangefs_listxattr() 473 new_op->downcall.resp.listxattr.lengths[i]); in orangefs_listxattr() 477 if (total + new_op->downcall.resp.listxattr.lengths[i] > size) in orangefs_listxattr() 485 if (is_reserved_key(new_op->downcall.resp.listxattr.key + in orangefs_listxattr() 487 new_op->downcall in orangefs_listxattr() [all...] |
H A D | dir.c | 96 vfree(op->downcall.trailer_buf); in do_readdir() 99 vfree(op->downcall.trailer_buf); in do_readdir() 106 vfree(op->downcall.trailer_buf); in do_readdir() 109 } else if (op->downcall.status) { in do_readdir() 110 vfree(op->downcall.trailer_buf); in do_readdir() 111 od->error = op->downcall.status; in do_readdir() 112 return op->downcall.status; in do_readdir() 119 if (op->downcall.trailer_size > PART_SIZE) { in do_readdir() 120 vfree(op->downcall.trailer_buf); in do_readdir() 126 op->downcall in do_readdir() [all...] |
H A D | orangefs-utils.c | 302 &new_op->downcall.resp.getattr.attributes, in orangefs_inode_getattr() 303 new_op->downcall.resp.getattr.link_target); in orangefs_inode_getattr() 311 downcall.resp.getattr.attributes.objtype); in orangefs_inode_getattr() 315 downcall.resp.getattr.attributes); in orangefs_inode_getattr() 318 downcall.resp.getattr.attributes.size; in orangefs_inode_getattr() 320 inode->i_blkbits = ffs(new_op->downcall.resp.getattr. in orangefs_inode_getattr() 337 downcall.resp.getattr.link_target); in orangefs_inode_getattr() 339 new_op->downcall.resp.getattr.link_target, in orangefs_inode_getattr() 357 downcall.resp.getattr.attributes.owner); in orangefs_inode_getattr() 359 downcall in orangefs_inode_getattr() [all...] |
H A D | namei.c | 52 &new_op->downcall.resp.create.refn.khandle, in orangefs_create() 53 new_op->downcall.resp.create.refn.fs_id, in orangefs_create() 60 ref = new_op->downcall.resp.create.refn; in orangefs_create() 153 &new_op->downcall.resp.lookup.refn.khandle, in orangefs_lookup() 154 new_op->downcall.resp.lookup.refn.fs_id, in orangefs_lookup() 159 inode = orangefs_iget(dir->i_sb, &new_op->downcall.resp.lookup.refn); in orangefs_lookup() 257 &new_op->downcall.resp.sym.refn.khandle, in orangefs_symlink() 258 new_op->downcall.resp.sym.refn.fs_id, ret); in orangefs_symlink() 267 ref = new_op->downcall.resp.sym.refn; in orangefs_symlink() 331 &new_op->downcall in orangefs_mkdir() [all...] |
H A D | file.c | 244 if (type == ORANGEFS_IO_READ && new_op->downcall.resp.io.amt_complete) { in wait_for_direct_io() 262 min(new_op->downcall.resp.io.amt_complete, in wait_for_direct_io() 265 copy_amount = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io() 280 (int)new_op->downcall.resp.io.amt_complete); in wait_for_direct_io() 282 ret = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io()
|
H A D | orangefs-cache.c | 17 /* a cache for orangefs upcall/downcall operations */ 127 new_op->downcall.type = ORANGEFS_VFS_OP_INVALID; in op_alloc() 128 new_op->downcall.status = -1; in op_alloc()
|
H A D | dcache.c | 58 if (!match_handle(new_op->downcall.resp.lookup.refn.khandle, in orangefs_revalidate_lookup() 71 if (new_op->downcall.status != 0) in orangefs_revalidate_lookup()
|
H A D | orangefs-sysfs.c | 501 (int)new_op->downcall.resp.param.u. in sysfs_service_op_show() 503 (int)new_op->downcall.resp.param.u. in sysfs_service_op_show() 507 (int)new_op->downcall.resp.param.u.value64); in sysfs_service_op_show() 514 new_op->downcall.resp.perf_count.buffer); in sysfs_service_op_show()
|
/kernel/linux/linux-6.6/fs/orangefs/ |
H A D | super.c | 189 if (new_op->downcall.status < 0) in orangefs_statfs() 197 (long)new_op->downcall.resp.statfs.blocks_avail, in orangefs_statfs() 198 (long)new_op->downcall.resp.statfs.blocks_total, in orangefs_statfs() 199 (long)new_op->downcall.resp.statfs.block_size, in orangefs_statfs() 200 (long)new_op->downcall.resp.statfs.files_total, in orangefs_statfs() 201 (long)new_op->downcall.resp.statfs.files_avail); in orangefs_statfs() 205 buf->f_bsize = new_op->downcall.resp.statfs.block_size; in orangefs_statfs() 208 buf->f_blocks = (sector_t) new_op->downcall.resp.statfs.blocks_total; in orangefs_statfs() 209 buf->f_bfree = (sector_t) new_op->downcall.resp.statfs.blocks_avail; in orangefs_statfs() 210 buf->f_bavail = (sector_t) new_op->downcall in orangefs_statfs() [all...] |
H A D | devorangefs-req.c | 423 if (!copy_from_iter_full(&op->downcall, downcall_size, iter)) { in orangefs_devreq_write_iter() 424 gossip_err("%s: failed to copy downcall.\n", __func__); in orangefs_devreq_write_iter() 428 if (op->downcall.status) in orangefs_devreq_write_iter() 432 * We've successfully peeled off the head and the downcall. in orangefs_devreq_write_iter() 436 if ((head_size + downcall_size + op->downcall.trailer_size) != total) { in orangefs_devreq_write_iter() 443 op->downcall.trailer_size, in orangefs_devreq_write_iter() 449 if ((op->downcall.type != ORANGEFS_VFS_OP_READDIR) && in orangefs_devreq_write_iter() 450 (op->downcall.trailer_size != 0)) { in orangefs_devreq_write_iter() 453 op->downcall.type); in orangefs_devreq_write_iter() 458 if ((op->downcall in orangefs_devreq_write_iter() [all...] |
H A D | waitqueue.c | 58 * Note op->downcall.status will contain the status of the operation (in 63 * Returns contents of op->downcall.status for convenience 78 op->downcall.status = 0; in service_operation() 103 op->downcall.status = ret; in service_operation() 153 /* got matching downcall; make sure status is in errno format */ in service_operation() 156 op->downcall.status = in service_operation() 157 orangefs_normalize_to_errno(op->downcall.status); in service_operation() 158 ret = op->downcall.status; in service_operation() 162 /* failed to get matching downcall */ in service_operation() 175 op->downcall in service_operation() [all...] |
H A D | xattr.c | 188 length = new_op->downcall.resp.getxattr.val_sz; in orangefs_inode_getxattr() 206 memcpy(buffer, new_op->downcall.resp.getxattr.val, length); in orangefs_inode_getxattr() 449 total = new_op->downcall.resp.listxattr.returned_count * in orangefs_listxattr() 454 returned_count = new_op->downcall.resp.listxattr.returned_count; in orangefs_listxattr() 468 if (new_op->downcall.resp.listxattr.lengths[i] < 0 || in orangefs_listxattr() 469 new_op->downcall.resp.listxattr.lengths[i] > in orangefs_listxattr() 473 new_op->downcall.resp.listxattr.lengths[i]); in orangefs_listxattr() 477 if (total + new_op->downcall.resp.listxattr.lengths[i] > size) in orangefs_listxattr() 485 if (is_reserved_key(new_op->downcall.resp.listxattr.key + in orangefs_listxattr() 487 new_op->downcall in orangefs_listxattr() [all...] |
H A D | dir.c | 96 vfree(op->downcall.trailer_buf); in do_readdir() 99 vfree(op->downcall.trailer_buf); in do_readdir() 106 vfree(op->downcall.trailer_buf); in do_readdir() 109 } else if (op->downcall.status) { in do_readdir() 110 vfree(op->downcall.trailer_buf); in do_readdir() 111 od->error = op->downcall.status; in do_readdir() 112 return op->downcall.status; in do_readdir() 119 if (op->downcall.trailer_size > PART_SIZE) { in do_readdir() 120 vfree(op->downcall.trailer_buf); in do_readdir() 126 op->downcall in do_readdir() [all...] |
H A D | orangefs-utils.c | 302 &new_op->downcall.resp.getattr.attributes, in orangefs_inode_getattr() 303 new_op->downcall.resp.getattr.link_target); in orangefs_inode_getattr() 311 downcall.resp.getattr.attributes.objtype); in orangefs_inode_getattr() 315 downcall.resp.getattr.attributes); in orangefs_inode_getattr() 318 downcall.resp.getattr.attributes.size; in orangefs_inode_getattr() 320 inode->i_blkbits = ffs(new_op->downcall.resp.getattr. in orangefs_inode_getattr() 337 downcall.resp.getattr.link_target); in orangefs_inode_getattr() 339 new_op->downcall.resp.getattr.link_target, in orangefs_inode_getattr() 357 downcall.resp.getattr.attributes.owner); in orangefs_inode_getattr() 359 downcall in orangefs_inode_getattr() [all...] |
H A D | namei.c | 53 &new_op->downcall.resp.create.refn.khandle, in orangefs_create() 54 new_op->downcall.resp.create.refn.fs_id, in orangefs_create() 61 ref = new_op->downcall.resp.create.refn; in orangefs_create() 154 &new_op->downcall.resp.lookup.refn.khandle, in orangefs_lookup() 155 new_op->downcall.resp.lookup.refn.fs_id, in orangefs_lookup() 160 inode = orangefs_iget(dir->i_sb, &new_op->downcall.resp.lookup.refn); in orangefs_lookup() 259 &new_op->downcall.resp.sym.refn.khandle, in orangefs_symlink() 260 new_op->downcall.resp.sym.refn.fs_id, ret); in orangefs_symlink() 269 ref = new_op->downcall.resp.sym.refn; in orangefs_symlink() 334 &new_op->downcall in orangefs_mkdir() [all...] |
H A D | dcache.c | 58 if (!match_handle(new_op->downcall.resp.lookup.refn.khandle, in orangefs_revalidate_lookup() 71 if (new_op->downcall.status != 0) in orangefs_revalidate_lookup()
|
H A D | orangefs-cache.c | 17 /* a cache for orangefs upcall/downcall operations */ 127 new_op->downcall.type = ORANGEFS_VFS_OP_INVALID; in op_alloc() 128 new_op->downcall.status = -1; in op_alloc()
|
H A D | file.c | 245 if (type == ORANGEFS_IO_READ && new_op->downcall.resp.io.amt_complete) { in wait_for_direct_io() 252 copy_amount = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io() 267 (int)new_op->downcall.resp.io.amt_complete); in wait_for_direct_io() 269 ret = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io()
|
H A D | orangefs-sysfs.c | 501 (int)new_op->downcall.resp.param.u. in sysfs_service_op_show() 503 (int)new_op->downcall.resp.param.u. in sysfs_service_op_show() 507 (int)new_op->downcall.resp.param.u.value64); in sysfs_service_op_show() 514 new_op->downcall.resp.perf_count.buffer); in sysfs_service_op_show()
|
/kernel/linux/linux-5.10/include/linux/sunrpc/ |
H A D | rpc_pipe_fs.h | 37 ssize_t (*downcall)(struct file *, const char __user *, size_t); member
|
/kernel/linux/linux-6.6/include/linux/sunrpc/ |
H A D | rpc_pipe_fs.h | 37 ssize_t (*downcall)(struct file *, const char __user *, size_t); member
|
/kernel/linux/linux-5.10/fs/nfs/blocklayout/ |
H A D | rpc_pipefs.c | 141 .downcall = bl_pipe_downcall,
|