Home
last modified time | relevance | path

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

123456

/fs/afs/
Dfs_operation.c20 struct afs_operation *op; in afs_alloc_operation() local
24 op = kzalloc(sizeof(*op), GFP_KERNEL); in afs_alloc_operation()
25 if (!op) in afs_alloc_operation()
31 kfree(op); in afs_alloc_operation()
38 op->key = key; in afs_alloc_operation()
39 op->volume = afs_get_volume(volume, afs_volume_trace_get_new_op); in afs_alloc_operation()
40 op->net = volume->cell->net; in afs_alloc_operation()
41 op->cb_v_break = volume->cb_v_break; in afs_alloc_operation()
42 op->debug_id = atomic_inc_return(&afs_operation_debug_counter); in afs_alloc_operation()
43 op->error = -EDESTADDRREQ; in afs_alloc_operation()
[all …]
Drotate.c21 static bool afs_start_fs_iteration(struct afs_operation *op, in afs_start_fs_iteration() argument
28 read_lock(&op->volume->servers_lock); in afs_start_fs_iteration()
29 op->server_list = afs_get_serverlist( in afs_start_fs_iteration()
30 rcu_dereference_protected(op->volume->servers, in afs_start_fs_iteration()
31 lockdep_is_held(&op->volume->servers_lock))); in afs_start_fs_iteration()
32 read_unlock(&op->volume->servers_lock); in afs_start_fs_iteration()
34 op->untried = (1UL << op->server_list->nr_servers) - 1; in afs_start_fs_iteration()
35 op->index = READ_ONCE(op->server_list->preferred); in afs_start_fs_iteration()
40 for (i = 0; i < op->server_list->nr_servers; i++) { in afs_start_fs_iteration()
41 server = op->server_list->servers[i].server; in afs_start_fs_iteration()
[all …]
Ddir_silly.c15 static void afs_silly_rename_success(struct afs_operation *op) in afs_silly_rename_success() argument
17 _enter("op=%08x", op->debug_id); in afs_silly_rename_success()
19 afs_check_dir_conflict(op, &op->file[0]); in afs_silly_rename_success()
20 afs_vnode_commit_status(op, &op->file[0]); in afs_silly_rename_success()
23 static void afs_silly_rename_edit_dir(struct afs_operation *op) in afs_silly_rename_edit_dir() argument
25 struct afs_vnode_param *dvp = &op->file[0]; in afs_silly_rename_edit_dir()
27 struct afs_vnode *vnode = AFS_FS_I(d_inode(op->dentry)); in afs_silly_rename_edit_dir()
28 struct dentry *old = op->dentry; in afs_silly_rename_edit_dir()
29 struct dentry *new = op->dentry_2; in afs_silly_rename_edit_dir()
34 if (dvnode->silly_key != op->key) { in afs_silly_rename_edit_dir()
[all …]
Ddir.c726 static void afs_do_lookup_success(struct afs_operation *op) in afs_do_lookup_success() argument
736 for (i = 0; i < op->nr_files; i++) { in afs_do_lookup_success()
739 vp = &op->file[0]; in afs_do_lookup_success()
742 op->ac.abort_code = abort_code; in afs_do_lookup_success()
743 op->error = afs_abort_to_error(abort_code); in afs_do_lookup_success()
748 vp = &op->file[1]; in afs_do_lookup_success()
752 vp = &op->more_files[i - 2]; in afs_do_lookup_success()
762 afs_vnode_commit_status(op, vp); in afs_do_lookup_success()
764 inode = afs_iget(op, vp); in afs_do_lookup_success()
767 afs_cache_permit(vnode, op->key, in afs_do_lookup_success()
[all …]
Dfsclient.c240 struct afs_operation *op = call->op; in afs_deliver_fs_fetch_status() local
241 struct afs_vnode_param *vp = &op->file[op->fetch_status.which]; in afs_deliver_fs_fetch_status()
253 xdr_decode_AFSVolSync(&bp, &op->volsync); in afs_deliver_fs_fetch_status()
264 .op = afs_FS_FetchStatus,
272 void afs_fs_fetch_status(struct afs_operation *op) in afs_fs_fetch_status() argument
274 struct afs_vnode_param *vp = &op->file[op->fetch_status.which]; in afs_fs_fetch_status()
279 key_serial(op->key), vp->fid.vid, vp->fid.vnode); in afs_fs_fetch_status()
281 call = afs_alloc_flat_call(op->net, &afs_RXFSFetchStatus, in afs_fs_fetch_status()
284 return afs_op_nomem(op); in afs_fs_fetch_status()
294 afs_make_op_call(op, call, GFP_NOFS); in afs_fs_fetch_status()
[all …]
Dyfsclient.c337 struct afs_operation *op = call->op; in yfs_deliver_status_and_volsync() local
346 xdr_decode_YFSFetchStatus(&bp, call, &op->file[0].scb); in yfs_deliver_status_and_volsync()
347 xdr_decode_YFSVolSync(&bp, &op->volsync); in yfs_deliver_status_and_volsync()
358 struct afs_operation *op = call->op; in yfs_deliver_fs_fetch_data64() local
359 struct afs_vnode_param *vp = &op->file[0]; in yfs_deliver_fs_fetch_data64()
360 struct afs_read *req = op->fetch.req; in yfs_deliver_fs_fetch_data64()
439 xdr_decode_YFSVolSync(&bp, &op->volsync); in yfs_deliver_fs_fetch_data64()
460 .op = yfs_FS_FetchData64,
468 void yfs_fs_fetch_data(struct afs_operation *op) in yfs_fs_fetch_data() argument
470 struct afs_vnode_param *vp = &op->file[0]; in yfs_fs_fetch_data()
[all …]
Dxattr.c17 static void afs_acl_success(struct afs_operation *op) in afs_acl_success() argument
19 afs_vnode_commit_status(op, &op->file[0]); in afs_acl_success()
22 static void afs_acl_put(struct afs_operation *op) in afs_acl_put() argument
24 kfree(op->acl); in afs_acl_put()
41 struct afs_operation *op; in afs_xattr_get_acl() local
46 op = afs_alloc_operation(NULL, vnode->volume); in afs_xattr_get_acl()
47 if (IS_ERR(op)) in afs_xattr_get_acl()
50 afs_op_set_vnode(op, 0, vnode); in afs_xattr_get_acl()
51 op->ops = &afs_fetch_acl_operation; in afs_xattr_get_acl()
53 afs_begin_vnode_operation(op); in afs_xattr_get_acl()
[all …]
Dinode.c59 static int afs_inode_init_from_status(struct afs_operation *op, in afs_inode_init_from_status() argument
69 op->type ? op->type->name : "???"); in afs_inode_init_from_status()
80 vnode->cb_v_break = op->cb_v_break; in afs_inode_init_from_status()
81 vnode->cb_s_break = op->cb_s_break; in afs_inode_init_from_status()
125 dump_vnode(vnode, op->file[0].vnode != vnode ? op->file[0].vnode : NULL); in afs_inode_init_from_status()
141 vnode->cb_server = op->server; in afs_inode_init_from_status()
152 static void afs_apply_status(struct afs_operation *op, in afs_apply_status() argument
165 op->type ? op->type->name : "???"); in afs_apply_status()
198 inode->i_ctime = op->ctime; in afs_apply_status()
211 op->type ? op->type->name : "???", in afs_apply_status()
[all …]
Dflock.c73 struct afs_operation *op = call->op; in afs_lock_op_done() local
74 struct afs_vnode *vnode = op->file[0].vnode; in afs_lock_op_done()
176 static void afs_lock_success(struct afs_operation *op) in afs_lock_success() argument
178 _enter("op=%08x", op->debug_id); in afs_lock_success()
179 afs_vnode_commit_status(op, &op->file[0]); in afs_lock_success()
195 struct afs_operation *op; in afs_set_lock() local
204 op = afs_alloc_operation(key, vnode->volume); in afs_set_lock()
205 if (IS_ERR(op)) in afs_set_lock()
206 return PTR_ERR(op); in afs_set_lock()
208 afs_op_set_vnode(op, 0, vnode); in afs_set_lock()
[all …]
Dfile.c219 static void afs_fetch_data_notify(struct afs_operation *op) in afs_fetch_data_notify() argument
221 struct afs_read *req = op->fetch.req; in afs_fetch_data_notify()
223 int error = op->error; in afs_fetch_data_notify()
226 error = afs_abort_to_error(op->ac.abort_code); in afs_fetch_data_notify()
238 static void afs_fetch_data_success(struct afs_operation *op) in afs_fetch_data_success() argument
240 struct afs_vnode *vnode = op->file[0].vnode; in afs_fetch_data_success()
242 _enter("op=%08x", op->debug_id); in afs_fetch_data_success()
243 afs_vnode_commit_status(op, &op->file[0]); in afs_fetch_data_success()
245 atomic_long_add(op->fetch.req->actual_len, &op->net->n_fetch_bytes); in afs_fetch_data_success()
246 afs_fetch_data_notify(op); in afs_fetch_data_success()
[all …]
Dwrite.c333 static void afs_store_data_success(struct afs_operation *op) in afs_store_data_success() argument
335 struct afs_vnode *vnode = op->file[0].vnode; in afs_store_data_success()
337 op->ctime = op->file[0].scb.status.mtime_client; in afs_store_data_success()
338 afs_vnode_commit_status(op, &op->file[0]); in afs_store_data_success()
339 if (op->error == 0) { in afs_store_data_success()
340 if (!op->store.laundering) in afs_store_data_success()
341 afs_pages_written_back(vnode, op->store.pos, op->store.size); in afs_store_data_success()
343 atomic_long_add(op->store.size, &afs_v2net(vnode)->n_store_bytes); in afs_store_data_success()
359 struct afs_operation *op; in afs_store_data() local
377 op = afs_alloc_operation(wbk->key, vnode->volume); in afs_store_data()
[all …]
/fs/fscache/
Doperation.c19 static void fscache_operation_dummy_cancel(struct fscache_operation *op) in fscache_operation_dummy_cancel() argument
35 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.c187 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 …]
Dio.c30 struct fscache_retrieval *op; in __fscache_begin_read_operation() local
52 op = fscache_alloc_retrieval(cookie, NULL, NULL, NULL); in __fscache_begin_read_operation()
53 if (!op) in __fscache_begin_read_operation()
55 trace_fscache_page_op(cookie, NULL, &op->op, fscache_page_op_retr_multi); in __fscache_begin_read_operation()
67 __set_bit(FSCACHE_OP_DEC_READ_CNT, &op->op.flags); in __fscache_begin_read_operation()
69 if (fscache_submit_op(object, &op->op) < 0) in __fscache_begin_read_operation()
78 object, &op->op, in __fscache_begin_read_operation()
85 ret = object->cache->ops->begin_read_operation(rreq, op); in __fscache_begin_read_operation()
99 fscache_put_retrieval(op); in __fscache_begin_read_operation()
108 fscache_put_retrieval(op); in __fscache_begin_read_operation()
/fs/orangefs/
Dwaitqueue.c20 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 …]
Ddevorangefs-req.c48 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 …]
Dorangefs-kernel.h145 #define set_op_state_waiting(op) ((op)->op_state = OP_VFS_STATE_WAITING) argument
146 #define set_op_state_inprogress(op) ((op)->op_state = OP_VFS_STATE_INPROGR) argument
147 #define set_op_state_given_up(op) ((op)->op_state = OP_VFS_STATE_GIVEN_UP) argument
148 static inline void set_op_state_serviced(struct orangefs_kernel_op_s *op) in set_op_state_serviced() argument
150 op->op_state = OP_VFS_STATE_SERVICED; in set_op_state_serviced()
151 complete(&op->waitq); in set_op_state_serviced()
154 #define op_state_waiting(op) ((op)->op_state & OP_VFS_STATE_WAITING) argument
155 #define op_state_in_progress(op) ((op)->op_state & OP_VFS_STATE_INPROGR) argument
156 #define op_state_serviced(op) ((op)->op_state & OP_VFS_STATE_SERVICED) argument
157 #define op_state_purged(op) ((op)->op_state & OP_VFS_STATE_PURGED) argument
[all …]
Ddir.c63 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 …]
Dorangefs-sysfs.c365 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 …]
Dorangefs-utils.c14 __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 …]
/fs/dlm/
Dplock.c61 static void dlm_release_plock_op(struct plock_op *op) in dlm_release_plock_op() argument
63 kfree(op->data); in dlm_release_plock_op()
64 kfree(op); in dlm_release_plock_op()
67 static void send_op(struct plock_op *op) in send_op() argument
69 set_version(&op->info); in send_op()
70 INIT_LIST_HEAD(&op->list); in send_op()
72 list_add_tail(&op->list, &send_list); in send_op()
85 struct plock_op *op; in do_unlock_close() local
87 op = kzalloc(sizeof(*op), GFP_NOFS); in do_unlock_close()
88 if (!op) in do_unlock_close()
[all …]
/fs/cachefiles/
Drdwr.c26 struct fscache_retrieval *op = monitor->op; in cachefiles_read_waiter() local
50 ASSERT(op); in cachefiles_read_waiter()
57 fscache_get_retrieval(op); in cachefiles_read_waiter()
59 object = container_of(op->op.object, struct cachefiles_object, fscache); in cachefiles_read_waiter()
61 list_add_tail(&monitor->op_link, &op->to_do); in cachefiles_read_waiter()
62 fscache_enqueue_retrieval(op); in cachefiles_read_waiter()
65 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/
Dfault_inject.c36 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 …]
Dnfs4proc.c490 …2 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op) in nfsd4_open_omfg() argument
492 struct nfsd4_open *open = &op->u.open; in nfsd4_open_omfg()
494 if (!seqid_mutating_err(ntohl(op->status))) in nfsd4_open_omfg()
495 return op->status; in nfsd4_open_omfg()
497 return op->status; in nfsd4_open_omfg()
498 open->op_xdr_error = op->status; in nfsd4_open_omfg()
499 return nfsd4_open(rqstp, cstate, &op->u); in nfsd4_open_omfg()
2365 const struct nfsd4_operation *OPDESC(struct nfsd4_op *op) in OPDESC() argument
2367 return &nfsd4_ops[op->opnum]; in OPDESC()
2370 bool nfsd4_cache_this_op(struct nfsd4_op *op) in nfsd4_cache_this_op() argument
[all …]
/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 …]

123456