OpenBSD-4.6/usr.sbin/amd/include/am.h

/*	$OpenBSD: am.h,v 1.11 2003/11/08 19:17:29 jmc Exp $	*/

/*
 * Copyright (c) 1990 Jan-Simon Pendry
 * Copyright (c) 1990 Imperial College of Science, Technology & Medicine
 * Copyright (c) 1990, 1993
 *	The Regents of the University of California.  All rights reserved.
 *
 * This code is derived from software contributed to Berkeley by
 * Jan-Simon Pendry at Imperial College, London.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 *	from: @(#)am.h	5.6 (Berkeley) 6/6/93
 */

#include "config.h"

/*
 * Global declarations
 */
#include <sys/param.h>
#include <sys/socket.h>
#include <rpc/rpc.h>
#include <sys/mount.h>
#include <string.h>
#include <stdlib.h>
#ifdef MNTENT_HDR
#include MNTENT_HDR
#endif /* MNTENT_HDR */
#ifndef NFS_PROTOCOL_VERSION
#if NFS_ARGSVERSION >= 3
#define NFS_PROTOCOL_VERSION 3
#endif /* NFS_ARGSVERSION >= 3 */
#endif /* NFS_PROTOCOL_VERSION */
#include "nfs_prot.h"
#include <assert.h>

#ifdef DEBUG_MEM
#include <malloc.h>
#endif /* DEBUG_MEM */

#ifndef MAXHOSTNAMELEN
#define MAXHOSTNAMELEN 64
#endif /* MAXHOSTNAMELEN */

#ifndef MNTTYPE_AUTO
#define MNTTYPE_AUTO "auto"
#endif /* MNTTYPE_AUTO */

#ifndef FALSE
#define FALSE 0
#define TRUE 1
#endif /* FALSE */

#ifndef ROOT_MAP
#define	ROOT_MAP "\"root\""
#endif /* ROOT_MAP */

/*
 * Flags from command line
 */
extern int print_pid;		/* Print pid to stdout */
extern int normalize_hosts;	/* Normalize host names before use */
extern int restart_existing_mounts;
#ifdef HAS_NIS_MAPS
extern char *domain;		/* NIS domain to use */
#endif /* HAS_NIS_MAPS */
extern int am_timeo;		/* Cache period */
extern int afs_timeo;		/* AFS timeout */
extern int afs_retrans;		/* AFS retrans */
extern int am_timeo_w;		/* Unmount timeout */
extern char *mtab;		/* Mount table */

typedef enum {
	Start,
	Run,
	Finishing,
	Quit,
	Done
} serv_state;

extern serv_state amd_state;	/* Should we go now */
extern int immediate_abort;	/* Should close-down unmounts be retried */
extern time_t do_mapc_reload;	/* Flush & reload mount map cache */

/*
 * Useful constants
 */
extern char pid_fsname[];	/* kiska.southseas.nz:(pid%d) */
extern char hostd[];		/* "kiska.southseas.nz" */
extern char *hostdomain;	/* "southseas.nz" */
extern char *op_sys;		/* "sos4" */
extern char *arch;		/* "sun4" */
extern char *karch;		/* "sun4c" */
extern char *cluster;		/* "r+d-kluster" */
extern char *endian;		/* "big" */
extern char *auto_dir;		/* "/a" */
extern char copyright[];	/* Copyright info */
extern char version[];		/* Version info */

typedef struct am_ops am_ops;
typedef struct am_node am_node;
typedef struct am_opts am_opts;
typedef struct mntfs mntfs;
typedef struct fserver fserver;
typedef struct fsrvinfo fsrvinfo;

/*
 * Debug defns.
 */
#ifdef DEBUG
#define	DEBUG_MTAB	"./mtab"

extern int debug_flags;		/* Debug options */

#define	D_DAEMON	0x0001	/* Enter daemon mode */
#define	D_TRACE		0x0002	/* Do protocol trace */
#define	D_FULL		0x0004	/* Do full trace */
#define	D_MTAB		0x0008	/* Use local mtab */
#define	D_AMQ		0x0010	/* Register amq program */
#define	D_STR		0x0020	/* Debug string munging */
#define	D_MEM		0x0040	/* Trace memory allocations */

/*
 * Normally, don't enter daemon mode, and don't register amq
 */
#define	D_TEST	(~(D_DAEMON|D_MEM|D_STR))
#endif /* DEBUG */

/*
 * Global variables.
 */
extern unsigned short nfs_port;	/* Our NFS service port */
extern struct in_addr myipaddr;	/* (An) IP address of this host */

extern int foreground;		/* Foreground process */
extern time_t next_softclock;	/* Time to call softclock() */
extern int task_notify_todo;	/* Task notifier needs running */
#ifdef HAS_TFS
extern int nfs_server_code_available;
#endif /* HAS_TFS */
extern int last_used_map;	/* Last map being used for mounts */
extern AUTH *nfs_auth;		/* Dummy uthorisation for remote servers */
extern am_node **exported_ap;	/* List of nodes */
extern int first_free_map;	/* First free node */
extern am_node *root_node;	/* Node for "root" */
extern char *wire;		/* Name of primary connected network */
#define	NEXP_AP	(254)
#define NEXP_AP_MARGIN (128)

typedef int (*task_fun)(void *);
typedef void (*cb_fun)(int, int, void *);
typedef void (*fwd_fun)(void *, int, struct sockaddr_in *,
				struct sockaddr_in *, void *, int);

/*
 * String comparison macros
 */
#define STREQ(s1, s2) (strcmp((s1), (s2)) == 0)
#define FSTREQ(s1, s2) ((*(s1) == *(s2)) && STREQ((s1),(s2)))

/*
 * Linked list
 */
typedef struct qelem qelem;
struct qelem {
	qelem *q_forw;
	qelem *q_back;
};
#define	FIRST(ty, q)	((ty *) ((q)->q_forw))
#define	LAST(ty, q)	((ty *) ((q)->q_back))
#define	NEXT(ty, q)	((ty *) (((qelem *) q)->q_forw))
#define	PREV(ty, q)	((ty *) (((qelem *) q)->q_back))
#define	HEAD(ty, q)	((ty *) q)
#define	ITER(v, ty, q) \
	for ((v) = FIRST(ty,(q)); (v) != HEAD(ty,(q)); (v) = NEXT(ty,(v)))

/*
 * List of mount table entries
 */
typedef struct mntlist mntlist;
struct mntlist {
	struct mntlist *mnext;
	struct mntent *mnt;
};

/*
 * Mount map
 */
typedef struct mnt_map mnt_map;

struct fhstatus;

/*
 * Global routines
 */
extern void	 am_mounted(am_node *);
extern void	 am_unmounted(am_node *);
extern pid_t	 background(void);
extern int	 bind_resv_port(int, unsigned short *);
extern int	 compute_mount_flags(struct mntent *);
extern int	 softclock(void);
#ifdef DEBUG
extern int	 debug_option(char *);
#endif /* DEBUG */
extern void	 deslashify(char *);
extern void	 discard_mntlist(mntlist *mp);
/*extern void	 domain_strip(char *, char *);*/
extern mntfs	*dup_mntfs(mntfs *);
extern fserver	*dup_srvr(fserver*);
extern int	eval_fs_opts(am_opts *, char *, char *, char *, char *, char *);
extern char	*expand_key(char *);
extern am_node	*exported_ap_alloc(void);
extern am_node	*find_ap(char *);
extern am_node	*find_mf(mntfs *);
extern mntfs	*find_mntfs(am_ops *, am_opts *, char *, char *, char *,
		 char *, char *);
extern void	 flush_mntfs(void);
extern void	 flush_nfs_fhandle_cache(fserver *);
extern void	 flush_srvr_nfs_cache(void);
extern void	 forcibly_timeout_mp(am_node *);
extern void	 free_mntfs(mntfs *);
extern void	 free_opts(am_opts *);
extern void	 free_map(am_node *);
extern void	 free_mntlist(mntlist *);
extern void	 free_srvr(fserver *);
extern int	 fwd_init(void);
extern int	 fwd_packet(int, void *, int, struct sockaddr_in *,
		 struct sockaddr_in *, void *, fwd_fun);
extern void	 fwd_reply(void);
extern void	 get_args(int, char *[]);
extern char	*getwire(void);
#ifdef NEED_MNTOPT_PARSER
extern char	*hasmntopt(struct mntent *, char *);
#endif /* NEED_MNTOPT_PARSER */
extern int	 hasmntval(struct mntent *, char *);
extern void	 host_normalize(char **);
extern char	*inet_dquad(char *, size_t, u_int32_t);
extern void	 init_map(am_node *, char *);
extern void	 insert_am(am_node *, am_node *);
extern void	 ins_que(qelem *, qelem *);
extern int	 islocalnet(in_addr_t);
extern int	 make_nfs_auth(void);
extern void	 make_root_node(void);
extern int	 make_rpc_packet(char *, int, u_long, struct rpc_msg *,
		 void *, xdrproc_t, AUTH *);
extern void	 map_flush_srvr(fserver *);
extern void	 mapc_add_kv(mnt_map *, char *, char *);
extern mnt_map	*mapc_find(char *, char *);
extern void	 mapc_free(mnt_map *);
extern int	 mapc_keyiter(mnt_map*, void (*)(char *,void *), void *);
extern int	 mapc_search(mnt_map *, char *, char **);
extern void	 mapc_reload(void);
extern void	 mapc_showtypes(FILE *);
extern void	 mf_mounted(mntfs *mf);
extern int	 mkdirs(char *, int);
extern void	 mk_fattr(am_node *, int);
extern void	 mnt_free(struct mntent *);
extern int	 mount_auto_node(char *, void *);
extern int	 mount_automounter(pid_t);
extern int	 mount_exported(void);
extern int	 mount_fs(struct mntent *, int, caddr_t, int, MTYPE_TYPE);
extern int	 mount_nfs_fh(struct fhstatus *, char *, char *, char *, mntfs *);
extern int	 mount_node(am_node *);
extern mntfs	*new_mntfs(void);
extern void	 new_ttl(am_node *);
extern am_node	*next_map(int *);
extern int	 nfs_srvr_port(fserver *, u_short *, void *);
extern void	 normalize_slash(char *);
extern void	 ops_showfstypes(FILE *);
extern int	 pickup_rpc_reply(void *, int, void *, xdrproc_t);
extern mntlist	*read_mtab(char *);
extern mntfs	*realloc_mntfs(mntfs *, am_ops *, am_opts *, char *,
		 char *, char *, char *, char *);
extern void	 rem_que(qelem *);
extern void	 reschedule_timeout_mp(void);
extern void	 restart(void);
#ifdef UPDATE_MTAB
extern void	 rewrite_mtab(mntlist *);
#endif /* UPDATE_MTAB */
extern void	 rmdirs(char *);
extern am_node	*root_ap(char *, int);
extern int	 root_keyiter(void (*)(char *,void *), void *);
extern void	 root_newmap(char *, char *, char *);
extern void	 rpc_msg_init(struct rpc_msg *, u_long, u_long, u_long);
extern void	 run_task(task_fun, void *, cb_fun, void *);
extern void	 sched_task(cb_fun, void *, void *);
extern void	 show_rcs_info(const char *, char *);
extern void	 sigchld(int);
extern void	 srvrlog(fserver *, char *);
extern char	*str3cat(char *, char *, char *, char *);
extern char	*strnsave(const char *, int);
extern char	*strealloc(char *, char *);
extern char	**strsplit(char *, int, int);
extern int	 switch_option(char *);
extern int	 switch_to_logfile(char *);
extern void	 do_task_notify(void);
extern int	 timeout(unsigned int, void (*fn)(), void *);
extern void	 timeout_mp(void);
extern void	 umount_exported(void);
extern int	 umount_fs(char *);
/*extern int unmount_node(am_node*);
extern int unmount_node_wrap(void *);*/
extern void	 unregister_amq(void);
extern void	 untimeout(int);
extern int	 valid_key(char *);
extern void	 wakeup(void *);
extern void	 wakeup_task(int, int, void *);
extern void	 wakeup_srvr(fserver *);
extern void	 write_mntent(struct mntent *);
#ifdef UPDATE_MTAB
extern void	 unlock_mntlist(void);
#else
#define	unlock_mntlist()
#endif /* UPDATE_MTAB */


#define	ALLOC(ty)	((struct ty *) xmalloc(sizeof(struct ty)))

/*
 * Options
 */
struct am_opts {
	char	*fs_glob;		/* Smashed copy of global options */
	char	*fs_local;		/* Expanded copy of local options */
	char	*fs_mtab;		/* Mount table entry */
	/* Other options ... */
	char	*opt_dev;
	char	*opt_delay;
	char	*opt_dir;
	char	*opt_fs;
	char	*opt_group;
	char	*opt_mount;
	char	*opt_opts;
	char	*opt_remopts;
	char	*opt_pref;
	char	*opt_cache;
	char	*opt_rfs;
	char	*opt_rhost;
	char	*opt_sublink;
	char	*opt_type;
	char	*opt_unmount;
	char	*opt_user;
};

/*
 * File Handle
 *
 * This is interpreted by indexing the exported array
 * by fhh_id.
 *
 * The whole structure is mapped onto a standard fhandle_t
 * when transmitted.
 */
struct am_fh {
	int	fhh_pid;		/* process id */
	int	fhh_id;			/* map id */
	int	fhh_gen;		/* generation number */
};

extern am_node	*fh_to_mp(nfs_fh *);
extern am_node	*fh_to_mp3(nfs_fh *, int *, int);
extern void	 mp_to_fh(am_node *, nfs_fh *);
#define	fh_to_mp2(fhp, rp) fh_to_mp3(fhp, rp, VLOOK_CREATE)
extern int	 auto_fmount(am_node *mp);
extern int	 auto_fumount(am_node *mp);

#define	MAX_READDIR_ENTRIES	16

typedef char	*(*vfs_match)(am_opts *);
typedef int	 (*vfs_init)(mntfs *);
typedef int	 (*vmount_fs)(am_node *);
typedef int	 (*vfmount_fs)(mntfs *);
typedef int	 (*vumount_fs)(am_node *);
typedef int	 (*vfumount_fs)(mntfs *);
typedef am_node	*(*vlookuppn)(am_node *, char *, int *, int);
typedef int	 (*vreaddir)(am_node *, nfscookie, dirlist *, entry *, int);
typedef am_node	*(*vreadlink)(am_node *, int *);
typedef void	 (*vmounted)(mntfs *);
typedef void	 (*vumounted)(am_node *);
typedef fserver	*(*vffserver)(mntfs *);

struct am_ops {
	char		*fs_type;
	vfs_match	fs_match;
	vfs_init	fs_init;
	vmount_fs	mount_fs;
	vfmount_fs	fmount_fs;
	vumount_fs	umount_fs;
	vfumount_fs	fumount_fs;
	vlookuppn	lookuppn;
	vreaddir	readdir;
	vreadlink	readlink;
	vmounted	mounted;
	vumounted	umounted;
	vffserver	ffserver;
	int		fs_flags;
};
extern am_node	*efs_lookuppn(am_node *, char *, int *, int);
extern int	 efs_readdir(am_node *, nfscookie, dirlist *, entry *, int);

#define	VLOOK_CREATE	0x1
#define	VLOOK_DELETE	0x2

#define FS_DIRECTORY	0x0001		/* This looks like a dir, not a link */
#define	FS_MBACKGROUND	0x0002		/* Should background this mount */
#define	FS_NOTIMEOUT	0x0004		/* Don't bother with timeouts */
#define FS_MKMNT	0x0008		/* Need to make the mount point */
#define FS_UBACKGROUND	0x0010		/* Unmount in background */
#define	FS_BACKGROUND	(FS_MBACKGROUND|FS_UBACKGROUND)
#define	FS_DISCARD	0x0020		/* Discard immediately on last reference */
#define	FS_AMQINFO	0x0040		/* Amq is interested in this fs type */

#ifdef SUNOS4_COMPAT
extern am_ops	*sunos4_match(am_opts *, char *, char *, char *, char *, char *);
#endif /* SUNOS4_COMPAT */
extern am_ops	*ops_match(am_opts *, char *, char *, char *, char *, char *);
#include "fstype.h"

/*
 * Per-mountpoint statistics
 */
struct am_stats {
	time_t	s_mtime;	/* Mount time */
	u_short	s_uid;		/* Uid of mounter */
	int	s_getattr;	/* Count of getattrs */
	int	s_lookup;	/* Count of lookups */
	int	s_readdir;	/* Count of readdirs */
	int	s_readlink;	/* Count of readlinks */
	int	s_statfs;	/* Count of statfs */
};
typedef struct am_stats am_stats;

/*
 * System statistics
 */
struct amd_stats {
	int	d_drops;	/* Dropped requests */
	int	d_stale;	/* Stale NFS handles */
	int	d_mok;		/* Successful mounts */
	int	d_merr;		/* Failed mounts */
	int	d_uerr;		/* Failed unmounts */
};
extern struct amd_stats amd_stats;

/*
 * List of fileservers
 */
struct fserver {
	qelem		fs_q;		/* List of fileservers */
	int		fs_refc;	/* Number of references to this node */
	char		*fs_host;	/* Normalized hostname of server */
	struct sockaddr_in *fs_ip;	/* Network address of server */
	int		fs_cid;		/* Callout id */
	int		fs_pinger;	/* Ping (keepalive) interval */
	int		fs_flags;	/* Flags */
	char		*fs_type;	/* File server type */
	void 		*fs_private;	/* Private data */
	void		(*fs_prfree)();	/* Free private data */
};
#define	FSF_VALID	0x0001		/* Valid information available */
#define	FSF_DOWN	0x0002		/* This fileserver is thought to be down */
#define	FSF_ERROR	0x0004		/* Permanent error has occured */
#define	FSF_WANT	0x0008		/* Want a wakeup call */
#define	FSF_PINGING	0x0010		/* Already doing pings */
#define	FSRV_ISDOWN(fs)	(((fs)->fs_flags & (FSF_DOWN|FSF_VALID)) == (FSF_DOWN|FSF_VALID))
#define	FSRV_ISUP(fs)	(((fs)->fs_flags & (FSF_DOWN|FSF_VALID)) == (FSF_VALID))

/*
 * List of mounted filesystems
 */
struct mntfs {
	qelem		mf_q;		/* List of mounted filesystems */
	am_ops		*mf_ops;	/* Operations on this mountpoint */
	am_opts		*mf_fo;		/* File opts */
	char		*mf_mount;	/* "/a/kiska/home/kiska" */
	char		*mf_info;	/* Mount info */
	char		*mf_auto;	/* Automount opts */
	char		*mf_mopts;	/* FS mount opts */
	char		*mf_remopts;	/* Remote FS mount opts */
	fserver		*mf_server;	/* File server */
	int		mf_flags;	/* Flags */
	int		mf_error;	/* Error code from background mount */
	int		mf_refc;	/* Number of references to this node */
	int		mf_cid;		/* Callout id */
	void		(*mf_prfree)();	/* Free private space */
	void 		*mf_private;	/* Private - per-fs data */
};

#define	MFF_MOUNTED	0x0001		/* Node is mounted */
#define	MFF_MOUNTING	0x0002		/* Mount is in progress */
#define	MFF_UNMOUNTING	0x0004		/* Unmount is in progress */
#define	MFF_RESTART	0x0008		/* Restarted node */
#define MFF_MKMNT	0x0010		/* Delete this node's am_mount */
#define	MFF_ERROR	0x0020		/* This node failed to mount */
#define	MFF_LOGDOWN	0x0040		/* Logged that this mount is down */
#define	MFF_RSTKEEP	0x0080		/* Don't timeout this filesystem - restarted */
#define	MFF_WANTTIMO	0x0100		/* Need a timeout call when not busy */

/*
 * Map of auto-mount points.
 */
struct am_node {
	int		am_mapno;	/* Map number */
	mntfs		*am_mnt;	/* Mounted filesystem */
	char		*am_name;	/* "kiska"
					   Name of this node */
	char		*am_path;	/* "/home/kiska"
					   Path of this node's mount point */
	char		*am_link;	/* "/a/kiska/home/kiska/this/that"
					   Link to sub-directory */
	am_node		*am_parent,	/* Parent of this node */
			*am_ysib,	/* Younger sibling of this node */
			*am_osib,	/* Older sibling of this node */
			*am_child;	/* First child of this node */
	struct attrstat	am_attr;	/* File attributes */
#define am_fattr	am_attr.attrstat_u.attributes
	int		am_flags;	/* Boolean flags */
	int		am_error;	/* Specific mount error */
	time_t		am_ttl;		/* Time to live */
	int		am_timeo_w;	/* Wait interval */
	int		am_timeo;	/* Timeout interval */
	unsigned int	am_gen;		/* Generation number */
	char		*am_pref;	/* Mount info prefix */
	am_stats	am_stats;	/* Statistics gathering */
};

#define	AMF_NOTIMEOUT	0x0001		/* This node never times out */
#define	AMF_ROOT	0x0002		/* This is a root node */

#define	ONE_HOUR	(60 * 60)	/* One hour in seconds */

/*
 * The following values can be tuned...
 */
#define	ALLOWED_MOUNT_TIME	40		/* 40s for a mount */
#define	AM_TTL			(5 * 60)	/* Default cache period */
#define	AM_TTL_W		(2 * 60)	/* Default unmount interval */
#define	AM_PINGER		30		/* NFS ping interval for live systems */
#define	AFS_TIMEO		8		/* Default afs timeout - .8s */
#define	AFS_RETRANS		((ALLOWED_MOUNT_TIME*10+5*afs_timeo)/afs_timeo * 2)
						/* Default afs retrans - 1/10th seconds */

#define	RPC_XID_PORTMAP		0
#define	RPC_XID_MOUNTD		1
#define	RPC_XID_NFSPING		2
#define	RPC_XID_MASK		(0x0f)		/* 16 id's for now */
#define	MK_RPC_XID(type_id, uniq)	((type_id) | ((uniq) << 4))