fs/afs/callback.c

31 	struct afs_vnode *vnode = container_of(work, struct afs_vnode, cb_work);
33 	unmap_mapping_pages(vnode->netfs.inode.i_mapping, 0, 0, false);
38 	struct afs_vnode *vnode;
42 	list_for_each_entry(vnode, &volume->open_mmaps, cb_mmap_link) {
43 		if (vnode->cb_v_check != atomic_read(&volume->cb_v_break)) {
44 			atomic64_set(&vnode->cb_expires_at, AFS_NO_CB_PROMISE);
45 			queue_work(system_unbound_wq, &vnode->cb_work);
77 void __afs_break_callback(struct afs_vnode *vnode, enum afs_cb_break_reason reason)
81 	clear_bit(AFS_VNODE_NEW_CONTENT, &vnode->flags);
82 	if (atomic64_xchg(&vnode->cb_expires_at, AFS_NO_CB_PROMISE) != AFS_NO_CB_PROMISE) {
83 		vnode->cb_break++;
84 		vnode->cb_v_check = atomic_read(&vnode->volume->cb_v_break);
85 		afs_clear_permits(vnode);
87 		if (vnode->lock_state == AFS_VNODE_LOCK_WAITING_FOR_CB)
88 			afs_lock_may_be_available(vnode);
91 		    vnode->status.type == AFS_FTYPE_FILE &&
92 		    atomic_read(&vnode->cb_nr_mmap))
93 			queue_work(system_unbound_wq, &vnode->cb_work);
95 		trace_afs_cb_break(&vnode->fid, vnode->cb_break, reason, true);
97 		trace_afs_cb_break(&vnode->fid, vnode->cb_break, reason, false);
101 void afs_break_callback(struct afs_vnode *vnode, enum afs_cb_break_reason reason)
103 	write_seqlock(&vnode->cb_lock);
104 	__afs_break_callback(vnode, reason);
105 	write_sequnlock(&vnode->cb_lock);
193 	struct afs_vnode *vnode;
204 	inode = find_inode_rcu(sb, fid->vnode, afs_ilookup5_test_by_fid, fid);
206 		vnode = AFS_FS_I(inode);
207 		afs_break_callback(vnode, afs_cb_break_for_callback);
224 	if (cbb->fid.vnode == 0 && cbb->fid.unique == 0) {
238 				       cbb->fid.vnode,