Home
last modified time | relevance | path

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

123456

/fs/afs/
A Drotate.c49 op->server_states = kcalloc(op->server_list->nr_servers, sizeof(op->server_states[0]), in afs_start_fs_iteration()
126 op->volume->vid, op->volume->name, &op->server->uuid, m); in afs_busy()
165 op->debug_id, op->nr_iterations, op->volume->vid, in afs_select_fileserver()
167 op->addr_index, op->addr_tried, in afs_select_fileserver()
462 op->type ? op->type->name : "???", op->debug_id); in afs_select_fileserver()
597 op->estate = op->server_states[op->server_index].endpoint_state; in afs_select_fileserver()
633 error = afs_wait_for_one_fs_probe(op->server, op->estate, op->addr_tried, in afs_select_fileserver()
646 error = afs_wait_for_one_fs_probe(op->server, op->estate, op->addr_tried, in afs_select_fileserver()
718 op->file[1].cb_break_before, op->flags, op->cumul_error.error); in afs_dump_edestaddrreq()
720 op->untried_servers, op->server_index, op->nr_iterations); in afs_dump_edestaddrreq()
[all …]
A Dfs_operation.c24 op = kzalloc(sizeof(*op), GFP_KERNEL); in afs_alloc_operation()
288 op->ops->issue_yfs_rpc(op); in afs_wait_for_operation()
290 op->ops->issue_afs_rpc(op); in afs_wait_for_operation()
297 op->call_error = op->call->error; in afs_wait_for_operation()
308 op->ops->success(op); in afs_wait_for_operation()
311 op->ops->aborted(op); in afs_wait_for_operation()
314 op->ops->failed(op); in afs_wait_for_operation()
321 op->ops->edit_dir(op); in afs_wait_for_operation()
336 if (op->ops && op->ops->put) in afs_put_operation()
337 op->ops->put(op); in afs_put_operation()
[all …]
A Ddir_silly.c19 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()
69 if (IS_ERR(op)) in afs_do_silly_rename()
70 return PTR_ERR(op); in afs_do_silly_rename()
81 op->dentry = old; in afs_do_silly_rename()
82 op->dentry_2 = new; in afs_do_silly_rename()
159 afs_check_dir_conflict(op, &op->file[0]); in afs_silly_unlink_success()
160 afs_vnode_commit_status(op, &op->file[0]); in afs_silly_unlink_success()
161 afs_vnode_commit_status(op, &op->file[1]); in afs_silly_unlink_success()
162 afs_update_dentry_version(op, &op->file[0], op->dentry); in afs_silly_unlink_success()
[all …]
A Ddir.c1273 afs_vnode_commit_status(op, &op->file[0]); in afs_create_success()
1274 afs_update_dentry_version(op, &op->file[0], op->dentry); in afs_create_success()
1368 afs_vnode_commit_status(op, &op->file[0]); in afs_rmdir_success()
1369 afs_update_dentry_version(op, &op->file[0], op->dentry); in afs_rmdir_success()
1513 afs_check_dir_conflict(op, &op->file[0]); in afs_unlink_success()
1514 afs_vnode_commit_status(op, &op->file[0]); in afs_unlink_success()
1515 afs_vnode_commit_status(op, &op->file[1]); in afs_unlink_success()
1516 afs_update_dentry_version(op, &op->file[0], op->dentry); in afs_unlink_success()
1831 afs_check_dir_conflict(op, &op->file[1]); in afs_rename_success()
1832 afs_vnode_commit_status(op, &op->file[0]); in afs_rename_success()
[all …]
A Dfsclient.c240 struct afs_operation *op = call->op; in afs_deliver_fs_fetch_status() local
303 struct afs_operation *op = call->op; in afs_deliver_fs_fetch_data() local
499 struct afs_operation *op = call->op; in afs_deliver_fs_create_vnode() local
637 struct afs_operation *op = call->op; in afs_deliver_fs_file_status_and_vol() local
759 struct afs_operation *op = call->op; in afs_deliver_fs_link() local
840 struct afs_operation *op = call->op; in afs_deliver_fs_symlink() local
936 struct afs_operation *op = call->op; in afs_deliver_fs_rename() local
1033 struct afs_operation *op = call->op; in afs_deliver_fs_store_data() local
1318 struct afs_operation *op = call->op; in afs_deliver_fs_get_volume_status() local
1482 struct afs_operation *op = call->op; in afs_deliver_fs_xxxx_lock() local
[all …]
A Dyfsclient.c333 struct afs_operation *op = call->op; in yfs_deliver_status_and_volsync() local
354 struct afs_operation *op = call->op; in yfs_deliver_fs_fetch_data64() local
512 struct afs_operation *op = call->op; in yfs_deliver_fs_create_vnode() local
644 struct afs_operation *op = call->op; in yfs_deliver_fs_remove_file2() local
730 struct afs_operation *op = call->op; in yfs_deliver_fs_remove() local
842 struct afs_operation *op = call->op; in yfs_deliver_fs_link() local
916 struct afs_operation *op = call->op; in yfs_deliver_fs_symlink() local
998 struct afs_operation *op = call->op; in yfs_deliver_fs_rename() local
1230 struct afs_operation *op = call->op; in yfs_deliver_fs_get_volume_status() local
1528 struct afs_operation *op = call->op; in yfs_deliver_fs_fetch_status() local
[all …]
A Dxattr.c19 afs_vnode_commit_status(op, &op->file[0]); in afs_acl_success()
24 kfree(op->acl); in afs_acl_put()
47 if (IS_ERR(op)) in afs_xattr_get_acl()
55 acl = op->acl; in afs_xattr_get_acl()
56 op->acl = NULL; in afs_xattr_get_acl()
80 afs_op_nomem(op); in afs_make_acl()
86 op->acl = acl; in afs_make_acl()
112 if (IS_ERR(op)) in afs_xattr_set_acl()
170 if (IS_ERR(op)) in afs_xattr_get_yfs()
174 op->yacl = yacl; in afs_xattr_get_yfs()
[all …]
A Dfile.c216 afs_vnode_commit_status(op, &op->file[0]); in afs_fetch_data_success()
218 atomic_long_add(op->fetch.subreq->transferred, &op->net->n_fetch_bytes); in afs_fetch_data_success()
239 op->call_error = 0; in afs_issue_read_call()
249 if (op->call_responded && op->server) in afs_end_read()
252 if (!afs_op_error(op)) in afs_end_read()
269 struct afs_operation *op = call->op; in afs_read_receive() local
296 op->call = NULL; in afs_read_receive()
297 call->op = NULL; in afs_read_receive()
308 afs_end_read(op); in afs_read_receive()
346 if (IS_ERR(op)) { in afs_issue_read()
[all …]
A Dinode.c163 op->type ? op->type->name : "???"); in afs_inode_init_from_status()
265 op->type ? op->type->name : "???"); in afs_apply_status()
317 op->type ? op->type->name : "???", in afs_apply_status()
318 op->debug_id); in afs_apply_status()
426 struct afs_vnode_param *vp = &op->file[op->fetch_status.which]; in afs_fetch_status_success()
461 if (IS_ERR(op)) in afs_fetch_status()
466 op->nr_files = 1; in afs_fetch_status()
649 if (IS_ERR(op)) { in afs_root_iget()
650 ret = PTR_ERR(op); in afs_root_iget()
656 op->nr_files = 1; in afs_root_iget()
[all …]
A Dvalidation.c165 if (op->server == se->server) { in __afs_is_server_excluded()
187 ret = afs_check_volume_status(op->volume, op); in afs_is_server_excluded()
202 time64_t new = op->volsync.creation; in afs_update_volume_creation_time()
268 time64_t old = op->pre_volsync.update; in afs_update_volume_update_time()
269 time64_t new = op->volsync.update; in afs_update_volume_update_time()
338 _enter("%llx", op->volume->vid); in afs_update_volume_state()
340 if (op->volsync.creation != TIME64_MIN || op->volsync.update != TIME64_MIN) { in afs_update_volume_state()
348 if (op->cb_v_break == cb_v_break && in afs_update_volume_state()
349 (op->file[0].scb.have_cb || op->file[1].scb.have_cb)) { in afs_update_volume_state()
352 if (!op->file[0].scb.have_cb) in afs_update_volume_state()
[all …]
A Dwrite.c71 op->ctime = op->file[0].scb.status.mtime_client; in afs_store_data_success()
72 afs_vnode_commit_status(op, &op->file[0]); in afs_store_data_success()
73 if (!afs_op_error(op)) { in afs_store_data_success()
74 afs_pages_written_back(vnode, op->store.pos, op->store.size); in afs_store_data_success()
107 struct afs_operation *op; in afs_issue_write_worker() local
132 if (IS_ERR(op)) in afs_issue_write_worker()
136 op->file[0].dv_delta = 1; in afs_issue_write_worker()
138 op->store.pos = pos; in afs_issue_write_worker()
139 op->store.size = len; in afs_issue_write_worker()
149 afs_wait_for_operation(op); in afs_issue_write_worker()
[all …]
A Dflock.c73 struct afs_operation *op = call->op; in afs_lock_op_done() local
178 afs_vnode_commit_status(op, &op->file[0]); in afs_lock_success()
194 struct afs_operation *op; in afs_set_lock() local
204 if (IS_ERR(op)) in afs_set_lock()
205 return PTR_ERR(op); in afs_set_lock()
209 op->lock.type = type; in afs_set_lock()
225 struct afs_operation *op; in afs_extend_lock() local
235 if (IS_ERR(op)) in afs_extend_lock()
236 return PTR_ERR(op); in afs_extend_lock()
266 if (IS_ERR(op)) in afs_release_lock()
[all …]
/fs/orangefs/
A Dwaitqueue.c83 op, in service_operation()
151 op); in service_operation()
202 op); in service_operation()
213 op->slot_to_free = op->upcall.req.io.buf_index; in orangefs_cancel_op_in_progress()
214 memset(&op->upcall, 0, sizeof(op->upcall)); in orangefs_cancel_op_in_progress()
215 memset(&op->downcall, 0, sizeof(op->downcall)); in orangefs_cancel_op_in_progress()
282 op); in orangefs_clean_up_interrupted_operation()
292 op); in orangefs_clean_up_interrupted_operation()
351 op); in wait_for_matching_downcall()
359 op, in wait_for_matching_downcall()
[all …]
A Ddevorangefs-req.c71 if (op->tag == tag && !op_state_purged(op) && in orangefs_devreq_remove_op()
75 return op; in orangefs_devreq_remove_op()
195 spin_lock(&op->lock); in orangefs_devreq_read()
196 if (unlikely(op_state_purged(op) || op_state_given_up(op))) { in orangefs_devreq_read()
211 llu(op->tag), in orangefs_devreq_read()
232 llu(op->tag), get_opname_string(op)); in orangefs_devreq_read()
245 cur_op = op; in orangefs_devreq_read()
416 if (!op) { in orangefs_devreq_write_iter()
469 op->downcall.trailer_buf = vzalloc(op->downcall.trailer_size); in orangefs_devreq_write_iter()
488 put_cancel(op); in orangefs_devreq_write_iter()
[all …]
A Dorangefs-kernel.h137 #define set_op_state_waiting(op) ((op)->op_state = OP_VFS_STATE_WAITING) argument
139 #define set_op_state_given_up(op) ((op)->op_state = OP_VFS_STATE_GIVEN_UP) argument
143 complete(&op->waitq); in set_op_state_serviced()
146 #define op_state_waiting(op) ((op)->op_state & OP_VFS_STATE_WAITING) argument
147 #define op_state_in_progress(op) ((op)->op_state & OP_VFS_STATE_INPROGR) argument
148 #define op_state_serviced(op) ((op)->op_state & OP_VFS_STATE_SERVICED) argument
149 #define op_state_purged(op) ((op)->op_state & OP_VFS_STATE_PURGED) argument
150 #define op_state_given_up(op) ((op)->op_state & OP_VFS_STATE_GIVEN_UP) argument
159 op_release(op); in put_cancel()
164 spin_lock(&op->lock); in set_op_state_purged()
[all …]
A Ddir.c74 op->uses_shared_memory = 1; in do_readdir()
94 if (op_state_purged(op)) { in do_readdir()
106 vfree(op->downcall.trailer_buf); in do_readdir()
109 } else if (op->downcall.status) { in do_readdir()
112 return op->downcall.status; in do_readdir()
126 op->downcall.trailer_buf; in do_readdir()
163 struct orangefs_kernel_op_s *op; in orangefs_dir_more() local
167 if (!op) { in orangefs_dir_more()
171 r = do_readdir(od, inode, op); in orangefs_dir_more()
176 r = parse_readdir(od, op); in orangefs_dir_more()
[all …]
A Dorangefs-sysfs.c358 new_op->upcall.req.param.op = in sysfs_service_op_show()
362 new_op->upcall.req.param.op = in sysfs_service_op_show()
366 new_op->upcall.req.param.op = in sysfs_service_op_show()
371 new_op->upcall.req.param.op = in sysfs_service_op_show()
376 new_op->upcall.req.param.op = in sysfs_service_op_show()
381 new_op->upcall.req.param.op = in sysfs_service_op_show()
386 new_op->upcall.req.param.op = in sysfs_service_op_show()
390 new_op->upcall.req.param.op = in sysfs_service_op_show()
394 new_op->upcall.req.param.op = in sysfs_service_op_show()
398 new_op->upcall.req.param.op = in sysfs_service_op_show()
[all …]
/fs/bcachefs/
A Dio_write.c408 op->new_i_size, &op->i_sectors_delta, in bch2_write_index_default()
556 op->end_io(op); in bch2_write_done()
873 op->crc.offset, op->crc.live_size, in bch2_write_rechecksum()
900 op->csum_type != op->crc.csum_type) { in bch2_write_prep_encoded_data()
944 op->crc.csum_type != op->csum_type) { in bch2_write_prep_encoded_data()
954 (op->compression_opt || op->crc.csum_type != op->csum_type)) { in bch2_write_prep_encoded_data()
970 bch2_write_op_error(op, op->pos.offset, in bch2_write_prep_encoded_data()
1014 init_append_extent(op, wp, op->version, op->crc); in bch2_write_extent()
1442 bch2_write_op_error(op, op->pos.offset, in bch2_nocow_write()
1510 memset(&op->failed, 0, sizeof(op->failed)); in __bch2_write()
[all …]
A Dio_write.h23 ? op->c->copygc_wq in index_update_wq()
36 op->c = c; in bch2_write_op_init()
37 op->end_io = NULL; in bch2_write_op_init()
38 op->flags = 0; in bch2_write_op_init()
39 op->written = 0; in bch2_write_op_init()
40 op->error = 0; in bch2_write_op_init()
43 op->nr_replicas = 0; in bch2_write_op_init()
49 op->target = 0; in bch2_write_op_init()
50 op->opts = opts; in bch2_write_op_init()
51 op->subvol = 0; in bch2_write_op_init()
[all …]
A Ddata_update.c267 struct data_update *m = container_of(op, struct data_update, op); in __bch2_data_update_index_update()
502 return bch2_trans_run(op->c, __bch2_data_update_index_update(trans, op)); in bch2_data_update_index_update()
513 m->op.wbio.bio.bi_iter.bi_size = m->op.crc.compressed_size << 9; in bch2_data_update_read_done()
549 bch2_keylist_init(&update->op.insert_keys, update->op.inline_keys); in bch2_update_unwritten_extent()
572 update->op.target, in bch2_update_unwritten_extent()
661 bch2_data_update_opts_to_text(out, m->op.c, &m->op.opts, &m->data_opts); in bch2_data_update_to_text()
673 bch2_data_update_opts_to_text(out, m->op.c, &m->op.opts, &m->data_opts); in bch2_data_update_inflight_to_text()
779 ? m->op.target in can_write_extent()
854 m->op.nr_replicas = 0; in bch2_data_update_init()
926 m->op.nr_replicas = max((unsigned) m->op.nr_replicas, 1); in bch2_data_update_init()
[all …]
A Dfs-io-direct.c248 struct bch_write_op op; member
365 if (!dio->op.error) { in bch2_dio_write_flush()
368 dio->op.error = ret; in bch2_dio_write_flush()
371 &dio->op.cl); in bch2_dio_write_flush()
377 closure_sync(&dio->op.cl); in bch2_dio_write_flush()
512 dio->op.end_io = sync in bch2_dio_write_loop()
515 dio->op.target = dio->op.opts.foreground_target; in bch2_dio_write_loop()
517 dio->op.nr_replicas = dio->op.opts.data_replicas; in bch2_dio_write_loop()
561 dio->op.error = ret; in bch2_dio_write_loop()
584 struct dio_write *dio = container_of(op, struct dio_write, op); in bch2_dio_write_loop_async()
[all …]
A Dio_misc.c279 subvol_inum inum = { le32_to_cpu(op->v.subvol), le64_to_cpu(op->v.inum) }; in __bch2_resume_logged_op_truncate()
310 struct bkey_i_logged_op_truncate op; in bch2_truncate() local
312 bkey_logged_op_truncate_init(&op.k_i); in bch2_truncate()
314 op.v.inum = cpu_to_le64(inum.inum); in bch2_truncate()
390 subvol_inum inum = { le32_to_cpu(op->v.subvol), le64_to_cpu(op->v.inum) }; in __bch2_resume_logged_op_finsert()
396 u64 pos = le64_to_cpu(op->v.pos); in __bch2_resume_logged_op_finsert()
418 switch (op->v.state) { in __bch2_resume_logged_op_finsert()
507 pos = le64_to_cpu(op->v.pos); in __bch2_resume_logged_op_finsert()
543 struct bkey_i_logged_op_finsert op; in bch2_fcollapse_finsert() local
546 bkey_logged_op_finsert_init(&op.k_i); in bch2_fcollapse_finsert()
[all …]
/fs/dlm/
A Dplock.c60 op = iter; in plock_lookup_waiter()
65 return op; in plock_lookup_waiter()
88 kfree(op); in dlm_release_plock_op()
105 op = kzalloc(sizeof(*op), GFP_NOFS); in do_lock_cancel()
106 if (!op) in do_lock_cancel()
134 op = kzalloc(sizeof(*op), GFP_NOFS); in dlm_posix_lock()
135 if (!op) { in dlm_posix_lock()
300 op = kzalloc(sizeof(*op), GFP_NOFS); in dlm_posix_unlock()
404 op->data->callback(op->data->fl, -EINTR); in dlm_posix_cancel()
433 op = kzalloc(sizeof(*op), GFP_NOFS); in dlm_posix_get()
[all …]
/fs/nfsd/
A Dnfs4proc.c2849 op->status = nfsd4_open_omfg(rqstp, cstate, op); in nfsd4_proc_compound()
2873 u32 plen = op->opdesc->op_rsize_bop(rqstp, op); in nfsd4_proc_compound()
2883 if (op->status) in nfsd4_proc_compound()
2887 op->opdesc->op_get_currentstateid(cstate, &op->u); in nfsd4_proc_compound()
2888 op->status = op->opdesc->op_func(rqstp, cstate, &op->u); in nfsd4_proc_compound()
2889 trace_nfsd_compound_op_err(rqstp, op->opnum, op->status); in nfsd4_proc_compound()
2899 op->opdesc->op_set_currentstateid(cstate, &op->u); in nfsd4_proc_compound()
2912 status = op->status = op->replay->rp_status; in nfsd4_proc_compound()
3789 if (op->opnum == OP_ILLEGAL || op->status == nfserr_notsupp) in nfsd4_max_reply()
3793 return OPDESC(op)->op_rsize_bop(rqstp, op); in nfsd4_max_reply()
[all …]
/fs/isofs/
A Djoliet.c21 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()

Completed in 824 milliseconds

123456