| /fs/fscache/ |
| D | operation.c | 23 static void fscache_operation_dummy_cancel(struct fscache_operation *op) in fscache_operation_dummy_cancel() argument
35 void fscache_operation_init(struct fscache_operation *op, in fscache_operation_init() argument
40 INIT_WORK(&op->work, fscache_op_work_func); in fscache_operation_init()
41 atomic_set(&op->usage, 1); in fscache_operation_init()
42 op->state = FSCACHE_OP_ST_INITIALISED; in fscache_operation_init()
43 op->debug_id = atomic_inc_return(&fscache_op_debug_id); in fscache_operation_init()
44 op->processor = processor; in fscache_operation_init()
45 op->cancel = cancel ?: fscache_operation_dummy_cancel; in fscache_operation_init()
46 op->release = release; in fscache_operation_init()
47 INIT_LIST_HEAD(&op->pend_link); in fscache_operation_init()
[all …]
|
| D | page.c | 173 static void fscache_attr_changed_op(struct fscache_operation *op) in fscache_attr_changed_op() argument
175 struct fscache_object *object = op->object; in fscache_attr_changed_op()
178 _enter("{OBJ%x OP%x}", object->debug_id, op->debug_id); in fscache_attr_changed_op()
190 fscache_op_complete(op, true); in fscache_attr_changed_op()
199 struct fscache_operation *op; in __fscache_attr_changed() local
209 op = kzalloc(sizeof(*op), GFP_KERNEL); in __fscache_attr_changed()
210 if (!op) { in __fscache_attr_changed()
216 fscache_operation_init(op, fscache_attr_changed_op, NULL, NULL); in __fscache_attr_changed()
217 op->flags = FSCACHE_OP_ASYNC | in __fscache_attr_changed()
230 if (fscache_submit_exclusive_op(object, op) < 0) in __fscache_attr_changed()
[all …]
|
| D | cookie.c | 661 struct fscache_operation *op; in __fscache_check_consistency() local
676 op = kzalloc(sizeof(*op), GFP_NOIO | __GFP_NOMEMALLOC | __GFP_NORETRY); in __fscache_check_consistency()
677 if (!op) in __fscache_check_consistency()
680 fscache_operation_init(op, NULL, NULL, NULL); in __fscache_check_consistency()
681 op->flags = FSCACHE_OP_MYTHREAD | in __fscache_check_consistency()
695 op->debug_id = atomic_inc_return(&fscache_op_debug_id); in __fscache_check_consistency()
698 if (fscache_submit_op(object, op) < 0) in __fscache_check_consistency()
704 ret = fscache_wait_for_operation_activation(object, op, NULL, NULL); in __fscache_check_consistency()
707 ret = object->cache->ops->check_consistency(op); in __fscache_check_consistency()
708 fscache_op_complete(op, false); in __fscache_check_consistency()
[all …]
|
| /fs/orangefs/ |
| D | waitqueue.c | 32 struct orangefs_kernel_op_s *op, *tmp; in purge_waiting_ops() local
35 list_for_each_entry_safe(op, tmp, &orangefs_request_list, list) { in purge_waiting_ops()
38 llu(op->tag), in purge_waiting_ops()
39 get_opname_string(op)); in purge_waiting_ops()
40 set_op_state_purged(op); in purge_waiting_ops()
44 get_opname_string(op), in purge_waiting_ops()
45 op->op_state, in purge_waiting_ops()
61 int service_operation(struct orangefs_kernel_op_s *op, in service_operation() argument
70 op->upcall.tgid = current->tgid; in service_operation()
71 op->upcall.pid = current->pid; in service_operation()
[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 | 159 #define set_op_state_waiting(op) ((op)->op_state = OP_VFS_STATE_WAITING) argument
160 #define set_op_state_inprogress(op) ((op)->op_state = OP_VFS_STATE_INPROGR) argument
161 #define set_op_state_given_up(op) ((op)->op_state = OP_VFS_STATE_GIVEN_UP) argument
162 static inline void set_op_state_serviced(struct orangefs_kernel_op_s *op) in set_op_state_serviced() argument
164 op->op_state = OP_VFS_STATE_SERVICED; in set_op_state_serviced()
165 complete(&op->waitq); in set_op_state_serviced()
168 #define op_state_waiting(op) ((op)->op_state & OP_VFS_STATE_WAITING) argument
169 #define op_state_in_progress(op) ((op)->op_state & OP_VFS_STATE_INPROGR) argument
170 #define op_state_serviced(op) ((op)->op_state & OP_VFS_STATE_SERVICED) argument
171 #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 | 347 new_op->upcall.req.param.op = in sysfs_service_op_show()
351 new_op->upcall.req.param.op = in sysfs_service_op_show()
355 new_op->upcall.req.param.op = in sysfs_service_op_show()
360 new_op->upcall.req.param.op = in sysfs_service_op_show()
365 new_op->upcall.req.param.op = in sysfs_service_op_show()
370 new_op->upcall.req.param.op = in sysfs_service_op_show()
375 new_op->upcall.req.param.op = in sysfs_service_op_show()
379 new_op->upcall.req.param.op = in sysfs_service_op_show()
383 new_op->upcall.req.param.op = in sysfs_service_op_show()
387 new_op->upcall.req.param.op = in sysfs_service_op_show()
[all …]
|
| D | orangefs-utils.c | 12 __s32 fsid_of_op(struct orangefs_kernel_op_s *op) in fsid_of_op() argument
16 if (op) { in fsid_of_op()
17 switch (op->upcall.type) { in fsid_of_op()
19 fsid = op->upcall.req.io.refn.fs_id; in fsid_of_op()
22 fsid = op->upcall.req.lookup.parent_refn.fs_id; in fsid_of_op()
25 fsid = op->upcall.req.create.parent_refn.fs_id; in fsid_of_op()
28 fsid = op->upcall.req.getattr.refn.fs_id; in fsid_of_op()
31 fsid = op->upcall.req.remove.parent_refn.fs_id; in fsid_of_op()
34 fsid = op->upcall.req.mkdir.parent_refn.fs_id; in fsid_of_op()
37 fsid = op->upcall.req.readdir.refn.fs_id; in fsid_of_op()
[all …]
|
| D | orangefs-mod.c | 213 struct orangefs_kernel_op_s *op; in purge_inprogress_ops() local
217 list_for_each_entry_safe(op, in purge_inprogress_ops()
221 set_op_state_purged(op); in purge_inprogress_ops()
225 get_opname_string(op), in purge_inprogress_ops()
226 op->op_state, in purge_inprogress_ops()
|
| /fs/dlm/ |
| D | plock.c | 64 static void send_op(struct plock_op *op) in send_op() argument
66 set_version(&op->info); in send_op()
67 INIT_LIST_HEAD(&op->list); in send_op()
69 list_add_tail(&op->list, &send_list); in send_op()
83 struct plock_op *op; in do_unlock_close() local
85 op = kzalloc(sizeof(*op), GFP_NOFS); in do_unlock_close()
86 if (!op) in do_unlock_close()
89 op->info.optype = DLM_PLOCK_OP_UNLOCK; in do_unlock_close()
90 op->info.pid = fl->fl_pid; in do_unlock_close()
91 op->info.fsid = ls->ls_global_id; in do_unlock_close()
[all …]
|
| /fs/cachefiles/ |
| D | rdwr.c | 30 struct fscache_retrieval *op = monitor->op; in cachefiles_read_waiter() local
55 ASSERT(op); in cachefiles_read_waiter()
62 fscache_get_retrieval(op); in cachefiles_read_waiter()
64 object = container_of(op->op.object, struct cachefiles_object, fscache); in cachefiles_read_waiter()
66 list_add_tail(&monitor->op_link, &op->to_do); in cachefiles_read_waiter()
69 fscache_enqueue_retrieval(op); in cachefiles_read_waiter()
70 fscache_put_retrieval(op); in cachefiles_read_waiter()
160 struct fscache_retrieval *op; in cachefiles_read_copier() local
163 op = container_of(_op, struct fscache_retrieval, op); in cachefiles_read_copier()
164 object = container_of(op->op.object, in cachefiles_read_copier()
[all …]
|
| D | interface.c | 389 static int cachefiles_check_consistency(struct fscache_operation *op) in cachefiles_check_consistency() argument
396 _enter("{OBJ%x}", op->object->debug_id); in cachefiles_check_consistency()
398 object = container_of(op->object, struct cachefiles_object, fscache); in cachefiles_check_consistency()
483 static void cachefiles_invalidate_object(struct fscache_operation *op) in cachefiles_invalidate_object() argument
492 object = container_of(op->object, struct cachefiles_object, fscache); in cachefiles_invalidate_object()
496 op->object->cookie->def->get_attr(op->object->cookie->netfs_data, in cachefiles_invalidate_object()
500 op->object->debug_id, (unsigned long long)ni_size); in cachefiles_invalidate_object()
524 fscache_op_complete(op, true); in cachefiles_invalidate_object()
|
| /fs/nfsd/ |
| D | fault_inject.c | 35 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_read() local
38 val = op->get(); in fault_inject_read()
51 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_write() local
68 val = op->set_clnt(&sa, size); in fault_inject_write()
71 op->file, write_buf, val); in fault_inject_write()
75 pr_info("NFSD Fault Injection: %s (all)", op->file); in fault_inject_write()
78 op->file, val); in fault_inject_write()
79 val = op->set_val(val); in fault_inject_write()
80 pr_info("NFSD: %s: found %llu", op->file, val); in fault_inject_write()
134 struct nfsd_fault_inject_op *op; in nfsd_fault_inject_init() local
[all …]
|
| D | nfs4proc.c | 472 …2 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op) in nfsd4_open_omfg() argument
474 struct nfsd4_open *open = &op->u.open; in nfsd4_open_omfg()
476 if (!seqid_mutating_err(ntohl(op->status))) in nfsd4_open_omfg()
477 return op->status; in nfsd4_open_omfg()
479 return op->status; in nfsd4_open_omfg()
480 open->op_xdr_error = op->status; in nfsd4_open_omfg()
481 return nfsd4_open(rqstp, cstate, &op->u); in nfsd4_open_omfg()
1607 struct nfsd4_op *op = &args->ops[0]; in nfs41_check_op_ordering() local
1615 if (op->status == nfserr_op_illegal) in nfs41_check_op_ordering()
1617 if (!(nfsd4_ops[op->opnum].op_flags & ALLOWED_AS_FIRST_OP)) in nfs41_check_op_ordering()
[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/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/ |
| D | seq_file.c | 48 int seq_open(struct file *file, const struct seq_operations *op) in seq_open() argument
61 p->op = op; in seq_open()
106 p = m->op->start(m, &index); in traverse()
111 error = m->op->show(m, p); in traverse()
133 p = m->op->next(m, p, &index); in traverse()
135 m->op->stop(m, p); in traverse()
140 m->op->stop(m, p); in traverse()
232 p = m->op->start(m, &pos); in seq_read()
237 err = m->op->show(m, p); in seq_read()
243 p = m->op->next(m, p, &pos); in seq_read()
[all …]
|
| D | open.c | 934 static inline int build_open_flags(int flags, umode_t mode, struct open_flags *op) in build_open_flags() argument
946 op->mode = (mode & S_IALLUGO) | S_IFREG; in build_open_flags()
948 op->mode = 0; in build_open_flags()
976 op->open_flag = flags; in build_open_flags()
987 op->acc_mode = acc_mode; in build_open_flags()
989 op->intent = flags & O_PATH ? 0 : LOOKUP_OPEN; in build_open_flags()
992 op->intent |= LOOKUP_CREATE; in build_open_flags()
994 op->intent |= LOOKUP_EXCL; in build_open_flags()
1001 op->lookup_flags = lookup_flags; in build_open_flags()
1018 struct open_flags op; in file_open_name() local
[all …]
|
| D | direct-io.c | 117 int op; member
173 if (ret < 0 && sdio->blocks_available && (dio->op == REQ_OP_WRITE)) { in dio_refill_pages()
274 if ((dio->op == REQ_OP_READ) && in dio_complete()
309 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()
443 bio_set_op_attrs(bio, dio->op, dio->op_flags); in dio_bio_alloc()
473 if (dio->is_async && dio->op == REQ_OP_READ && dio->should_dirty) in dio_bio_submit()
552 if (dio->is_async && dio->op == REQ_OP_READ && dio->should_dirty) { in dio_bio_complete()
558 if (dio->op == REQ_OP_READ && !PageCompound(page) && in dio_bio_complete()
[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()
|
| D | dir.c | 350 int op = ceph_snap(inode) == CEPH_SNAPDIR ? in ceph_readdir() local
371 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_readdir()
381 if (op == CEPH_MDS_OP_READDIR) { in ceph_readdir()
726 int op; in ceph_lookup() local
759 op = ceph_snap(dir) == CEPH_SNAPDIR ? in ceph_lookup()
761 req = ceph_mdsc_create_request(mdsc, op, USE_ANY_MDS); in ceph_lookup()
909 int op; in ceph_mkdir() local
913 op = CEPH_MDS_OP_MKSNAP; in ceph_mkdir()
918 op = CEPH_MDS_OP_MKDIR; in ceph_mkdir()
928 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_mkdir()
[all …]
|
| /fs/nfs/ |
| D | callback_xdr.c | 173 static __be32 decode_op_hdr(struct xdr_stream *xdr, unsigned int *op) in decode_op_hdr() argument
179 *op = ntohl(*p); in decode_op_hdr()
638 static __be32 encode_op_hdr(struct xdr_stream *xdr, uint32_t op, __be32 res) in encode_op_hdr() argument
645 *p++ = htonl(op); in encode_op_hdr()
719 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
738 *op = &callback_ops[op_nr]; in preprocess_nfs41_op()
779 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
791 preprocess_nfs42_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs42_op() argument
793 __be32 status = preprocess_nfs41_op(nop, op_nr, op); in preprocess_nfs42_op()
803 preprocess_nfs42_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs42_op() argument
[all …]
|
| /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()
|