// SPDX-License-Identifier: GPL-2.0-only /* * linux/fs/lockd/svc.c * * This is the central lockd service. * * FIXME: Separate the lockd NFS server functionality from the lockd NFS * client functionality. Oh why didn't Sun create two separate * services in the first place? * * Authors: Olaf Kirch ([email protected]) * * Copyright (C) 1995, 1996 Olaf Kirch <[email protected]> */ #include <linux/module.h> #include <linux/init.h> #include <linux/sysctl.h> #include <linux/moduleparam.h> #include <linux/sched/signal.h> #include <linux/errno.h> #include <linux/in.h> #include <linux/uio.h> #include <linux/smp.h> #include <linux/mutex.h> #include <linux/freezer.h> #include <linux/inetdevice.h> #include <linux/sunrpc/types.h> #include <linux/sunrpc/stats.h> #include <linux/sunrpc/clnt.h> #include <linux/sunrpc/svc.h> #include <linux/sunrpc/svcsock.h> #include <linux/sunrpc/svc_xprt.h> #include <net/ip.h> #include <net/addrconf.h> #include <net/ipv6.h> #include <linux/lockd/lockd.h> #include <linux/nfs.h> #include "netns.h" #include "procfs.h" #define NLMDBG_FACILITY … #define LOCKD_BUFSIZE … static struct svc_program nlmsvc_program; const struct nlmsvc_binding *nlmsvc_ops; EXPORT_SYMBOL_GPL(…); static DEFINE_MUTEX(nlmsvc_mutex); static unsigned int nlmsvc_users; static struct svc_serv *nlmsvc_serv; unsigned long nlmsvc_timeout; static void nlmsvc_request_retry(struct timer_list *tl) { … } DEFINE_TIMER(nlmsvc_retry, nlmsvc_request_retry); unsigned int lockd_net_id; /* * These can be set at insmod time (useful for NFS as root filesystem), * and also changed through the sysctl interface. -- Jamie Lokier, Aug 2003 */ static unsigned long nlm_grace_period; static unsigned long nlm_timeout = …; static int nlm_udpport, nlm_tcpport; /* RLIM_NOFILE defaults to 1024. That seems like a reasonable default here. */ static unsigned int nlm_max_connections = …; /* * Constants needed for the sysctl interface. */ static const unsigned long nlm_grace_period_min = …; static const unsigned long nlm_grace_period_max = …; static const unsigned long nlm_timeout_min = …; static const unsigned long nlm_timeout_max = …; #ifdef CONFIG_SYSCTL static const int nlm_port_min = …, nlm_port_max = …; static struct ctl_table_header * nlm_sysctl_table; #endif static unsigned long get_lockd_grace_period(void) { … } static void grace_ender(struct work_struct *grace) { … } static void set_grace_period(struct net *net) { … } /* * This is the lockd kernel thread */ static int lockd(void *vrqstp) { … } static int create_lockd_listener(struct svc_serv *serv, const char *name, struct net *net, const int family, const unsigned short port, const struct cred *cred) { … } static int create_lockd_family(struct svc_serv *serv, struct net *net, const int family, const struct cred *cred) { … } /* * Ensure there are active UDP and TCP listeners for lockd. * * Even if we have only TCP NFS mounts and/or TCP NFSDs, some * local services (such as rpc.statd) still require UDP, and * some NFS servers do not yet support NLM over TCP. * * Returns zero if all listeners are available; otherwise a * negative errno value is returned. */ static int make_socks(struct svc_serv *serv, struct net *net, const struct cred *cred) { … } static int lockd_up_net(struct svc_serv *serv, struct net *net, const struct cred *cred) { … } static void lockd_down_net(struct svc_serv *serv, struct net *net) { … } static int lockd_inetaddr_event(struct notifier_block *this, unsigned long event, void *ptr) { … } static struct notifier_block lockd_inetaddr_notifier = …; #if IS_ENABLED(CONFIG_IPV6) static int lockd_inet6addr_event(struct notifier_block *this, unsigned long event, void *ptr) { … } static struct notifier_block lockd_inet6addr_notifier = …; #endif static int lockd_get(void) { … } static void lockd_put(void) { … } /* * Bring up the lockd process if it's not already up. */ int lockd_up(struct net *net, const struct cred *cred) { … } EXPORT_SYMBOL_GPL(…); /* * Decrement the user count and bring down lockd if we're the last. */ void lockd_down(struct net *net) { … } EXPORT_SYMBOL_GPL(…); #ifdef CONFIG_SYSCTL /* * Sysctl parameters (same as module parameters, different interface). */ static struct ctl_table nlm_sysctls[] = …; #endif /* CONFIG_SYSCTL */ /* * Module (and sysfs) parameters. */ #define param_set_min_max(name, type, which_strtol, min, max) … static inline int is_callback(u32 proc) { … } static enum svc_auth_status lockd_authenticate(struct svc_rqst *rqstp) { … } param_set_min_max(…) param_set_min_max(…) param_set_min_max(…) MODULE_AUTHOR(…) …; MODULE_DESCRIPTION(…) …; MODULE_LICENSE(…) …; module_param_call(…); module_param_call(…); module_param_call(…); module_param_call(…); module_param(nsm_use_hostnames, bool, 0644); module_param(nlm_max_connections, uint, 0644); static int lockd_init_net(struct net *net) { … } static void lockd_exit_net(struct net *net) { … } static struct pernet_operations lockd_net_ops = …; /* * Initialising and terminating the module. */ static int __init init_nlm(void) { … } static void __exit exit_nlm(void) { … } module_init(…) …; module_exit(exit_nlm); /** * nlmsvc_dispatch - Process an NLM Request * @rqstp: incoming request * * Return values: * %0: Processing complete; do not send a Reply * %1: Processing complete; send Reply in rqstp->rq_res */ static int nlmsvc_dispatch(struct svc_rqst *rqstp) { … } /* * Define NLM program and procedures */ static DEFINE_PER_CPU_ALIGNED(unsigned long, nlmsvc_version1_count[17]); static const struct svc_version nlmsvc_version1 = …; static DEFINE_PER_CPU_ALIGNED(unsigned long, nlmsvc_version3_count[ARRAY_SIZE(nlmsvc_procedures)]); static const struct svc_version nlmsvc_version3 = …; #ifdef CONFIG_LOCKD_V4 static DEFINE_PER_CPU_ALIGNED(unsigned long, nlmsvc_version4_count[ARRAY_SIZE(nlmsvc_procedures4)]); static const struct svc_version nlmsvc_version4 = …; #endif static const struct svc_version *nlmsvc_version[] = …; #define NLM_NRVERS … static struct svc_program nlmsvc_program = …;
Codebase Browser
linux