/* * Copyright (c) 2002 Red Hat, Inc. All rights reserved. * * This software may be freely redistributed under the terms of the * GNU General Public License. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. * * Authors: David Woodhouse <dwmw2@cambridge.redhat.com> * David Howells <dhowells@redhat.com> * */ #include <linux/kernel.h> #include <linux/module.h> #include <linux/init.h> #include "server.h" #include "vnode.h" #include "internal.h" #include "cmservice.h" /*****************************************************************************/ /* * allow the fileserver to request callback state (re-)initialisation */ int SRXAFSCM_InitCallBackState(struct afs_server *server) { struct list_head callbacks; _enter("%p", server); INIT_LIST_HEAD(&callbacks); /* transfer the callback list from the server to a temp holding area */ spin_lock(&server->cb_lock); list_add(&callbacks, &server->cb_promises); list_del_init(&server->cb_promises); /* munch our way through the list, grabbing the inode, dropping all the * locks and regetting them in the right order */ while (!list_empty(&callbacks)) { struct afs_vnode *vnode; struct inode *inode; vnode = list_entry(callbacks.next, struct afs_vnode, cb_link); list_del_init(&vnode->cb_link); /* try and grab the inode - may fail */ inode = igrab(AFS_VNODE_TO_I(vnode)); if (inode) { int release = 0; spin_unlock(&server->cb_lock); spin_lock(&vnode->lock); if (vnode->cb_server == server) { vnode->cb_server = NULL; afs_kafstimod_del_timer(&vnode->cb_timeout); spin_lock(&afs_cb_hash_lock); list_del_init(&vnode->cb_hash_link); spin_unlock(&afs_cb_hash_lock); release = 1; } spin_unlock(&vnode->lock); iput(inode); afs_put_server(server); spin_lock(&server->cb_lock); } } spin_unlock(&server->cb_lock); _leave(" = 0"); return 0; } /* end SRXAFSCM_InitCallBackState() */ /*****************************************************************************/ /* * allow the fileserver to break callback promises */ int SRXAFSCM_CallBack(struct afs_server *server, size_t count, struct afs_callback callbacks[]) { _enter("%p,%u,", server, count); for (; count > 0; callbacks++, count--) { struct afs_vnode *vnode = NULL; struct inode *inode = NULL; int valid = 0; _debug("- Fid { vl=%08x n=%u u=%u } CB { v=%u x=%u t=%u }", callbacks->fid.vid, callbacks->fid.vnode, callbacks->fid.unique, callbacks->version, callbacks->expiry, callbacks->type ); /* find the inode for this fid */ spin_lock(&afs_cb_hash_lock); list_for_each_entry(vnode, &afs_cb_hash(server, &callbacks->fid), cb_hash_link) { if (memcmp(&vnode->fid, &callbacks->fid, sizeof(struct afs_fid)) != 0) continue; /* right vnode, but is it same server? */ if (vnode->cb_server != server) break; /* no */ /* try and nail the inode down */ inode = igrab(AFS_VNODE_TO_I(vnode)); break; } spin_unlock(&afs_cb_hash_lock); if (inode) { /* we've found the record for this vnode */ spin_lock(&vnode->lock); if (vnode->cb_server == server) { /* the callback _is_ on the calling server */ vnode->cb_server = NULL; valid = 1; afs_kafstimod_del_timer(&vnode->cb_timeout); vnode->flags |= AFS_VNODE_CHANGED; spin_lock(&server->cb_lock); list_del_init(&vnode->cb_link); spin_unlock(&server->cb_lock); spin_lock(&afs_cb_hash_lock); list_del_init(&vnode->cb_hash_link); spin_unlock(&afs_cb_hash_lock); } spin_unlock(&vnode->lock); if (valid) { invalidate_remote_inode(inode); afs_put_server(server); } iput(inode); } } _leave(" = 0"); return 0; } /* end SRXAFSCM_CallBack() */ /*****************************************************************************/ /* * allow the fileserver to see if the cache manager is still alive */ int SRXAFSCM_Probe(struct afs_server *server) { _debug("SRXAFSCM_Probe(%p)\n", server); return 0; } /* end SRXAFSCM_Probe() */