42acd02182
Currently session draining only drains the fore channel. The back channel processing must also be drained. Use the back channel highest_slot_used to indicate that a callback is being processed by the callback thread. Move the session complete to be per channel. When the session is draininig, wait for any current back channel processing to complete and stop all new back channel processing by returning NFS4ERR_DELAY to the back channel client. Drain the back channel, then the fore channel. Signed-off-by: Andy Adamson <andros@netapp.com> Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
170 lines
4.2 KiB
C
170 lines
4.2 KiB
C
/*
|
|
* linux/fs/nfs/callback.h
|
|
*
|
|
* Copyright (C) 2004 Trond Myklebust
|
|
*
|
|
* NFSv4 callback definitions
|
|
*/
|
|
#ifndef __LINUX_FS_NFS_CALLBACK_H
|
|
#define __LINUX_FS_NFS_CALLBACK_H
|
|
|
|
#define NFS4_CALLBACK 0x40000000
|
|
#define NFS4_CALLBACK_XDRSIZE 2048
|
|
#define NFS4_CALLBACK_BUFSIZE (1024 + NFS4_CALLBACK_XDRSIZE)
|
|
|
|
enum nfs4_callback_procnum {
|
|
CB_NULL = 0,
|
|
CB_COMPOUND = 1,
|
|
};
|
|
|
|
enum nfs4_callback_opnum {
|
|
OP_CB_GETATTR = 3,
|
|
OP_CB_RECALL = 4,
|
|
/* Callback operations new to NFSv4.1 */
|
|
OP_CB_LAYOUTRECALL = 5,
|
|
OP_CB_NOTIFY = 6,
|
|
OP_CB_PUSH_DELEG = 7,
|
|
OP_CB_RECALL_ANY = 8,
|
|
OP_CB_RECALLABLE_OBJ_AVAIL = 9,
|
|
OP_CB_RECALL_SLOT = 10,
|
|
OP_CB_SEQUENCE = 11,
|
|
OP_CB_WANTS_CANCELLED = 12,
|
|
OP_CB_NOTIFY_LOCK = 13,
|
|
OP_CB_NOTIFY_DEVICEID = 14,
|
|
OP_CB_ILLEGAL = 10044,
|
|
};
|
|
|
|
struct cb_process_state {
|
|
__be32 drc_status;
|
|
struct nfs_client *clp;
|
|
struct nfs4_sessionid *svc_sid; /* v4.1 callback service sessionid */
|
|
};
|
|
|
|
struct cb_compound_hdr_arg {
|
|
unsigned int taglen;
|
|
const char *tag;
|
|
unsigned int minorversion;
|
|
unsigned int cb_ident; /* v4.0 callback identifier */
|
|
unsigned nops;
|
|
};
|
|
|
|
struct cb_compound_hdr_res {
|
|
__be32 *status;
|
|
unsigned int taglen;
|
|
const char *tag;
|
|
__be32 *nops;
|
|
};
|
|
|
|
struct cb_getattrargs {
|
|
struct sockaddr *addr;
|
|
struct nfs_fh fh;
|
|
uint32_t bitmap[2];
|
|
};
|
|
|
|
struct cb_getattrres {
|
|
__be32 status;
|
|
uint32_t bitmap[2];
|
|
uint64_t size;
|
|
uint64_t change_attr;
|
|
struct timespec ctime;
|
|
struct timespec mtime;
|
|
};
|
|
|
|
struct cb_recallargs {
|
|
struct sockaddr *addr;
|
|
struct nfs_fh fh;
|
|
nfs4_stateid stateid;
|
|
uint32_t truncate;
|
|
};
|
|
|
|
#if defined(CONFIG_NFS_V4_1)
|
|
|
|
struct referring_call {
|
|
uint32_t rc_sequenceid;
|
|
uint32_t rc_slotid;
|
|
};
|
|
|
|
struct referring_call_list {
|
|
struct nfs4_sessionid rcl_sessionid;
|
|
uint32_t rcl_nrefcalls;
|
|
struct referring_call *rcl_refcalls;
|
|
};
|
|
|
|
struct cb_sequenceargs {
|
|
struct sockaddr *csa_addr;
|
|
struct nfs4_sessionid csa_sessionid;
|
|
uint32_t csa_sequenceid;
|
|
uint32_t csa_slotid;
|
|
uint32_t csa_highestslotid;
|
|
uint32_t csa_cachethis;
|
|
uint32_t csa_nrclists;
|
|
struct referring_call_list *csa_rclists;
|
|
};
|
|
|
|
struct cb_sequenceres {
|
|
__be32 csr_status;
|
|
struct nfs4_sessionid csr_sessionid;
|
|
uint32_t csr_sequenceid;
|
|
uint32_t csr_slotid;
|
|
uint32_t csr_highestslotid;
|
|
uint32_t csr_target_highestslotid;
|
|
};
|
|
|
|
extern __be32 nfs4_callback_sequence(struct cb_sequenceargs *args,
|
|
struct cb_sequenceres *res,
|
|
struct cb_process_state *cps);
|
|
|
|
extern int nfs41_validate_delegation_stateid(struct nfs_delegation *delegation,
|
|
const nfs4_stateid *stateid);
|
|
|
|
#define RCA4_TYPE_MASK_RDATA_DLG 0
|
|
#define RCA4_TYPE_MASK_WDATA_DLG 1
|
|
|
|
struct cb_recallanyargs {
|
|
struct sockaddr *craa_addr;
|
|
uint32_t craa_objs_to_keep;
|
|
uint32_t craa_type_mask;
|
|
};
|
|
|
|
extern __be32 nfs4_callback_recallany(struct cb_recallanyargs *args,
|
|
void *dummy,
|
|
struct cb_process_state *cps);
|
|
|
|
struct cb_recallslotargs {
|
|
struct sockaddr *crsa_addr;
|
|
uint32_t crsa_target_max_slots;
|
|
};
|
|
extern __be32 nfs4_callback_recallslot(struct cb_recallslotargs *args,
|
|
void *dummy,
|
|
struct cb_process_state *cps);
|
|
|
|
extern void nfs4_check_drain_bc_complete(struct nfs4_session *ses);
|
|
extern void nfs4_cb_take_slot(struct nfs_client *clp);
|
|
#endif /* CONFIG_NFS_V4_1 */
|
|
|
|
extern __be32 nfs4_callback_getattr(struct cb_getattrargs *args,
|
|
struct cb_getattrres *res,
|
|
struct cb_process_state *cps);
|
|
extern __be32 nfs4_callback_recall(struct cb_recallargs *args, void *dummy,
|
|
struct cb_process_state *cps);
|
|
#ifdef CONFIG_NFS_V4
|
|
extern int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt);
|
|
extern void nfs_callback_down(int minorversion);
|
|
extern int nfs4_validate_delegation_stateid(struct nfs_delegation *delegation,
|
|
const nfs4_stateid *stateid);
|
|
extern int nfs4_set_callback_sessionid(struct nfs_client *clp);
|
|
#endif /* CONFIG_NFS_V4 */
|
|
/*
|
|
* nfs41: Callbacks are expected to not cause substantial latency,
|
|
* so we limit their concurrency to 1 by setting up the maximum number
|
|
* of slots for the backchannel.
|
|
*/
|
|
#define NFS41_BC_MIN_CALLBACKS 1
|
|
#define NFS41_BC_MAX_CALLBACKS 1
|
|
|
|
extern unsigned int nfs_callback_set_tcpport;
|
|
extern unsigned short nfs_callback_tcpport;
|
|
extern unsigned short nfs_callback_tcpport6;
|
|
|
|
#endif /* __LINUX_FS_NFS_CALLBACK_H */
|