Searched refs:session (Results 1 - 25 of 30) sorted by relevance

12

/fs/ceph/
H A Dmds_client.c40 * 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 Dcaps.c503 * 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 Dmds_client.h19 * 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 Ddebugfs.c69 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 Dsuper.h116 * 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 Dsnap.c733 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 Dinode.c663 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 Ddir.c997 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 Dnfs4session.c434 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 Dnfs4session.h34 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 Dnfs4trace.h246 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 Dcallback_proc.c362 * 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 Dnfs4proc.c405 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 Dnfs4_fs.h262 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 Dnfs4xdr.c1725 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 Dnfs4client.c305 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 Doptions.c37 { 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 Dwrapper.c135 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 Dsuper.c150 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 Dmdb.c43 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 Dhfs_fs.h156 int session, part; member in struct:hfs_sb_info
/fs/nfsd/
H A Dnfs4callback.c157 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 Dnfs4state.c1235 * 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 Dnfs4proc.c247 /* 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 Dinode.c6 * 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...]

Completed in 247 milliseconds

12