Commit f773a7c2 authored by Bernd Schubert's avatar Bernd Schubert Committed by Miklos Szeredi
Browse files

fuse: Add fuse-io-uring handling into fuse_copy 



Add special fuse-io-uring into the fuse argument
copy handler.

Signed-off-by: default avatarBernd Schubert <bschubert@ddn.com>
Reviewed-by: default avatarJoanne Koong <joannelkoong@gmail.com>
Reviewed-by: default avatarLuis Henriques <luis@igalia.com>
Signed-off-by: default avatarMiklos Szeredi <mszeredi@redhat.com>
parent d0f9c62a

fs/fuse/dev.c

+11 −1
Original line number Diff line number Diff line
@@ -786,6 +786,9 @@ static int fuse_copy_do(struct fuse_copy_state *cs, void **val, unsigned *size) 
	*size -= ncpy;

	cs->len -= ncpy;

	cs->offset += ncpy;

	if (cs->is_uring)

		cs->ring.copied_sz += ncpy;



	return ncpy;

}
@@ -1922,7 +1925,14 @@ static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique) 
int fuse_copy_out_args(struct fuse_copy_state *cs, struct fuse_args *args,

		       unsigned nbytes)

{

	unsigned reqsize = sizeof(struct fuse_out_header);



	unsigned int reqsize = 0;



	/*

	 * Uring has all headers separated from args - args is payload only

	 */

	if (!cs->is_uring)

		reqsize = sizeof(struct fuse_out_header);



	reqsize += fuse_len_args(args->out_numargs, args->out_args);

fs/fuse/fuse_dev_i.h

+4 −0
Original line number Diff line number Diff line
@@ -27,6 +27,10 @@ struct fuse_copy_state { 
	unsigned int len;

	unsigned int offset;

	unsigned int move_pages:1;

	unsigned int is_uring:1;

	struct {

		unsigned int copied_sz; /* copied size into the user buffer */

	} ring;

};



static inline struct fuse_dev *fuse_get_dev(struct file *file)