/* $NetBSD: map.c,v 1.2 2015/01/21 21:48:23 joerg Exp $ */
/*
* Copyright (c) 1997-2014 Erez Zadok
* Copyright (c) 1990 Jan-Simon Pendry
* Copyright (c) 1990 Imperial College of Science, Technology & Medicine
* Copyright (c) 1990 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.
*
*
* File: am-utils/amd/map.c
*
*/
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif /* HAVE_CONFIG_H */
#include <am_defs.h>
#include <amd.h>
#define smallest_t(t1, t2) (t1 != NEVER ? (t2 != NEVER ? (t1 < t2 ? t1 : t2) : t1) : t2)
#define IGNORE_FLAGS (MFF_MOUNTING|MFF_UNMOUNTING|MFF_RESTART)
#define new_gen() (am_gen++)
/*
* Generation Numbers.
*
* Generation numbers are allocated to every node created
* by amd. When a filehandle is computed and sent to the
* kernel, the generation number makes sure that it is safe
* to reallocate a node slot even when the kernel has a cached
* reference to its old incarnation.
* No garbage collection is done, since it is assumed that
* there is no way that 2^32 generation numbers could ever
* be allocated by a single run of amd - there is simply
* not enough cpu time available.
* Famous last words... -Ion
*/
static u_int am_gen = 2; /* Initial generation number */
static int timeout_mp_id; /* Id from last call to timeout */
static am_node *root_node; /* The root of the mount tree */
static am_node **exported_ap = (am_node **) NULL;
static int exported_ap_size = 0;
static int first_free_map = 0; /* First available free slot */
static int last_used_map = -1; /* Last unavailable used slot */
/*
* This is the default attributes field which
* is copied into every new node to be created.
* The individual filesystem fs_init() routines
* patch the copy to represent the particular
* details for the relevant filesystem type
*/
static nfsfattr gen_fattr =
{
NFLNK, /* type */
NFSMODE_LNK | 0777, /* mode */
1, /* nlink */
0, /* uid */
0, /* gid */
0, /* size */
4096, /* blocksize */
0, /* rdev */
1, /* blocks */
0, /* fsid */
0, /* fileid */
{0, 0}, /* atime */
{0, 0}, /* mtime */
{0, 0}, /* ctime */
};
/* forward declarations */
static int unmount_node(opaque_t arg);
static void exported_ap_free(am_node *mp);
static void remove_am(am_node *mp);
static am_node *get_root_ap(char *dir);
/*
* Iterator functions for exported_ap[]
*/
am_node *
get_first_exported_ap(int *index)
{
*index = -1;
return get_next_exported_ap(index);
}
am_node *
get_next_exported_ap(int *index)
{
(*index)++;
while (*index < exported_ap_size) {
if (exported_ap[*index] != NULL)
return exported_ap[*index];
(*index)++;
}
return NULL;
}
/*
* Get exported_ap by index
*/
am_node *
get_exported_ap(int index)
{
if (index < 0 || index >= exported_ap_size)
return 0;
return exported_ap[index];
}
/*
* Get exported_ap by path
*/
am_node *
path_to_exported_ap(char *path)
{
int index;
am_node *mp;
mp = get_first_exported_ap(&index);
while (mp != NULL) {
if (STREQ(mp->am_path, path))
break;
mp = get_next_exported_ap(&index);
}
return mp;
}
/*
* Resize exported_ap map
*/
static int
exported_ap_realloc_map(int nsize)
{
/*
* this shouldn't happen, but...
*/
if (nsize < 0 || nsize == exported_ap_size)
return 0;
exported_ap = (am_node **) xrealloc((voidp) exported_ap, nsize * sizeof(am_node *));
if (nsize > exported_ap_size)
memset((char *) (exported_ap + exported_ap_size), 0,
(nsize - exported_ap_size) * sizeof(am_node *));
exported_ap_size = nsize;
return 1;
}
am_node *
get_ap_child(am_node *mp, char *fname)
{
am_node *new_mp;
mntfs *mf = mp->am_al->al_mnt;
/*
* Allocate a new map
*/
new_mp = exported_ap_alloc();
if (new_mp) {
/*
* Fill it in
*/
init_map(new_mp, fname);
/*
* Put it in the table
*/
insert_am(new_mp, mp);
/*
* Fill in some other fields,
* path and mount point.
*
* bugfix: do not prepend old am_path if direct map
* <
[email protected]> William Sebok
*/
new_mp->am_path = str3cat(new_mp->am_path,
(mf->mf_fsflags & FS_DIRECT)
? ""
: mp->am_path,
*fname == '/' ? "" : "/", fname);
dlog("setting path to %s", new_mp->am_path);
}
return new_mp;
}
/*
* Allocate a new mount slot and create
* a new node.
* Fills in the map number of the node,
* but leaves everything else uninitialized.
*/
am_node *
exported_ap_alloc(void)
{
am_node *mp, **mpp;
/*
* First check if there are any slots left, realloc if needed
*/
if (first_free_map >= exported_ap_size)
if (!exported_ap_realloc_map(exported_ap_size + NEXP_AP))
return 0;
/*
* Grab the next free slot
*/
mpp = exported_ap + first_free_map;
mp = *mpp = ALLOC(struct am_node);
memset((char *) mp, 0, sizeof(struct am_node));
mp->am_mapno = first_free_map++;
/*
* Update free pointer
*/
while (first_free_map < exported_ap_size && exported_ap[first_free_map])
first_free_map++;
if (first_free_map > last_used_map)
last_used_map = first_free_map - 1;
return mp;
}
/*
* Free a mount slot
*/
static void
exported_ap_free(am_node *mp)
{
/*
* Sanity check
*/
if (!mp)
return;
/*
* Zero the slot pointer to avoid double free's
*/
exported_ap[mp->am_mapno] = NULL;
/*
* Update the free and last_used indices
*/
if (mp->am_mapno == last_used_map)
while (last_used_map >= 0 && exported_ap[last_used_map] == 0)
--last_used_map;
if (first_free_map > mp->am_mapno)
first_free_map = mp->am_mapno;
/*
* Free the mount node, and zero out it's internal struct data.
*/
memset((char *) mp, 0, sizeof(am_node));
XFREE(mp);
}
/*
* Insert mp into the correct place,
* where p_mp is its parent node.
* A new node gets placed as the youngest sibling
* of any other children, and the parent's child
* pointer is adjusted to point to the new child node.
*/
void
insert_am(am_node *mp, am_node *p_mp)
{
/*
* If this is going in at the root then flag it
* so that it cannot be unmounted by amq.
*/
if (p_mp == root_node)
mp->am_flags |= AMF_ROOT;
/*
* Fill in n-way links
*/
mp->am_parent = p_mp;
mp->am_osib = p_mp->am_child;
if (mp->am_osib)
mp->am_osib->am_ysib = mp;
p_mp->am_child = mp;
#ifdef HAVE_FS_AUTOFS
if (p_mp->am_al->al_mnt->mf_flags & MFF_IS_AUTOFS)
mp->am_flags |= AMF_AUTOFS;
#endif /* HAVE_FS_AUTOFS */
}
/*
* Remove am from its place in the mount tree
*/
static void
remove_am(am_node *mp)
{
/*
* 1. Consistency check
*/
if (mp->am_child && mp->am_parent) {
plog(XLOG_WARNING, "children of \"%s\" still exist - deleting anyway", mp->am_path);
}
/*
* 2. Update parent's child pointer
*/
if (mp->am_parent && mp->am_parent->am_child == mp)
mp->am_parent->am_child = mp->am_osib;
/*
* 3. Unlink from sibling chain
*/
if (mp->am_ysib)
mp->am_ysib->am_osib = mp->am_osib;
if (mp->am_osib)
mp->am_osib->am_ysib = mp->am_ysib;
}
/*
* Compute a new time to live value for a node.
*/
void
new_ttl(am_node *mp)
{
mp->am_timeo_w = 0;
mp->am_ttl = clocktime(&mp->am_fattr.na_atime);
mp->am_ttl += mp->am_timeo; /* sun's -tl option */
}
void
mk_fattr(nfsfattr *fattr, nfsftype vntype)
{
switch (vntype) {
case NFDIR:
fattr->na_type = NFDIR;
fattr->na_mode = NFSMODE_DIR | 0555;
fattr->na_nlink = 2;
fattr->na_size = 512;
break;
case NFLNK:
fattr->na_type = NFLNK;
fattr->na_mode = NFSMODE_LNK | 0777;
fattr->na_nlink = 1;
fattr->na_size = 0;
break;
default:
plog(XLOG_FATAL, "Unknown fattr type %d - ignored", vntype);
break;
}
}
/*
* Initialize an allocated mount node.
* It is assumed that the mount node was b-zero'd
* before getting here so anything that would
* be set to zero isn't done here.
*/
void
init_map(am_node *mp, char *dir)
{
/*
* mp->am_mapno is initialized by exported_ap_alloc
* other fields don't need to be set to zero.
*/
mp->am_al = new_loc();
mp->am_alarray = NULL;
mp->am_name = xstrdup(dir);
mp->am_path = xstrdup(dir);
mp->am_gen = new_gen();
#ifdef HAVE_FS_AUTOFS
mp->am_autofs_fh = NULL;
#endif /* HAVE_FS_AUTOFS */
mp->am_timeo = gopt.am_timeo;
mp->am_attr.ns_status = NFS_OK;
mp->am_fattr = gen_fattr;
mp->am_fattr.na_fsid = 42;
mp->am_fattr.na_fileid = mp->am_gen;
clocktime(&mp->am_fattr.na_atime);
/* next line copies a "struct nfstime" among several fields */
mp->am_fattr.na_mtime = mp->am_fattr.na_ctime = mp->am_fattr.na_atime;
new_ttl(mp);
mp->am_stats.s_mtime = mp->am_fattr.na_atime.nt_seconds;
mp->am_dev = -1;
mp->am_rdev = -1;
mp->am_fd[0] = -1;
mp->am_fd[1] = -1;
}
void
notify_child(am_node *mp, au_etype au_etype, int au_errno, int au_signal)
{
amq_sync_umnt rv;
int err;
if (mp->am_fd[1] >= 0) { /* we have a child process */
rv.au_etype = au_etype;
rv.au_signal = au_signal;
rv.au_errno = au_errno;
err = write(mp->am_fd[1], &rv, sizeof(rv));
/* XXX: do something else on err? */
if (err < sizeof(rv))
plog(XLOG_INFO, "notify_child: write returned %d instead of %d.",
err, (int) sizeof(rv));
close(mp->am_fd[1]);
mp->am_fd[1] = -1;
}
}
/*
* Free a mount node.
* The node must be already unmounted.
*/
void
free_map(am_node *mp)
{
remove_am(mp);
if (mp->am_fd[1] != -1)
plog(XLOG_FATAL, "free_map: called prior to notifying the child for %s.",
mp->am_path);
XFREE(mp->am_link);
XFREE(mp->am_name);
XFREE(mp->am_path);
XFREE(mp->am_pref);
XFREE(mp->am_transp);
if (mp->am_al)
free_loc(mp->am_al);
if (mp->am_alarray) {
am_loc **temp_al;
for (temp_al = mp->am_alarray; *temp_al; temp_al++)
free_loc(*temp_al);
XFREE(mp->am_alarray);
}
#ifdef HAVE_FS_AUTOFS
if (mp->am_autofs_fh)
autofs_release_fh(mp);
#endif /* HAVE_FS_AUTOFS */
exported_ap_free(mp);
}
static am_node *
find_ap_recursive(char *dir, am_node *mp)
{
if (mp) {
am_node *mp2;
if (STREQ(mp->am_path, dir))
return mp;
if ((mp->am_al->al_mnt->mf_flags & MFF_MOUNTED) &&
STREQ(mp->am_al->al_mnt->mf_mount, dir))
return mp;
mp2 = find_ap_recursive(dir, mp->am_osib);
if (mp2)
return mp2;
return find_ap_recursive(dir, mp->am_child);
}
return 0;
}
/*
* Find the mount node corresponding to dir. dir can match either the
* automount path or, if the node is mounted, the mount location.
*/
am_node *
find_ap(char *dir)
{
int i;
for (i = last_used_map; i >= 0; --i) {
am_node *mp = exported_ap[i];
if (mp && (mp->am_flags & AMF_ROOT)) {
mp = find_ap_recursive(dir, exported_ap[i]);
if (mp) {
return mp;
}
}
}
return 0;
}
/*
* Get the filehandle for a particular named directory.
* This is used during the bootstrap to tell the kernel
* the filehandles of the initial automount points.
*/
am_nfs_handle_t *
get_root_nfs_fh(char *dir, am_nfs_handle_t *nfh)
{
am_node *mp = get_root_ap(dir);
if (mp) {
if (nfs_dispatcher == nfs_program_2)
mp_to_fh(mp, &nfh->v2);
else
mp_to_fh3(mp, &nfh->v3);
return nfh;
}
/*
* Should never get here...
*/
plog(XLOG_ERROR, "Can't find root filehandle for %s", dir);
return 0;
}
static am_node *
get_root_ap(char *dir)
{
am_node *mp = find_ap(dir);
if (mp && mp->am_parent == root_node)
return mp;
return 0;
}
/*
* Timeout all nodes waiting on
* a given Fserver.
*/
void
map_flush_srvr(fserver *fs)
{
int i;
int done = 0;
for (i = last_used_map; i >= 0; --i) {
am_node *mp = exported_ap[i];
if (mp && mp->am_al->al_mnt && mp->am_al->al_mnt->mf_server == fs) {
plog(XLOG_INFO, "Flushed %s; dependent on %s", mp->am_path, fs->fs_host);
mp->am_ttl = clocktime(NULL);
done = 1;
}
}
if (done)
reschedule_timeout_mp();
}
/*
* Mount a top level automount node
* by calling lookup in the parent
* (root) node which will cause the
* automount node to be automounted.
*/
int
mount_auto_node(char *dir, opaque_t arg)
{
int error = 0;
am_node *mp = (am_node *) arg;
am_node *new_mp;
new_mp = mp->am_al->al_mnt->mf_ops->lookup_child(mp, dir, &error, VLOOK_CREATE);
if (new_mp && error < 0) {
/*
* We can't allow the fileid of the root node to change.
* Should be ok to force it to 1, always.
*/
new_mp->am_gen = new_mp->am_fattr.na_fileid = 1;
(void) mp->am_al->al_mnt->mf_ops->mount_child(new_mp, &error);
}
if (error > 0) {
errno = error; /* XXX */
plog(XLOG_ERROR, "Could not mount %s: %m", dir);
}
return error;
}
/*
* Cause all the top-level mount nodes
* to be automounted
*/
int
mount_exported(void)
{
/*
* Iterate over all the nodes to be started
*/
return root_keyiter(mount_auto_node, root_node);
}
/*
* Construct top-level node
*/
void
make_root_node(void)
{
mntfs *root_mf;
char *rootmap = ROOT_MAP;
root_node = exported_ap_alloc();
/*
* Allocate a new map
*/
init_map(root_node, "");
/*
* Allocate a new mounted filesystem
*/
root_mf = find_mntfs(&amfs_root_ops, (am_opts *) NULL, "", rootmap, "", "", "");
/*
* Replace the initial null reference
*/
free_mntfs(root_node->am_al->al_mnt);
root_node->am_al->al_mnt = root_mf;
/*
* Initialize the root
*/
if (root_mf->mf_ops->fs_init)
(*root_mf->mf_ops->fs_init) (root_mf);
/*
* Mount the root
*/
root_mf->mf_error = root_mf->mf_ops->mount_fs(root_node, root_mf);
}
/*
* Cause all the nodes to be unmounted by timing
* them out.
*/
void
umount_exported(void)
{
int i, work_done;
do {
work_done = 0;
for (i = last_used_map; i >= 0; --i) {
am_node *mp = exported_ap[i];
mntfs *mf;
if (!mp)
continue;
/*
* Wait for children to be removed first
*/
if (mp->am_child)
continue;
mf = mp->am_al->al_mnt;
if (mf->mf_flags & MFF_UNMOUNTING) {
/*
* If this node is being unmounted then just ignore it. However,
* this could prevent amd from finishing if the unmount gets blocked
* since the am_node will never be free'd. am_unmounted needs
* telling about this possibility. - XXX
*/
continue;
}
if (!(mf->mf_fsflags & FS_DIRECTORY))
/*
* When shutting down this had better
* look like a directory, otherwise it
* can't be unmounted!
*/
mk_fattr(&mp->am_fattr, NFDIR);
if ((--immediate_abort < 0 &&
!(mp->am_flags & AMF_ROOT) && mp->am_parent) ||
(mf->mf_flags & MFF_RESTART)) {
work_done++;
/*
* Just throw this node away without bothering to unmount it. If
* the server is not known to be up then don't discard the mounted
* on directory or Amd might hang...
*/
if (mf->mf_server &&
(mf->mf_server->fs_flags & (FSF_DOWN | FSF_VALID)) != FSF_VALID)
mf->mf_flags &= ~MFF_MKMNT;
if (gopt.flags & CFM_UNMOUNT_ON_EXIT || mp->am_flags & AMF_AUTOFS) {
plog(XLOG_INFO, "on-exit attempt to unmount %s", mf->mf_mount);
/*
* use unmount_mp, not unmount_node, so that unmounts be
* backgrounded as needed.
*/
unmount_mp((opaque_t) mp);
} else {
am_unmounted(mp);
}
if (!(mf->mf_flags & (MFF_UNMOUNTING|MFF_MOUNTED)))
exported_ap[i] = NULL;
} else {
/*
* Any other node gets forcibly timed out.
*/
mp->am_flags &= ~AMF_NOTIMEOUT;
mp->am_al->al_mnt->mf_flags &= ~MFF_RSTKEEP;
mp->am_ttl = 0;
mp->am_timeo = 1;
mp->am_timeo_w = 0;
}
}
} while (work_done);
}
/*
* Try to mount a file system. Can be called directly or in a sub-process by run_task.
*
* Warning: this function might be running in a child process context.
* Don't expect any changes made here to survive in the parent amd process.
*/
int
mount_node(opaque_t arg)
{
am_node *mp = (am_node *) arg;
mntfs *mf = mp->am_al->al_mnt;
int error = 0;
#ifdef HAVE_FS_AUTOFS
if (mp->am_flags & AMF_AUTOFS)
error = autofs_mount_fs(mp, mf);
else
#endif /* HAVE_FS_AUTOFS */
if (!(mf->mf_flags & MFF_MOUNTED))
error = mf->mf_ops->mount_fs(mp, mf);
if (error > 0)
dlog("mount_node: call to mf_ops->mount_fs(%s) failed: %s",
mp->am_path, strerror(error));
return error;
}
static int
unmount_node(opaque_t arg)
{
am_node *mp = (am_node *) arg;
mntfs *mf = mp->am_al->al_mnt;
int error = 0;
if (mf->mf_flags & MFF_ERROR) {
/*
* Just unlink
*/
dlog("No-op unmount of error node %s", mf->mf_info);
} else {
dlog("Unmounting <%s> <%s> (%s) flags %x",
mp->am_path, mf->mf_mount, mf->mf_info, mf->mf_flags);
#ifdef HAVE_FS_AUTOFS
if (mp->am_flags & AMF_AUTOFS)
error = autofs_umount_fs(mp, mf);
else
#endif /* HAVE_FS_AUTOFS */
if (mf->mf_refc == 1)
error = mf->mf_ops->umount_fs(mp, mf);
}
/* do this again, it might have changed */
mf = mp->am_al->al_mnt;
if (error) {
errno = error; /* XXX */
dlog("%s: unmount: %m", mf->mf_mount);
}
return error;
}
static void
free_map_if_success(int rc, int term, opaque_t arg)
{
am_node *mp = (am_node *) arg;
mntfs *mf = mp->am_al->al_mnt;
wchan_t wchan = get_mntfs_wchan(mf);
/*
* Not unmounting any more
*/
mf->mf_flags &= ~MFF_UNMOUNTING;
/*
* If a timeout was deferred because the underlying filesystem
* was busy then arrange for a timeout as soon as possible.
*/
if (mf->mf_flags & MFF_WANTTIMO) {
mf->mf_flags &= ~MFF_WANTTIMO;
reschedule_timeout_mp();
}
if (term) {
notify_child(mp, AMQ_UMNT_SIGNAL, 0, term);
plog(XLOG_ERROR, "unmount for %s got signal %d", mp->am_path, term);
#if defined(DEBUG) && defined(SIGTRAP)
/*
* dbx likes to put a trap on exit().
* Pretend it succeeded for now...
*/
if (term == SIGTRAP) {
am_unmounted(mp);
}
#endif /* DEBUG */
#ifdef HAVE_FS_AUTOFS
if (mp->am_flags & AMF_AUTOFS)
autofs_umount_failed(mp);
#endif /* HAVE_FS_AUTOFS */
amd_stats.d_uerr++;
} else if (rc) {
notify_child(mp, AMQ_UMNT_FAILED, rc, 0);
if (mf->mf_ops == &amfs_program_ops || rc == EBUSY)
plog(XLOG_STATS, "\"%s\" on %s still active", mp->am_path, mf->mf_mount);
else
plog(XLOG_ERROR, "%s: unmount: %s", mp->am_path, strerror(rc));
#ifdef HAVE_FS_AUTOFS
if (rc != ENOENT) {
if (mf->mf_flags & MFF_IS_AUTOFS)
autofs_get_mp(mp);
if (mp->am_flags & AMF_AUTOFS)
autofs_umount_failed(mp);
}
#endif /* HAVE_FS_AUTOFS */
amd_stats.d_uerr++;
} else {
/*
* am_unmounted() will call notify_child() appropriately.
*/
am_unmounted(mp);
}
/*
* Wakeup anything waiting for this unmount
*/
wakeup(wchan);
}
int
unmount_mp(am_node *mp)
{
int was_backgrounded = 0;
mntfs *mf = mp->am_al->al_mnt;
#ifdef notdef
plog(XLOG_INFO, "\"%s\" on %s timed out (flags 0x%x)",
mp->am_path, mf->mf_mount, (int) mf->mf_flags);
#endif /* notdef */
#ifndef MNT2_NFS_OPT_SYMTTL
/*
* This code is needed to defeat Solaris 2.4's (and newer) symlink
* values cache. It forces the last-modified time of the symlink to be
* current. It is not needed if the O/S has an nfs flag to turn off the
* symlink-cache at mount time (such as Irix 5.x and 6.x). -Erez.
*
* Additionally, Linux currently ignores the nt_useconds field,
* so we must update the nt_seconds field every time if clocktime(NULL)
* didn't return a new number of seconds.
*/
if (mp->am_parent) {
time_t last = mp->am_parent->am_attr.ns_u.ns_attr_u.na_mtime.nt_seconds;
clocktime(&mp->am_parent->am_attr.ns_u.ns_attr_u.na_mtime);
/* defensive programming... can't we assert the above condition? */
if (last == (time_t) mp->am_parent->am_attr.ns_u.ns_attr_u.na_mtime.nt_seconds)
mp->am_parent->am_attr.ns_u.ns_attr_u.na_mtime.nt_seconds++;
}
#endif /* not MNT2_NFS_OPT_SYMTTL */
if (mf->mf_refc == 1 && !FSRV_ISUP(mf->mf_server)) {
/*
* Don't try to unmount from a server that is known to be down
*/
if (!(mf->mf_flags & MFF_LOGDOWN)) {
/* Only log this once, otherwise gets a bit boring */
plog(XLOG_STATS, "file server %s is down - timeout of \"%s\" ignored", mf->mf_server->fs_host, mp->am_path);
mf->mf_flags |= MFF_LOGDOWN;
}
notify_child(mp, AMQ_UMNT_SERVER, 0, 0);
return 0;
}
dlog("\"%s\" on %s timed out", mp->am_path, mf->mf_mount);
mf->mf_flags |= MFF_UNMOUNTING;
#ifdef HAVE_FS_AUTOFS
if (mf->mf_flags & MFF_IS_AUTOFS)
autofs_release_mp(mp);
#endif /* HAVE_FS_AUTOFS */
if ((mf->mf_fsflags & FS_UBACKGROUND) &&
(mf->mf_flags & MFF_MOUNTED) &&
!(mf->mf_flags & MFF_ON_AUTOFS)) {
dlog("Trying unmount in background");
run_task(unmount_node, (opaque_t) mp,
free_map_if_success, (opaque_t) mp);
was_backgrounded = 1;
} else {
dlog("Trying unmount in foreground");
free_map_if_success(unmount_node((opaque_t) mp), 0, (opaque_t) mp);
dlog("unmount attempt done");
}
return was_backgrounded;
}
void
timeout_mp(opaque_t v) /* argument not used?! */
{
int i;
time_t t = NEVER;
time_t now = clocktime(NULL);
int backoff = NumChildren / 4;
dlog("Timing out automount points...");
for (i = last_used_map; i >= 0; --i) {
am_node *mp = exported_ap[i];
mntfs *mf;
/*
* Just continue if nothing mounted
*/
if (!mp)
continue;
/*
* Pick up mounted filesystem
*/
mf = mp->am_al->al_mnt;
if (!mf)
continue;
#ifdef HAVE_FS_AUTOFS
if (mf->mf_flags & MFF_IS_AUTOFS && mp->am_autofs_ttl != NEVER) {
if (now >= mp->am_autofs_ttl)
autofs_timeout_mp(mp);
t = smallest_t(t, mp->am_autofs_ttl);
}
#endif /* HAVE_FS_AUTOFS */
if (mp->am_flags & AMF_NOTIMEOUT)
continue;
/*
* Don't delete last reference to a restarted filesystem.
*/
if ((mf->mf_flags & MFF_RSTKEEP) && mf->mf_refc == 1)
continue;
/*
* If there is action on this filesystem then ignore it
*/
if (!(mf->mf_flags & IGNORE_FLAGS)) {
int expired = 0;
mf->mf_flags &= ~MFF_WANTTIMO;
if (now >= mp->am_ttl) {
if (!backoff) {
expired = 1;
/*
* Move the ttl forward to avoid thrashing effects
* on the next call to timeout!
*/
/* sun's -tw option */
if (mp->am_timeo_w < 4 * gopt.am_timeo_w)
mp->am_timeo_w += gopt.am_timeo_w;
mp->am_ttl = now + mp->am_timeo_w;
} else {
/*
* Just backoff this unmount for
* a couple of seconds to avoid
* many multiple unmounts being
* started in parallel.
*/
mp->am_ttl = now + backoff + 1;
}
}
/*
* If the next ttl is smallest, use that
*/
t = smallest_t(t, mp->am_ttl);
if (!mp->am_child && mf->mf_error >= 0 && expired) {
/*
* If the unmount was backgrounded then
* bump the backoff counter.
*/
if (unmount_mp(mp)) {
backoff = 2;
}
}
} else if (mf->mf_flags & MFF_UNMOUNTING) {
mf->mf_flags |= MFF_WANTTIMO;
}
}
if (t == NEVER) {
dlog("No further timeouts");
t = now + ONE_HOUR;
}
/*
* Sanity check to avoid runaways.
* Absolutely should never get this but
* if you do without this trap amd will thrash.
*/
if (t <= now) {
t = now + 6; /* XXX */
plog(XLOG_ERROR, "Got a zero interval in timeout_mp()!");
}
/*
* XXX - when shutting down, make things happen faster
*/
if ((int) amd_state >= (int) Finishing)
t = now + 1;
dlog("Next mount timeout in %lds", (long) (t - now));
timeout_mp_id = timeout(t - now, timeout_mp, NULL);
}
/*
* Cause timeout_mp to be called soonest
*/
void
reschedule_timeout_mp(void)
{
if (timeout_mp_id)
untimeout(timeout_mp_id);
timeout_mp_id = timeout(0, timeout_mp, NULL);
}
