| /fs/fscache/ |
| D | operation.c | 19 static void fscache_operation_dummy_cancel(struct fscache_operation *op) in fscache_operation_dummy_cancel() argument
32 struct fscache_operation *op, in fscache_operation_init() argument
37 INIT_WORK(&op->work, fscache_op_work_func); in fscache_operation_init()
38 atomic_set(&op->usage, 1); in fscache_operation_init()
39 op->state = FSCACHE_OP_ST_INITIALISED; in fscache_operation_init()
40 op->debug_id = atomic_inc_return(&fscache_op_debug_id); in fscache_operation_init()
41 op->processor = processor; in fscache_operation_init()
42 op->cancel = cancel ?: fscache_operation_dummy_cancel; in fscache_operation_init()
43 op->release = release; in fscache_operation_init()
44 INIT_LIST_HEAD(&op->pend_link); in fscache_operation_init()
[all …]
|
| D | page.c | 187 static void fscache_attr_changed_op(struct fscache_operation *op) in fscache_attr_changed_op() argument
189 struct fscache_object *object = op->object; in fscache_attr_changed_op()
192 _enter("{OBJ%x OP%x}", object->debug_id, op->debug_id); in fscache_attr_changed_op()
202 fscache_op_complete(op, ret < 0); in fscache_attr_changed_op()
204 fscache_op_complete(op, true); in fscache_attr_changed_op()
215 struct fscache_operation *op; in __fscache_attr_changed() local
225 op = kzalloc(sizeof(*op), GFP_KERNEL); in __fscache_attr_changed()
226 if (!op) { in __fscache_attr_changed()
232 fscache_operation_init(cookie, op, fscache_attr_changed_op, NULL, NULL); in __fscache_attr_changed()
233 trace_fscache_page_op(cookie, NULL, op, fscache_page_op_attr_changed); in __fscache_attr_changed()
[all …]
|
| D | cookie.c | 891 struct fscache_operation *op; in __fscache_check_consistency() local
906 op = kzalloc(sizeof(*op), GFP_NOIO | __GFP_NOMEMALLOC | __GFP_NORETRY); in __fscache_check_consistency()
907 if (!op) in __fscache_check_consistency()
910 fscache_operation_init(cookie, op, NULL, NULL, NULL); in __fscache_check_consistency()
911 op->flags = FSCACHE_OP_MYTHREAD | in __fscache_check_consistency()
914 trace_fscache_page_op(cookie, NULL, op, fscache_page_op_check_consistency); in __fscache_check_consistency()
928 op->debug_id = atomic_inc_return(&fscache_op_debug_id); in __fscache_check_consistency()
931 if (fscache_submit_op(object, op) < 0) in __fscache_check_consistency()
937 ret = fscache_wait_for_operation_activation(object, op, NULL, NULL); in __fscache_check_consistency()
940 ret = object->cache->ops->check_consistency(op); in __fscache_check_consistency()
[all …]
|
| /fs/orangefs/ |
| D | waitqueue.c | 20 static int wait_for_matching_downcall(struct orangefs_kernel_op_s *op,
23 __acquires(op->lock);
24 static void orangefs_clean_up_interrupted_operation(struct orangefs_kernel_op_s *op)
25 __releases(op->lock);
36 struct orangefs_kernel_op_s *op, *tmp; in purge_waiting_ops() local
39 list_for_each_entry_safe(op, tmp, &orangefs_request_list, list) { in purge_waiting_ops()
42 llu(op->tag), in purge_waiting_ops()
43 get_opname_string(op)); in purge_waiting_ops()
44 set_op_state_purged(op); in purge_waiting_ops()
48 get_opname_string(op), in purge_waiting_ops()
[all …]
|
| D | devorangefs-req.c | 48 static void orangefs_devreq_add_op(struct orangefs_kernel_op_s *op) in orangefs_devreq_add_op() argument
50 int index = hash_func(op->tag, hash_table_size); in orangefs_devreq_add_op()
52 list_add_tail(&op->list, &orangefs_htable_ops_in_progress[index]); in orangefs_devreq_add_op()
61 struct orangefs_kernel_op_s *op, *next; in orangefs_devreq_remove_op() local
67 list_for_each_entry_safe(op, in orangefs_devreq_remove_op()
71 if (op->tag == tag && !op_state_purged(op) && in orangefs_devreq_remove_op()
72 !op_state_given_up(op)) { in orangefs_devreq_remove_op()
73 list_del_init(&op->list); in orangefs_devreq_remove_op()
75 return op; in orangefs_devreq_remove_op()
162 struct orangefs_kernel_op_s *op, *temp; in orangefs_devreq_read() local
[all …]
|
| D | orangefs-kernel.h | 143 #define set_op_state_waiting(op) ((op)->op_state = OP_VFS_STATE_WAITING) argument
144 #define set_op_state_inprogress(op) ((op)->op_state = OP_VFS_STATE_INPROGR) argument
145 #define set_op_state_given_up(op) ((op)->op_state = OP_VFS_STATE_GIVEN_UP) argument
146 static inline void set_op_state_serviced(struct orangefs_kernel_op_s *op) in set_op_state_serviced() argument
148 op->op_state = OP_VFS_STATE_SERVICED; in set_op_state_serviced()
149 complete(&op->waitq); in set_op_state_serviced()
152 #define op_state_waiting(op) ((op)->op_state & OP_VFS_STATE_WAITING) argument
153 #define op_state_in_progress(op) ((op)->op_state & OP_VFS_STATE_INPROGR) argument
154 #define op_state_serviced(op) ((op)->op_state & OP_VFS_STATE_SERVICED) argument
155 #define op_state_purged(op) ((op)->op_state & OP_VFS_STATE_PURGED) argument
[all …]
|
| D | dir.c | 63 struct orangefs_kernel_op_s *op) in do_readdir() argument
74 op->uses_shared_memory = 1; in do_readdir()
75 op->upcall.req.readdir.refn = oi->refn; in do_readdir()
76 op->upcall.req.readdir.token = od->token; in do_readdir()
77 op->upcall.req.readdir.max_dirent_count = in do_readdir()
87 op->upcall.req.readdir.buf_index = bufi; in do_readdir()
89 r = service_operation(op, "orangefs_readdir", in do_readdir()
94 if (op_state_purged(op)) { in do_readdir()
96 vfree(op->downcall.trailer_buf); in do_readdir()
99 vfree(op->downcall.trailer_buf); in do_readdir()
[all …]
|
| D | orangefs-sysfs.c | 365 new_op->upcall.req.param.op = in sysfs_service_op_show()
369 new_op->upcall.req.param.op = in sysfs_service_op_show()
373 new_op->upcall.req.param.op = in sysfs_service_op_show()
378 new_op->upcall.req.param.op = in sysfs_service_op_show()
383 new_op->upcall.req.param.op = in sysfs_service_op_show()
388 new_op->upcall.req.param.op = in sysfs_service_op_show()
393 new_op->upcall.req.param.op = in sysfs_service_op_show()
397 new_op->upcall.req.param.op = in sysfs_service_op_show()
401 new_op->upcall.req.param.op = in sysfs_service_op_show()
405 new_op->upcall.req.param.op = in sysfs_service_op_show()
[all …]
|
| D | orangefs-utils.c | 14 __s32 fsid_of_op(struct orangefs_kernel_op_s *op) in fsid_of_op() argument
18 if (op) { in fsid_of_op()
19 switch (op->upcall.type) { in fsid_of_op()
21 fsid = op->upcall.req.io.refn.fs_id; in fsid_of_op()
24 fsid = op->upcall.req.lookup.parent_refn.fs_id; in fsid_of_op()
27 fsid = op->upcall.req.create.parent_refn.fs_id; in fsid_of_op()
30 fsid = op->upcall.req.getattr.refn.fs_id; in fsid_of_op()
33 fsid = op->upcall.req.remove.parent_refn.fs_id; in fsid_of_op()
36 fsid = op->upcall.req.mkdir.parent_refn.fs_id; in fsid_of_op()
39 fsid = op->upcall.req.readdir.refn.fs_id; in fsid_of_op()
[all …]
|
| D | orangefs-mod.c | 211 struct orangefs_kernel_op_s *op; in purge_inprogress_ops() local
215 list_for_each_entry_safe(op, in purge_inprogress_ops()
219 set_op_state_purged(op); in purge_inprogress_ops()
223 get_opname_string(op), in purge_inprogress_ops()
224 op->op_state, in purge_inprogress_ops()
|
| /fs/dlm/ |
| D | plock.c | 61 static void send_op(struct plock_op *op) in send_op() argument
63 set_version(&op->info); in send_op()
64 INIT_LIST_HEAD(&op->list); in send_op()
66 list_add_tail(&op->list, &send_list); in send_op()
80 struct plock_op *op; in do_unlock_close() local
82 op = kzalloc(sizeof(*op), GFP_NOFS); in do_unlock_close()
83 if (!op) in do_unlock_close()
86 op->info.optype = DLM_PLOCK_OP_UNLOCK; in do_unlock_close()
87 op->info.pid = fl->fl_pid; in do_unlock_close()
88 op->info.fsid = ls->ls_global_id; in do_unlock_close()
[all …]
|
| /fs/cachefiles/ |
| D | rdwr.c | 26 struct fscache_retrieval *op = monitor->op; in cachefiles_read_waiter() local
51 ASSERT(op); in cachefiles_read_waiter()
58 fscache_get_retrieval(op); in cachefiles_read_waiter()
60 object = container_of(op->op.object, struct cachefiles_object, fscache); in cachefiles_read_waiter()
62 list_add_tail(&monitor->op_link, &op->to_do); in cachefiles_read_waiter()
65 fscache_enqueue_retrieval(op); in cachefiles_read_waiter()
66 fscache_put_retrieval(op); in cachefiles_read_waiter()
156 struct fscache_retrieval *op; in cachefiles_read_copier() local
159 op = container_of(_op, struct fscache_retrieval, op); in cachefiles_read_copier()
160 object = container_of(op->op.object, in cachefiles_read_copier()
[all …]
|
| /fs/nfsd/ |
| D | fault_inject.c | 36 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_read() local
39 val = op->get(); in fault_inject_read()
52 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_write() local
69 val = op->set_clnt(&sa, size); in fault_inject_write()
72 op->file, write_buf, val); in fault_inject_write()
76 pr_info("NFSD Fault Injection: %s (all)", op->file); in fault_inject_write()
79 op->file, val); in fault_inject_write()
80 val = op->set_val(val); in fault_inject_write()
81 pr_info("NFSD: %s: found %llu", op->file, val); in fault_inject_write()
133 struct nfsd_fault_inject_op *op; in nfsd_fault_inject_init() local
[all …]
|
| D | nfs4proc.c | 478 …2 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op) in nfsd4_open_omfg() argument
480 struct nfsd4_open *open = &op->u.open; in nfsd4_open_omfg()
482 if (!seqid_mutating_err(ntohl(op->status))) in nfsd4_open_omfg()
483 return op->status; in nfsd4_open_omfg()
485 return op->status; in nfsd4_open_omfg()
486 open->op_xdr_error = op->status; in nfsd4_open_omfg()
487 return nfsd4_open(rqstp, cstate, &op->u); in nfsd4_open_omfg()
1851 const struct nfsd4_operation *OPDESC(struct nfsd4_op *op) in OPDESC() argument
1853 return &nfsd4_ops[op->opnum]; in OPDESC()
1856 bool nfsd4_cache_this_op(struct nfsd4_op *op) in nfsd4_cache_this_op() argument
[all …]
|
| /fs/nls/ |
| D | nls_base.c | 135 u16 *op; in utf8s_to_utf16s() local
139 op = pwcs; in utf8s_to_utf16s()
152 put_utf16(op++, SURROGATE_PAIR | in utf8s_to_utf16s()
155 put_utf16(op++, SURROGATE_PAIR | in utf8s_to_utf16s()
161 put_utf16(op++, u, endian); in utf8s_to_utf16s()
165 put_utf16(op++, *s++, endian); in utf8s_to_utf16s()
170 return op - pwcs; in utf8s_to_utf16s()
189 u8 *op; in utf16s_to_utf8s() local
193 op = s; in utf16s_to_utf8s()
219 size = utf32_to_utf8(u, op, maxout); in utf16s_to_utf8s()
[all …]
|
| /fs/isofs/ |
| D | joliet.c | 21 unsigned char *op; in uni16_to_x8() local
24 op = ascii; in uni16_to_x8()
28 llen = nls->uni2char(be16_to_cpu(ch), op, NLS_MAX_CHARSET_SIZE); in uni16_to_x8()
30 op += llen; in uni16_to_x8()
32 *op++ = '?'; in uni16_to_x8()
37 *op = 0; in uni16_to_x8()
38 return (op - ascii); in uni16_to_x8()
|
| /fs/ |
| D | seq_file.c | 51 int seq_open(struct file *file, const struct seq_operations *op) in seq_open() argument
64 p->op = op; in seq_open()
108 p = m->op->start(m, &m->index); in traverse()
113 error = m->op->show(m, p); in traverse()
122 p = m->op->next(m, p, &m->index); in traverse()
133 m->op->stop(m, p); in traverse()
137 m->op->stop(m, p); in traverse()
224 p = m->op->start(m, &m->index); in seq_read()
229 err = m->op->show(m, p); in seq_read()
235 p = m->op->next(m, p, &m->index); in seq_read()
[all …]
|
| D | open.c | 970 static inline int build_open_flags(int flags, umode_t mode, struct open_flags *op) in build_open_flags() argument
982 op->mode = (mode & S_IALLUGO) | S_IFREG; in build_open_flags()
984 op->mode = 0; in build_open_flags()
1012 op->open_flag = flags; in build_open_flags()
1023 op->acc_mode = acc_mode; in build_open_flags()
1025 op->intent = flags & O_PATH ? 0 : LOOKUP_OPEN; in build_open_flags()
1028 op->intent |= LOOKUP_CREATE; in build_open_flags()
1030 op->intent |= LOOKUP_EXCL; in build_open_flags()
1037 op->lookup_flags = lookup_flags; in build_open_flags()
1054 struct open_flags op; in file_open_name() local
[all …]
|
| D | direct-io.c | 119 int op; member
175 if (ret < 0 && sdio->blocks_available && (dio->op == REQ_OP_WRITE)) { in dio_refill_pages()
275 if ((dio->op == REQ_OP_READ) && in dio_complete()
310 ret > 0 && dio->op == REQ_OP_WRITE && in dio_complete()
329 if (ret > 0 && dio->op == REQ_OP_WRITE) in dio_complete()
377 (dio->op == REQ_OP_WRITE && in dio_bio_end_aio()
447 bio_set_op_attrs(bio, dio->op, dio->op_flags); in dio_bio_alloc()
477 if (dio->is_async && dio->op == REQ_OP_READ && dio->should_dirty) in dio_bio_submit()
546 bool should_dirty = dio->op == REQ_OP_READ && dio->should_dirty; in dio_bio_complete()
707 create = dio->op == REQ_OP_WRITE; in get_more_blocks()
[all …]
|
| /fs/ceph/ |
| D | strings.c | 34 const char *ceph_session_op_name(int op) in ceph_session_op_name() argument
36 switch (op) { in ceph_session_op_name()
53 const char *ceph_mds_op_name(int op) in ceph_mds_op_name() argument
55 switch (op) { in ceph_mds_op_name()
88 const char *ceph_cap_op_name(int op) in ceph_cap_op_name() argument
90 switch (op) { in ceph_cap_op_name()
|
| /fs/nfs/ |
| D | callback_xdr.c | 166 static __be32 decode_op_hdr(struct xdr_stream *xdr, unsigned int *op) in decode_op_hdr() argument
172 *op = ntohl(*p); in decode_op_hdr()
672 static __be32 encode_op_hdr(struct xdr_stream *xdr, uint32_t op, __be32 res) in encode_op_hdr() argument
679 *p++ = htonl(op); in encode_op_hdr()
757 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
776 *op = &callback_ops[op_nr]; in preprocess_nfs41_op()
817 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
829 preprocess_nfs42_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs42_op() argument
831 __be32 status = preprocess_nfs41_op(nop, op_nr, op); in preprocess_nfs42_op()
836 *op = &callback_ops[op_nr]; in preprocess_nfs42_op()
[all …]
|
| /fs/xfs/ |
| D | xfs_bio_io.c | 18 unsigned int op) in xfs_rw_bdev() argument
26 if (is_vmalloc && op == REQ_OP_WRITE) in xfs_rw_bdev()
32 bio->bi_opf = op | REQ_META | REQ_SYNC; in xfs_rw_bdev()
58 if (is_vmalloc && op == REQ_OP_READ) in xfs_rw_bdev()
|
| /fs/hfsplus/ |
| D | unicode.c | 128 u8 *op; in hfsplus_uni2asc() local
133 op = astr; in hfsplus_uni2asc()
193 res = nls->uni2char(c0, op, len); in hfsplus_uni2asc()
197 *op = '?'; in hfsplus_uni2asc()
200 op += res; in hfsplus_uni2asc()
236 res = nls->uni2char(cc, op, len); in hfsplus_uni2asc()
240 *op = '?'; in hfsplus_uni2asc()
243 op += res; in hfsplus_uni2asc()
248 *len_p = (char *)op - astr; in hfsplus_uni2asc()
|
| /fs/freevxfs/ |
| D | vxfs_olt.c | 81 struct vxfs_olt *op; in vxfs_read_olt() local
88 op = (struct vxfs_olt *)bp->b_data; in vxfs_read_olt()
89 if (fs32_to_cpu(infp, op->olt_magic) != VXFS_OLT_MAGIC) { in vxfs_read_olt()
104 oaddr = bp->b_data + fs32_to_cpu(infp, op->olt_size); in vxfs_read_olt()
|
| /fs/afs/ |
| D | flock.c | 778 enum afs_flock_operation op; in afs_lock() local
802 case 0: op = afs_flock_op_return_ok; break; in afs_lock()
803 case -EAGAIN: op = afs_flock_op_return_eagain; break; in afs_lock()
804 case -EDEADLK: op = afs_flock_op_return_edeadlk; break; in afs_lock()
805 default: op = afs_flock_op_return_error; break; in afs_lock()
807 trace_afs_flock_op(vnode, fl, op); in afs_lock()
817 enum afs_flock_operation op; in afs_flock() local
844 case 0: op = afs_flock_op_return_ok; break; in afs_flock()
845 case -EAGAIN: op = afs_flock_op_return_eagain; break; in afs_flock()
846 case -EDEADLK: op = afs_flock_op_return_edeadlk; break; in afs_flock()
[all …]
|