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

fuse: rename to fuse_dev_end_requests and make non-static 



This function is needed by fuse_uring.c to clean ring queues,
so make it non static. Especially in non-static mode the function
name 'end_requests' should be prefixed with fuse_

Signed-off-by: default avatarBernd Schubert <bschubert@ddn.com>
Reviewed-by: default avatarJosef Bacik <josef@toxicpanda.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 ffd294d3

fs/fuse/dev.c

+5 −6
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ 
*/



#include "fuse_i.h"

#include "fuse_dev_i.h"



#include <linux/init.h>

#include <linux/module.h>
@@ -34,8 +35,6 @@ MODULE_ALIAS("devname:fuse"); 


static struct kmem_cache *fuse_req_cachep;



static void end_requests(struct list_head *head);



static struct fuse_dev *fuse_get_dev(struct file *file)

{

	/*
@@ -1885,7 +1884,7 @@ static void fuse_resend(struct fuse_conn *fc) 
		spin_unlock(&fiq->lock);

		list_for_each_entry(req, &to_queue, list)

			clear_bit(FR_PENDING, &req->flags);

		end_requests(&to_queue);

		fuse_dev_end_requests(&to_queue);

		return;

	}

	/* iq and pq requests are both oldest to newest */
@@ -2204,7 +2203,7 @@ static __poll_t fuse_dev_poll(struct file *file, poll_table *wait) 
}



/* Abort all requests on the given list (pending or processing) */

static void end_requests(struct list_head *head)

void fuse_dev_end_requests(struct list_head *head)

{

	while (!list_empty(head)) {

		struct fuse_req *req;
@@ -2307,7 +2306,7 @@ void fuse_abort_conn(struct fuse_conn *fc) 
		wake_up_all(&fc->blocked_waitq);

		spin_unlock(&fc->lock);



		end_requests(&to_end);

		fuse_dev_end_requests(&to_end);

	} else {

		spin_unlock(&fc->lock);

	}
@@ -2337,7 +2336,7 @@ int fuse_dev_release(struct inode *inode, struct file *file) 
			list_splice_init(&fpq->processing[i], &to_end);

		spin_unlock(&fpq->lock);



		end_requests(&to_end);

		fuse_dev_end_requests(&to_end);



		/* Are we the last open device? */

		if (atomic_dec_and_test(&fc->dev_count)) {

fs/fuse/fuse_dev_i.h

0 → 100644
+14 −0
Original line number Diff line number Diff line 
/* SPDX-License-Identifier: GPL-2.0

 *

 * FUSE: Filesystem in Userspace

 * Copyright (C) 2001-2008  Miklos Szeredi <miklos@szeredi.hu>

 */

#ifndef _FS_FUSE_DEV_I_H

#define _FS_FUSE_DEV_I_H



#include <linux/types.h>



void fuse_dev_end_requests(struct list_head *head);



#endif