4c4cd222ee
We shouldn't be allowing, e.g., write locks on files not open for read. To enforce this, we add a pointer from the lock stateid back to the open stateid it came from, so that the check will continue to be correct even after the open is upgraded or downgraded. Signed-off-by: Andy Adamson <andros@citi.umich.edu> Signed-off-by: J. Bruce Fields <bfields@citi.umich.edu> Signed-off-by: Neil Brown <neilb@cse.unsw.edu.au> Signed-off-by: Andrew Morton <akpm@osdl.org> Signed-off-by: Linus Torvalds <torvalds@osdl.org>
311 lines
11 KiB
C
311 lines
11 KiB
C
/*
|
|
* linux/include/nfsd/state.h
|
|
*
|
|
* Copyright (c) 2001 The Regents of the University of Michigan.
|
|
* All rights reserved.
|
|
*
|
|
* Kendrick Smith <kmsmith@umich.edu>
|
|
* Andy Adamson <andros@umich.edu>
|
|
*
|
|
* 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 ``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.
|
|
*
|
|
*/
|
|
|
|
#ifndef _NFSD4_STATE_H
|
|
#define _NFSD4_STATE_H
|
|
|
|
#include <linux/list.h>
|
|
#include <linux/kref.h>
|
|
#include <linux/sunrpc/clnt.h>
|
|
|
|
#define NFS4_OPAQUE_LIMIT 1024
|
|
typedef struct {
|
|
u32 cl_boot;
|
|
u32 cl_id;
|
|
} clientid_t;
|
|
|
|
typedef struct {
|
|
u32 so_boot;
|
|
u32 so_stateownerid;
|
|
u32 so_fileid;
|
|
} stateid_opaque_t;
|
|
|
|
typedef struct {
|
|
u32 si_generation;
|
|
stateid_opaque_t si_opaque;
|
|
} stateid_t;
|
|
#define si_boot si_opaque.so_boot
|
|
#define si_stateownerid si_opaque.so_stateownerid
|
|
#define si_fileid si_opaque.so_fileid
|
|
|
|
|
|
struct nfs4_cb_recall {
|
|
u32 cbr_ident;
|
|
int cbr_trunc;
|
|
stateid_t cbr_stateid;
|
|
u32 cbr_fhlen;
|
|
u32 cbr_fhval[NFS4_FHSIZE];
|
|
struct nfs4_delegation *cbr_dp;
|
|
};
|
|
|
|
struct nfs4_delegation {
|
|
struct list_head dl_perfile;
|
|
struct list_head dl_perclnt;
|
|
struct list_head dl_recall_lru; /* delegation recalled */
|
|
atomic_t dl_count; /* ref count */
|
|
struct nfs4_client *dl_client;
|
|
struct nfs4_file *dl_file;
|
|
struct file_lock *dl_flock;
|
|
struct file *dl_vfs_file;
|
|
u32 dl_type;
|
|
time_t dl_time;
|
|
struct nfs4_cb_recall dl_recall;
|
|
};
|
|
|
|
#define dl_stateid dl_recall.cbr_stateid
|
|
#define dl_fhlen dl_recall.cbr_fhlen
|
|
#define dl_fhval dl_recall.cbr_fhval
|
|
|
|
/* client delegation callback info */
|
|
struct nfs4_callback {
|
|
/* SETCLIENTID info */
|
|
u32 cb_addr;
|
|
unsigned short cb_port;
|
|
u32 cb_prog;
|
|
u32 cb_ident;
|
|
/* RPC client info */
|
|
atomic_t cb_set; /* successful CB_NULL call */
|
|
struct rpc_program cb_program;
|
|
struct rpc_stat cb_stat;
|
|
struct rpc_clnt * cb_client;
|
|
};
|
|
|
|
#define HEXDIR_LEN 33 /* hex version of 16 byte md5 of cl_name plus '\0' */
|
|
|
|
/*
|
|
* struct nfs4_client - one per client. Clientids live here.
|
|
* o Each nfs4_client is hashed by clientid.
|
|
*
|
|
* o Each nfs4_clients is also hashed by name
|
|
* (the opaque quantity initially sent by the client to identify itself).
|
|
*
|
|
* o cl_perclient list is used to ensure no dangling stateowner references
|
|
* when we expire the nfs4_client
|
|
*/
|
|
struct nfs4_client {
|
|
struct list_head cl_idhash; /* hash by cl_clientid.id */
|
|
struct list_head cl_strhash; /* hash by cl_name */
|
|
struct list_head cl_openowners;
|
|
struct list_head cl_delegations;
|
|
struct list_head cl_lru; /* tail queue */
|
|
struct xdr_netobj cl_name; /* id generated by client */
|
|
char cl_recdir[HEXDIR_LEN]; /* recovery dir */
|
|
nfs4_verifier cl_verifier; /* generated by client */
|
|
time_t cl_time; /* time of last lease renewal */
|
|
u32 cl_addr; /* client ipaddress */
|
|
struct svc_cred cl_cred; /* setclientid principal */
|
|
clientid_t cl_clientid; /* generated by server */
|
|
nfs4_verifier cl_confirm; /* generated by server */
|
|
struct nfs4_callback cl_callback; /* callback info */
|
|
atomic_t cl_count; /* ref count */
|
|
u32 cl_firststate; /* recovery dir creation */
|
|
};
|
|
|
|
/* struct nfs4_client_reset
|
|
* one per old client. Populates reset_str_hashtbl. Filled from conf_id_hashtbl
|
|
* upon lease reset, or from upcall to state_daemon (to read in state
|
|
* from non-volitile storage) upon reboot.
|
|
*/
|
|
struct nfs4_client_reclaim {
|
|
struct list_head cr_strhash; /* hash by cr_name */
|
|
char cr_recdir[HEXDIR_LEN]; /* recover dir */
|
|
};
|
|
|
|
static inline void
|
|
update_stateid(stateid_t *stateid)
|
|
{
|
|
stateid->si_generation++;
|
|
}
|
|
|
|
/* A reasonable value for REPLAY_ISIZE was estimated as follows:
|
|
* The OPEN response, typically the largest, requires
|
|
* 4(status) + 8(stateid) + 20(changeinfo) + 4(rflags) + 8(verifier) +
|
|
* 4(deleg. type) + 8(deleg. stateid) + 4(deleg. recall flag) +
|
|
* 20(deleg. space limit) + ~32(deleg. ace) = 112 bytes
|
|
*/
|
|
|
|
#define NFSD4_REPLAY_ISIZE 112
|
|
|
|
/*
|
|
* Replay buffer, where the result of the last seqid-mutating operation
|
|
* is cached.
|
|
*/
|
|
struct nfs4_replay {
|
|
u32 rp_status;
|
|
unsigned int rp_buflen;
|
|
char *rp_buf;
|
|
unsigned intrp_allocated;
|
|
int rp_openfh_len;
|
|
char rp_openfh[NFS4_FHSIZE];
|
|
char rp_ibuf[NFSD4_REPLAY_ISIZE];
|
|
};
|
|
|
|
/*
|
|
* nfs4_stateowner can either be an open_owner, or a lock_owner
|
|
*
|
|
* so_idhash: stateid_hashtbl[] for open owner, lockstateid_hashtbl[]
|
|
* for lock_owner
|
|
* so_strhash: ownerstr_hashtbl[] for open_owner, lock_ownerstr_hashtbl[]
|
|
* for lock_owner
|
|
* so_perclient: nfs4_client->cl_perclient entry - used when nfs4_client
|
|
* struct is reaped.
|
|
* so_perfilestate: heads the list of nfs4_stateid (either open or lock)
|
|
* and is used to ensure no dangling nfs4_stateid references when we
|
|
* release a stateowner.
|
|
* so_perlockowner: (open) nfs4_stateid->st_perlockowner entry - used when
|
|
* close is called to reap associated byte-range locks
|
|
* so_close_lru: (open) stateowner is placed on this list instead of being
|
|
* reaped (when so_perfilestate is empty) to hold the last close replay.
|
|
* reaped by laundramat thread after lease period.
|
|
*/
|
|
struct nfs4_stateowner {
|
|
struct kref so_ref;
|
|
struct list_head so_idhash; /* hash by so_id */
|
|
struct list_head so_strhash; /* hash by op_name */
|
|
struct list_head so_perclient;
|
|
struct list_head so_stateids;
|
|
struct list_head so_perstateid; /* for lockowners only */
|
|
struct list_head so_close_lru; /* tail queue */
|
|
time_t so_time; /* time of placement on so_close_lru */
|
|
int so_is_open_owner; /* 1=openowner,0=lockowner */
|
|
u32 so_id;
|
|
struct nfs4_client * so_client;
|
|
/* after increment in ENCODE_SEQID_OP_TAIL, represents the next
|
|
* sequence id expected from the client: */
|
|
u32 so_seqid;
|
|
struct xdr_netobj so_owner; /* open owner name */
|
|
int so_confirmed; /* successful OPEN_CONFIRM? */
|
|
struct nfs4_replay so_replay;
|
|
};
|
|
|
|
/*
|
|
* nfs4_file: a file opened by some number of (open) nfs4_stateowners.
|
|
* o fi_perfile list is used to search for conflicting
|
|
* share_acces, share_deny on the file.
|
|
*/
|
|
struct nfs4_file {
|
|
struct kref fi_ref;
|
|
struct list_head fi_hash; /* hash by "struct inode *" */
|
|
struct list_head fi_stateids;
|
|
struct list_head fi_delegations;
|
|
struct inode *fi_inode;
|
|
u32 fi_id; /* used with stateowner->so_id
|
|
* for stateid_hashtbl hash */
|
|
};
|
|
|
|
/*
|
|
* nfs4_stateid can either be an open stateid or (eventually) a lock stateid
|
|
*
|
|
* (open)nfs4_stateid: one per (open)nfs4_stateowner, nfs4_file
|
|
*
|
|
* st_hash: stateid_hashtbl[] entry or lockstateid_hashtbl entry
|
|
* st_perfile: file_hashtbl[] entry.
|
|
* st_perfile_state: nfs4_stateowner->so_perfilestate
|
|
* st_perlockowner: (open stateid) list of lock nfs4_stateowners
|
|
* st_access_bmap: used only for open stateid
|
|
* st_deny_bmap: used only for open stateid
|
|
* st_openstp: open stateid lock stateid was derived from
|
|
*
|
|
* XXX: open stateids and lock stateids have diverged sufficiently that
|
|
* we should consider defining separate structs for the two cases.
|
|
*/
|
|
|
|
struct nfs4_stateid {
|
|
struct list_head st_hash;
|
|
struct list_head st_perfile;
|
|
struct list_head st_perstateowner;
|
|
struct list_head st_lockowners;
|
|
struct nfs4_stateowner * st_stateowner;
|
|
struct nfs4_file * st_file;
|
|
stateid_t st_stateid;
|
|
struct file * st_vfs_file;
|
|
unsigned long st_access_bmap;
|
|
unsigned long st_deny_bmap;
|
|
struct nfs4_stateid * st_openstp;
|
|
};
|
|
|
|
/* flags for preprocess_seqid_op() */
|
|
#define CHECK_FH 0x00000001
|
|
#define CONFIRM 0x00000002
|
|
#define OPEN_STATE 0x00000004
|
|
#define LOCK_STATE 0x00000008
|
|
#define RD_STATE 0x00000010
|
|
#define WR_STATE 0x00000020
|
|
#define CLOSE_STATE 0x00000040
|
|
#define DELEG_RET 0x00000080
|
|
|
|
#define seqid_mutating_err(err) \
|
|
(((err) != nfserr_stale_clientid) && \
|
|
((err) != nfserr_bad_seqid) && \
|
|
((err) != nfserr_stale_stateid) && \
|
|
((err) != nfserr_bad_stateid))
|
|
|
|
extern int nfsd4_renew(clientid_t *clid);
|
|
extern int nfs4_preprocess_stateid_op(struct svc_fh *current_fh,
|
|
stateid_t *stateid, int flags, struct file **filp);
|
|
extern void nfs4_lock_state(void);
|
|
extern void nfs4_unlock_state(void);
|
|
extern int nfs4_in_grace(void);
|
|
extern int nfs4_check_open_reclaim(clientid_t *clid);
|
|
extern void put_nfs4_client(struct nfs4_client *clp);
|
|
extern void nfs4_free_stateowner(struct kref *kref);
|
|
extern void nfsd4_probe_callback(struct nfs4_client *clp);
|
|
extern void nfsd4_cb_recall(struct nfs4_delegation *dp);
|
|
extern void nfs4_put_delegation(struct nfs4_delegation *dp);
|
|
extern int nfs4_make_rec_clidname(char *clidname, struct xdr_netobj *clname);
|
|
extern void nfsd4_init_recdir(char *recdir_name);
|
|
extern int nfsd4_recdir_load(void);
|
|
extern void nfsd4_shutdown_recdir(void);
|
|
extern int nfs4_client_to_reclaim(const char *name);
|
|
extern int nfs4_has_reclaimed_state(const char *name);
|
|
extern void nfsd4_recdir_purge_old(void);
|
|
extern int nfsd4_create_clid_dir(struct nfs4_client *clp);
|
|
extern void nfsd4_remove_clid_dir(struct nfs4_client *clp);
|
|
|
|
static inline void
|
|
nfs4_put_stateowner(struct nfs4_stateowner *so)
|
|
{
|
|
kref_put(&so->so_ref, nfs4_free_stateowner);
|
|
}
|
|
|
|
static inline void
|
|
nfs4_get_stateowner(struct nfs4_stateowner *so)
|
|
{
|
|
kref_get(&so->so_ref);
|
|
}
|
|
|
|
#endif /* NFSD4_STATE_H */
|