/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 | 31 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 …]
|
D | devorangefs-req.c | 47 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 …]
|
D | orangefs-kernel.h | 158 #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 …]
|
D | orangefs-sysfs.c | 338 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 …]
|
D | orangefs-utils.c | 11 __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 …]
|
D | orangefs-mod.c | 224 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/ |
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 | 54 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 …]
|
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 | 34 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 …]
|
D | nfs4proc.c | 482 …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/ |
D | joliet.c | 20 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/ |
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 | 61 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 …]
|
D | open.c | 913 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 …]
|
D | direct-io.c | 111 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/ |
D | strings.c | 33 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()
|
D | dir.c | 370 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 …]
|
D | locks.c | 162 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/ |
D | unicode.c | 127 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/ |
D | callback_xdr.c | 193 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/ |
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()
|