Home
last modified time | relevance | path

Searched refs:op (Results 1 – 25 of 96) sorted by relevance

1234

/fs/fscache/
Doperation.c23 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 …]
Dpage.c173 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 …]
Dcookie.c661 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/
Dwaitqueue.c31 struct orangefs_kernel_op_s *op, *tmp; in purge_waiting_ops() local
34 list_for_each_entry_safe(op, tmp, &orangefs_request_list, list) { in purge_waiting_ops()
37 llu(op->tag), in purge_waiting_ops()
38 get_opname_string(op)); in purge_waiting_ops()
39 set_op_state_purged(op); in purge_waiting_ops()
43 get_opname_string(op), in purge_waiting_ops()
44 op->op_state, in purge_waiting_ops()
60 int service_operation(struct orangefs_kernel_op_s *op, in service_operation() argument
69 op->upcall.tgid = current->tgid; in service_operation()
70 op->upcall.pid = current->pid; in service_operation()
[all …]
Ddevorangefs-req.c47 static void orangefs_devreq_add_op(struct orangefs_kernel_op_s *op) in orangefs_devreq_add_op() argument
49 int index = hash_func(op->tag, hash_table_size); in orangefs_devreq_add_op()
51 list_add_tail(&op->list, &orangefs_htable_ops_in_progress[index]); in orangefs_devreq_add_op()
60 struct orangefs_kernel_op_s *op, *next; in orangefs_devreq_remove_op() local
66 list_for_each_entry_safe(op, in orangefs_devreq_remove_op()
70 if (op->tag == tag && !op_state_purged(op) && in orangefs_devreq_remove_op()
71 !op_state_given_up(op)) { in orangefs_devreq_remove_op()
72 list_del_init(&op->list); in orangefs_devreq_remove_op()
74 return op; in orangefs_devreq_remove_op()
161 struct orangefs_kernel_op_s *op, *temp; in orangefs_devreq_read() local
[all …]
Dorangefs-kernel.h158 #define set_op_state_waiting(op) ((op)->op_state = OP_VFS_STATE_WAITING) argument
159 #define set_op_state_inprogress(op) ((op)->op_state = OP_VFS_STATE_INPROGR) argument
160 #define set_op_state_given_up(op) ((op)->op_state = OP_VFS_STATE_GIVEN_UP) argument
161 static inline void set_op_state_serviced(struct orangefs_kernel_op_s *op) in set_op_state_serviced() argument
163 op->op_state = OP_VFS_STATE_SERVICED; in set_op_state_serviced()
164 complete(&op->waitq); in set_op_state_serviced()
167 #define op_state_waiting(op) ((op)->op_state & OP_VFS_STATE_WAITING) argument
168 #define op_state_in_progress(op) ((op)->op_state & OP_VFS_STATE_INPROGR) argument
169 #define op_state_serviced(op) ((op)->op_state & OP_VFS_STATE_SERVICED) argument
170 #define op_state_purged(op) ((op)->op_state & OP_VFS_STATE_PURGED) argument
[all …]
Dorangefs-sysfs.c338 new_op->upcall.req.param.op = in sysfs_service_op_show()
342 new_op->upcall.req.param.op = in sysfs_service_op_show()
346 new_op->upcall.req.param.op = in sysfs_service_op_show()
351 new_op->upcall.req.param.op = in sysfs_service_op_show()
356 new_op->upcall.req.param.op = in sysfs_service_op_show()
361 new_op->upcall.req.param.op = in sysfs_service_op_show()
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()
377 new_op->upcall.req.param.op = in sysfs_service_op_show()
[all …]
Dorangefs-utils.c11 __s32 fsid_of_op(struct orangefs_kernel_op_s *op) in fsid_of_op() argument
15 if (op) { in fsid_of_op()
16 switch (op->upcall.type) { in fsid_of_op()
18 fsid = op->upcall.req.io.refn.fs_id; in fsid_of_op()
21 fsid = op->upcall.req.lookup.parent_refn.fs_id; in fsid_of_op()
24 fsid = op->upcall.req.create.parent_refn.fs_id; in fsid_of_op()
27 fsid = op->upcall.req.getattr.refn.fs_id; in fsid_of_op()
30 fsid = op->upcall.req.remove.parent_refn.fs_id; in fsid_of_op()
33 fsid = op->upcall.req.mkdir.parent_refn.fs_id; in fsid_of_op()
36 fsid = op->upcall.req.readdir.refn.fs_id; in fsid_of_op()
[all …]
Dorangefs-mod.c224 struct orangefs_kernel_op_s *op; in purge_inprogress_ops() local
228 list_for_each_entry_safe(op, in purge_inprogress_ops()
232 set_op_state_purged(op); in purge_inprogress_ops()
236 get_opname_string(op), in purge_inprogress_ops()
237 op->op_state, in purge_inprogress_ops()
/fs/dlm/
Dplock.c64 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/
Drdwr.c54 ASSERT(monitor->op); in cachefiles_read_waiter()
56 object = container_of(monitor->op->op.object, in cachefiles_read_waiter()
60 list_add_tail(&monitor->op_link, &monitor->op->to_do); in cachefiles_read_waiter()
63 fscache_enqueue_retrieval(monitor->op); in cachefiles_read_waiter()
153 struct fscache_retrieval *op; in cachefiles_read_copier() local
156 op = container_of(_op, struct fscache_retrieval, op); in cachefiles_read_copier()
157 object = container_of(op->op.object, in cachefiles_read_copier()
165 while (!list_empty(&op->to_do)) { in cachefiles_read_copier()
166 monitor = list_entry(op->to_do.next, in cachefiles_read_copier()
180 fscache_mark_page_cached(monitor->op, in cachefiles_read_copier()
[all …]
Dinterface.c389 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/
Dfault_inject.c34 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_read() local
37 val = op->get(); in fault_inject_read()
50 struct nfsd_fault_inject_op *op = file_inode(file)->i_private; in fault_inject_write() local
67 val = op->set_clnt(&sa, size); in fault_inject_write()
70 op->file, write_buf, val); in fault_inject_write()
74 pr_info("NFSD Fault Injection: %s (all)", op->file); in fault_inject_write()
77 op->file, val); in fault_inject_write()
78 val = op->set_val(val); in fault_inject_write()
79 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 …]
Dnfs4proc.c482 …2 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op) in nfsd4_open_omfg() argument
484 struct nfsd4_open *open = (struct nfsd4_open *)&op->u; in nfsd4_open_omfg()
486 if (!seqid_mutating_err(ntohl(op->status))) in nfsd4_open_omfg()
487 return op->status; in nfsd4_open_omfg()
489 return op->status; in nfsd4_open_omfg()
490 open->op_xdr_error = op->status; in nfsd4_open_omfg()
1540 typedef u32(*nfsd4op_rsize)(struct svc_rqst *, struct nfsd4_op *op);
1602 struct nfsd4_op *op = &args->ops[0]; in nfs41_check_op_ordering() local
1610 if (op->status == nfserr_op_illegal) in nfs41_check_op_ordering()
1612 if (!(nfsd4_ops[op->opnum].op_flags & ALLOWED_AS_FIRST_OP)) in nfs41_check_op_ordering()
[all …]
/fs/isofs/
Djoliet.c20 unsigned char *op; in uni16_to_x8() local
23 op = ascii; in uni16_to_x8()
27 llen = nls->uni2char(be16_to_cpu(ch), op, NLS_MAX_CHARSET_SIZE); in uni16_to_x8()
29 op += llen; in uni16_to_x8()
31 *op++ = '?'; in uni16_to_x8()
36 *op = 0; in uni16_to_x8()
37 return (op - ascii); in uni16_to_x8()
/fs/nls/
Dnls_base.c135 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/
Dseq_file.c61 int seq_open(struct file *file, const struct seq_operations *op) in seq_open() argument
74 p->op = op; in seq_open()
119 p = m->op->start(m, &index); in traverse()
124 error = m->op->show(m, p); in traverse()
146 p = m->op->next(m, p, &index); in traverse()
148 m->op->stop(m, p); in traverse()
153 m->op->stop(m, p); in traverse()
235 p = m->op->start(m, &pos); in seq_read()
240 err = m->op->show(m, p); in seq_read()
246 p = m->op->next(m, p, &pos); in seq_read()
[all …]
Dopen.c913 static inline int build_open_flags(int flags, umode_t mode, struct open_flags *op) in build_open_flags() argument
925 op->mode = (mode & S_IALLUGO) | S_IFREG; in build_open_flags()
927 op->mode = 0; in build_open_flags()
955 op->open_flag = flags; in build_open_flags()
966 op->acc_mode = acc_mode; in build_open_flags()
968 op->intent = flags & O_PATH ? 0 : LOOKUP_OPEN; in build_open_flags()
971 op->intent |= LOOKUP_CREATE; in build_open_flags()
973 op->intent |= LOOKUP_EXCL; in build_open_flags()
980 op->lookup_flags = lookup_flags; in build_open_flags()
997 struct open_flags op; in file_open_name() local
[all …]
Ddirect-io.c111 int op; member
167 if (ret < 0 && sdio->blocks_available && (dio->op == REQ_OP_WRITE)) { in dio_refill_pages()
246 if ((dio->op == REQ_OP_READ) && in dio_complete()
281 if (dio->op == REQ_OP_WRITE) in dio_complete()
383 bio_set_op_attrs(bio, dio->op, dio->op_flags); in dio_bio_alloc()
411 if (dio->is_async && dio->op == REQ_OP_READ && dio->should_dirty) in dio_bio_submit()
486 if (dio->is_async && dio->op == REQ_OP_READ && dio->should_dirty) { in dio_bio_complete()
493 if (dio->op == REQ_OP_READ && !PageCompound(page) && in dio_bio_complete()
646 create = dio->op == REQ_OP_WRITE; in get_more_blocks()
796 if (dio->op == REQ_OP_WRITE) { in submit_page_section()
[all …]
/fs/ceph/
Dstrings.c33 const char *ceph_session_op_name(int op) in ceph_session_op_name() argument
35 switch (op) { in ceph_session_op_name()
52 const char *ceph_mds_op_name(int op) in ceph_mds_op_name() argument
54 switch (op) { in ceph_mds_op_name()
87 const char *ceph_cap_op_name(int op) in ceph_cap_op_name() argument
89 switch (op) { in ceph_cap_op_name()
Ddir.c370 int op = ceph_snap(inode) == CEPH_SNAPDIR ? in ceph_readdir() local
391 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_readdir()
740 int op; in ceph_lookup() local
777 op = ceph_snap(dir) == CEPH_SNAPDIR ? in ceph_lookup()
779 req = ceph_mdsc_create_request(mdsc, op, USE_ANY_MDS); in ceph_lookup()
924 int op; in ceph_mkdir() local
928 op = CEPH_MDS_OP_MKSNAP; in ceph_mkdir()
933 op = CEPH_MDS_OP_MKDIR; in ceph_mkdir()
943 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_mkdir()
1041 int op; in ceph_unlink() local
[all …]
Dlocks.c162 u16 op = CEPH_MDS_OP_SETFILELOCK; in ceph_lock() local
174 op = CEPH_MDS_OP_GETFILELOCK; in ceph_lock()
185 err = ceph_lock_message(CEPH_LOCK_FCNTL, op, file, lock_cmd, wait, fl); in ceph_lock()
187 if (op != CEPH_MDS_OP_GETFILELOCK) { in ceph_lock()
190 if (err && (CEPH_MDS_OP_SETFILELOCK == op)) { in ceph_lock()
194 ceph_lock_message(CEPH_LOCK_FCNTL, op, file, in ceph_lock()
/fs/hfsplus/
Dunicode.c127 u8 *op; in hfsplus_uni2asc() local
132 op = astr; in hfsplus_uni2asc()
192 res = nls->uni2char(c0, op, len); in hfsplus_uni2asc()
196 *op = '?'; in hfsplus_uni2asc()
199 op += res; in hfsplus_uni2asc()
235 res = nls->uni2char(cc, op, len); in hfsplus_uni2asc()
239 *op = '?'; in hfsplus_uni2asc()
242 op += res; in hfsplus_uni2asc()
247 *len_p = (char *)op - astr; in hfsplus_uni2asc()
/fs/nfs/
Dcallback_xdr.c193 static __be32 decode_op_hdr(struct xdr_stream *xdr, unsigned int *op) in decode_op_hdr() argument
199 *op = ntohl(*p); in decode_op_hdr()
694 static __be32 encode_op_hdr(struct xdr_stream *xdr, uint32_t op, __be32 res) in encode_op_hdr() argument
701 *p++ = htonl(op); in encode_op_hdr()
775 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
794 *op = &callback_ops[op_nr]; in preprocess_nfs41_op()
836 preprocess_nfs41_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs41_op() argument
848 preprocess_nfs42_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs42_op() argument
850 __be32 status = preprocess_nfs41_op(nop, op_nr, op); in preprocess_nfs42_op()
860 preprocess_nfs42_op(int nop, unsigned int op_nr, struct callback_op **op) in preprocess_nfs42_op() argument
[all …]
/fs/freevxfs/
Dvxfs_olt.c81 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()

1234