/fs/ceph/ |
H A D | mds_client.c | 40 * We maintain a stateful "session" with each MDS we interact with. 41 * Within each session, we sent periodic heartbeat messages to ensure 43 * the session times out and goes stale, our leases and capabilities 383 struct ceph_mds_session *session; local 387 session = mdsc->sessions[mds]; 388 dout("lookup_mds_session %p %d\n", session, 389 atomic_read(&session->s_ref)); 390 get_session(session); 391 return session; 411 * create+register a new session fo 894 __open_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 924 struct ceph_mds_session *session; local 942 struct ceph_mds_session *session; local 953 __open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 974 ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 989 cleanup_cap_releases(struct ceph_mds_session *session) argument 1015 iterate_session_caps(struct ceph_mds_session *session, int (*cb)(struct inode *, struct ceph_cap *, void *), void *arg) argument 1127 remove_session_caps(struct ceph_mds_session *session) argument 1188 wake_up_session_caps(struct ceph_mds_session *session, int reconnect) argument 1202 send_renew_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1232 send_flushmsg_ack(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, u64 seq) argument 1252 renewed_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int is_renew) argument 1284 request_close_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1302 __close_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1323 struct ceph_mds_session *session = arg; local 1369 trim_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int max_caps) argument 1398 ceph_add_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1468 struct ceph_mds_session *session = mdsc->sessions[mds]; local 1509 ceph_send_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1529 discard_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2044 struct ceph_mds_session *session = NULL; local 2270 handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) argument 2443 handle_forward(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument 2494 handle_session(struct ceph_mds_session *session, struct ceph_msg *msg) argument 2596 replay_unsafe_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2747 send_mds_reconnect(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2991 handle_lease(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument 3096 ceph_mdsc_lease_send_msg(struct ceph_mds_session *session, struct inode *inode, struct dentry *dentry, char action, u32 seq) argument 3140 struct ceph_mds_session *session; local 3455 struct ceph_mds_session *session; local [all...] |
H A D | caps.c | 503 * Add a capability under the given MDS session. 505 * Caller should hold session snap_rwsem (read) and s_mutex. 512 struct ceph_mds_session *session, u64 cap_id, 520 int mds = session->s_mds; 524 session->s_mds, cap_id, ceph_cap_string(issued), seq); 547 /* add to session cap list */ 548 cap->session = session; 549 spin_lock(&session->s_cap_lock); 550 list_add_tail(&cap->session_caps, &session 511 ceph_add_cap(struct inode *inode, struct ceph_mds_session *session, u64 cap_id, int fmode, unsigned issued, unsigned wanted, unsigned seq, unsigned mseq, u64 realmino, int flags, struct ceph_cap **new_cap) argument 908 struct ceph_mds_session *session = cap->session; local 968 send_cap_msg(struct ceph_mds_session *session, u64 ino, u64 cid, int op, int caps, int wanted, int dirty, u32 seq, u64 flush_tid, u32 issue_seq, u32 mseq, u64 size, u64 max_size, struct timespec *mtime, struct timespec *atime, u64 time_warp_seq, kuid_t uid, kgid_t gid, umode_t mode, u64 xattr_version, struct ceph_buffer *xattrs_buf, u64 follows) argument 1034 __queue_cap_release(struct ceph_mds_session *session, u64 ino, u64 cap_id, u32 migrate_seq, u32 issue_seq) argument 1122 struct ceph_mds_session *session; variable in typeref:struct:ceph_mds_session 1253 struct ceph_mds_session *session = NULL; /* if session != NULL, we hold variable in typeref:struct:ceph_mds_session 1299 ceph_put_mds_session(session); variable 1358 ceph_put_mds_session(session); variable 1416 __mark_caps_flushing(struct inode *inode, struct ceph_mds_session *session) argument 1489 ceph_check_caps(struct ceph_inode_info *ci, int flags, struct ceph_mds_session *session) argument 1746 struct ceph_mds_session *session = NULL; local 1928 kick_flushing_capsnaps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1954 ceph_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1990 kick_flushing_inode_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct inode *inode) argument 2696 handle_cap_flushsnap_ack(struct inode *inode, u64 flush_tid, struct ceph_mds_caps *m, struct ceph_mds_session *session) argument 2779 handle_cap_export(struct inode *inode, struct ceph_mds_caps *ex, struct ceph_mds_cap_peer *ph, struct ceph_mds_session *session) argument 2982 ceph_handle_caps(struct ceph_mds_session *session, struct ceph_msg *msg) argument [all...] |
H A D | mds_client.h | 19 * session->s_mutex 102 * state associated with each MDS<->client session 120 struct mutex s_mutex; /* serialize session messages */ 129 unsigned long s_cap_ttl; /* when session caps expire */ 133 struct list_head s_caps; /* all caps issued by this session */ 242 struct list_head r_unsafe_item; /* per-session unsafe list item */ 264 struct ceph_mds_session **sessions; /* NULL for mds if no session */ 371 struct ceph_mds_session *session); 373 struct ceph_mds_session *session); 381 extern void ceph_mdsc_lease_send_msg(struct ceph_mds_session *session, [all...] |
H A D | debugfs.c | 69 seq_printf(s, "%lld\t(no session)\t", req->r_tid); 177 /* The list of MDS session rank+state */ 179 struct ceph_mds_session *session = local 181 if (!session) { 186 session->s_mds, 187 ceph_session_state_name(session->s_state)); 189 ceph_put_mds_session(session);
|
H A D | super.h | 116 * session capability lists. 121 struct ceph_mds_session *session; member in struct:ceph_cap 122 struct list_head session_caps; /* per-session caplist */ 276 /* capabilities. protected _both_ by i_ceph_lock and cap->session's 670 struct ceph_mds_session *session, 705 struct ceph_mds_session *session); 707 struct ceph_mds_session *session); 790 extern void ceph_handle_caps(struct ceph_mds_session *session, 795 struct ceph_mds_session *session, u64 cap_id, 804 extern void __queue_cap_release(struct ceph_mds_session *session, u6 [all...] |
H A D | snap.c | 733 struct ceph_mds_session *session = NULL; local 744 __ceph_flush_snaps(ci, &session, 0); 751 if (session) { 752 mutex_unlock(&session->s_mutex); 753 ceph_put_mds_session(session); 771 struct ceph_mds_session *session, 775 int mds = session->s_mds; 803 mutex_lock(&session->s_mutex); 804 session->s_seq++; 805 mutex_unlock(&session 770 ceph_handle_snap(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument [all...] |
H A D | inode.c | 663 struct ceph_mds_session *session, 854 ceph_add_cap(inode, session, 903 * caller should hold session s_mutex. 907 struct ceph_mds_session *session, 931 if (di->lease_gen == session->s_cap_gen && 935 if (di->lease_session && di->lease_session != session) 941 di->lease_session = ceph_get_mds_session(session); 942 di->lease_gen = session->s_cap_gen; 1009 struct ceph_mds_session *session) 1038 session, re 660 fill_inode(struct inode *inode, struct ceph_mds_reply_info_in *iinfo, struct ceph_mds_reply_dirfrag *dirinfo, struct ceph_mds_session *session, unsigned long ttl_from, int cap_fmode, struct ceph_cap_reservation *caps_reservation) argument 905 update_dentry_lease(struct dentry *dentry, struct ceph_mds_reply_lease *lease, struct ceph_mds_session *session, unsigned long from_time) argument 1008 ceph_fill_trace(struct super_block *sb, struct ceph_mds_request *req, struct ceph_mds_session *session) argument 1285 readdir_prepopulate_inodes_only(struct ceph_mds_request *req, struct ceph_mds_session *session) argument 1318 ceph_readdir_prepopulate(struct ceph_mds_request *req, struct ceph_mds_session *session) argument [all...] |
H A D | dir.c | 997 struct ceph_mds_session *session = NULL; local 1018 session = ceph_get_mds_session(s); 1027 if (session) { 1028 ceph_mdsc_lease_send_msg(session, dir, dentry, 1030 ceph_put_mds_session(session);
|
/fs/nfs/ |
H A D | nfs4session.c | 434 static void nfs4_release_session_slot_tables(struct nfs4_session *session) argument 436 nfs4_release_slot_table(&session->fc_slot_table); 437 nfs4_release_slot_table(&session->bc_slot_table); 451 tbl->session = ses; 457 tbl->session = ses; 468 struct nfs4_session *session; local 470 session = kzalloc(sizeof(struct nfs4_session), GFP_NOFS); 471 if (!session) 474 nfs4_init_slot_table(&session->fc_slot_table, "ForeChannel Slot table"); 475 nfs4_init_slot_table(&session 482 nfs4_destroy_session_slot_tables(struct nfs4_session *session) argument 488 nfs4_destroy_session(struct nfs4_session *session) argument 541 struct nfs4_session *session = clp->cl_session; local [all...] |
H A D | nfs4session.h | 34 struct nfs4_session *session; /* Parent session */ member in struct:nfs4_slot_table 100 extern void nfs4_destroy_session(struct nfs4_session *session); 123 * nfs_session_id_hash - calculate the crc32 hash for the session id 124 * @session - pointer to session 129 #define nfs_session_id_hash(session) (0)
|
H A D | nfs4trace.h | 246 const struct nfs4_session *session, 249 TP_ARGS(session, args), 252 __field(unsigned int, session) 260 __entry->session = nfs_session_id_hash(&session->sess_id); 267 "session=0x%08x slot_nr=%u seq_nr=%u " 269 __entry->session, 301 const struct nfs4_session *session, 304 TP_ARGS(session, res), 307 __field(unsigned int, session) [all...] |
H A D | callback_proc.c | 362 * For each referring call triple, check the session's slot table for 372 struct nfs4_session *session; local 379 * a session lookup from within the loop 381 session = clp->cl_session; 382 tbl = &session->fc_slot_table; 386 if (memcmp(session->sess_id.data, 433 /* state manager is resetting the session */ 437 /* Return NFS4ERR_BADSESSION if we're draining the session
|
H A D | nfs4proc.c | 405 dprintk("%s ERROR: %d Reset session\n", __func__, 565 struct nfs4_session *session; local 571 session = tbl->session; 592 nfs41_server_notify_highest_slotid_update(session->clp); 597 struct nfs4_session *session; local 609 session = slot->table->session; 616 trace_nfs4_sequence_done(session, res); 622 clp = session 709 nfs41_setup_sequence(struct nfs4_session *session, struct nfs4_sequence_args *args, struct nfs4_sequence_res *res, struct rpc_task *task) argument 778 struct nfs4_session *session = nfs4_get_session(server); local 797 struct nfs4_session *session = nfs4_get_session(data->seq_server); local 7105 nfs4_verify_fore_channel_attrs(struct nfs41_create_session_args *args, struct nfs4_session *session) argument 7127 nfs4_verify_back_channel_attrs(struct nfs41_create_session_args *args, struct nfs4_session *session) argument 7146 nfs4_verify_channel_attrs(struct nfs41_create_session_args *args, struct nfs4_session *session) argument 7160 struct nfs4_session *session = clp->cl_session; local 7201 struct nfs4_session *session = clp->cl_session; local 7227 nfs4_proc_destroy_session(struct nfs4_session *session, struct rpc_cred *cred) argument 7520 struct nfs4_session *session = nfs4_get_session(server); local 7876 struct nfs4_session *session = nfs4_get_session(server); local [all...] |
H A D | nfs4_fs.h | 262 extern int nfs41_setup_sequence(struct nfs4_session *session, 407 static inline void nfs4_schedule_session_recovery(struct nfs4_session *session, int err) argument
|
H A D | nfs4xdr.c | 1725 struct nfs4_session *session, 1732 encode_opaque_fixed(xdr, session->sess_id.data, NFS4_MAX_SESSIONID_LEN); 1855 struct nfs4_session *session, 1859 encode_opaque_fixed(xdr, session->sess_id.data, NFS4_MAX_SESSIONID_LEN); 1884 struct nfs4_session *session; local 1890 session = tp->session; 1891 if (!session) 1902 ((u32 *)session->sess_id.data)[0], 1903 ((u32 *)session 1724 encode_bind_conn_to_session(struct xdr_stream *xdr, struct nfs4_session *session, struct compound_hdr *hdr) argument 1854 encode_destroy_session(struct xdr_stream *xdr, struct nfs4_session *session, struct compound_hdr *hdr) argument 2063 struct nfs4_session *session = args->sa_slot->table->session; local 2794 nfs4_xdr_enc_destroy_session(struct rpc_rqst *req, struct xdr_stream *xdr, struct nfs4_session *session) argument 5617 struct nfs4_session *session = clp->cl_session; local 5663 struct nfs4_session *session; local [all...] |
H A D | nfs4client.c | 305 struct nfs4_session *session = NULL; local 308 * Create the session and mark it expired. 309 * When a SEQUENCE operation encounters the expired session 310 * it will do session recovery to initialize it. 312 session = nfs4_alloc_session(clp); 313 if (!session) 316 clp->cl_session = session; 319 * The create session reply races with the server back 919 /* We must ensure the session is initialised first */ 1155 * Either its session i [all...] |
/fs/hfsplus/ |
H A D | options.c | 37 { opt_session, "session=%u" }, 59 opts->session = -1; 162 if (match_int(&args[0], &sbi->session)) { 163 pr_err("session requires an argument\n"); 229 if (sbi->session >= 0) 230 seq_printf(seq, ",session=%u", sbi->session);
|
H A D | wrapper.c | 135 if (HFSPLUS_SB(sb)->session >= 0) { 136 te.cdte_track = HFSPLUS_SB(sb)->session; 144 pr_err("invalid session number or type of track\n");
|
/fs/hfs/ |
H A D | super.c | 150 if (sbi->session >= 0) 151 seq_printf(seq, ",session=%u", sbi->session); 206 { opt_session, "session=%u" }, 243 hsb->session = -1; 305 if (match_int(&args[0], &hsb->session)) { 306 pr_err("session requires an argument\n");
|
H A D | mdb.c | 43 if (HFS_SB(sb)->session >= 0) { 44 te.cdte_track = HFS_SB(sb)->session; 51 pr_err("invalid session number or type of track\n");
|
H A D | hfs_fs.h | 156 int session, part; member in struct:hfs_sb_info
|
/fs/nfsd/ |
H A D | nfs4callback.c | 157 const struct nfsd4_session *session) 162 xdr_encode_opaque_fixed(p, session->se_sessionid.data, 355 struct nfsd4_session *session = cb->cb_clp->cl_cb_session; local 362 encode_sessionid4(xdr, session); 365 *p++ = cpu_to_be32(session->se_cb_seq_nr); /* csa_sequenceid */ 398 struct nfsd4_session *session = cb->cb_clp->cl_cb_session; local 414 if (memcmp(id.data, session->se_sessionid.data, 416 dprintk("NFS: %s Invalid session id\n", __func__); 422 if (dummy != session->se_cb_seq_nr) { 156 encode_sessionid4(struct xdr_stream *xdr, const struct nfsd4_session *session) argument
|
H A D | nfs4state.c | 1235 * We don't actually need to cache the rpc and session headers, so we 1252 * room for new connections. For now we just fail the create session. 1477 dprintk("%s: session not found\n", __func__); 1485 struct nfsd4_session *session; local 1488 session = __find_in_sessionid_hashtbl(sessionid, net); 1489 if (!session) 1491 status = nfsd4_get_session_locked(session); 1493 session = NULL; 1496 return session; 2111 * session value 2560 struct nfsd4_session *session = cstate->session; local 2583 struct nfsd4_session *session; local 2612 nfsd4_compound_in_session(struct nfsd4_session *session, struct nfs4_sessionid *sid) argument 2701 nfsd4_session_too_many_ops(struct svc_rqst *rqstp, struct nfsd4_session *session) argument 2708 nfsd4_request_too_big(struct svc_rqst *rqstp, struct nfsd4_session *session) argument 2723 struct nfsd4_session *session; local [all...] |
H A D | nfs4proc.c | 247 /* FIXME: check session persistence and pnfs flags. 347 copy_clientid(clientid_t *clid, struct nfsd4_session *session) argument 350 (struct nfsd4_sessionid *)session->se_sessionid.data; 381 &cstate->session->se_client->cl_flags) && 386 copy_clientid(&open->op_clientid, cstate->session);
|
/fs/isofs/ |
H A D | inode.c | 6 * 1994 Eberhard Mönkeberg - multi session handling. 169 s32 session; member in struct:iso9660_options 315 {Opt_session, "session=%u"}, 361 popt->session=-1; 415 popt->session = n + 1; 478 * look if the driver can tell the multi session redirection value 486 * each track is #0), and a track is not a session. 495 static unsigned int isofs_get_last_session(struct super_block *sb, s32 session) argument 504 if(session >= 0 && session < [all...] |