Lines Matching refs:new_op
22 struct orangefs_kernel_op_s *new_op; in flush_racache() local
30 new_op = op_alloc(ORANGEFS_VFS_OP_RA_FLUSH); in flush_racache()
31 if (!new_op) in flush_racache()
33 new_op->upcall.req.ra_cache_flush.refn = orangefs_inode->refn; in flush_racache()
35 ret = service_operation(new_op, "orangefs_flush_racache", in flush_racache()
41 op_release(new_op); in flush_racache()
55 struct orangefs_kernel_op_s *new_op = NULL; in wait_for_direct_io() local
62 new_op = op_alloc(ORANGEFS_VFS_OP_FILE_IO); in wait_for_direct_io()
63 if (!new_op) in wait_for_direct_io()
67 new_op->upcall.req.io.readahead_size = readahead_size; in wait_for_direct_io()
68 new_op->upcall.req.io.io_type = type; in wait_for_direct_io()
69 new_op->upcall.req.io.refn = orangefs_inode->refn; in wait_for_direct_io()
85 new_op, in wait_for_direct_io()
88 new_op->uses_shared_memory = 1; in wait_for_direct_io()
89 new_op->upcall.req.io.buf_index = buffer_index; in wait_for_direct_io()
90 new_op->upcall.req.io.count = total_size; in wait_for_direct_io()
91 new_op->upcall.req.io.offset = *offset; in wait_for_direct_io()
93 new_op->upcall.uid = from_kuid(&init_user_ns, wr->uid); in wait_for_direct_io()
94 new_op->upcall.gid = from_kgid(&init_user_ns, wr->gid); in wait_for_direct_io()
125 new_op->upcall.uid = 0; in wait_for_direct_io()
127 new_op->upcall.uid = 0; in wait_for_direct_io()
152 llu(new_op->tag)); in wait_for_direct_io()
155 ret = service_operation(new_op, in wait_for_direct_io()
170 if (ret == -EAGAIN && op_state_purged(new_op)) { in wait_for_direct_io()
193 switch (new_op->op_state - OP_VFS_STATE_GIVEN_UP) { in wait_for_direct_io()
219 new_op->op_state); in wait_for_direct_io()
226 new_op->op_state, in wait_for_direct_io()
227 new_op); in wait_for_direct_io()
235 if (orangefs_cancel_op_in_progress(new_op)) in wait_for_direct_io()
244 if (type == ORANGEFS_IO_READ && new_op->downcall.resp.io.amt_complete) { in wait_for_direct_io()
251 copy_amount = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io()
266 (int)new_op->downcall.resp.io.amt_complete); in wait_for_direct_io()
268 ret = new_op->downcall.resp.io.amt_complete; in wait_for_direct_io()
278 op_release(new_op); in wait_for_direct_io()
445 struct orangefs_kernel_op_s *new_op = NULL; in orangefs_fsync() local
452 new_op = op_alloc(ORANGEFS_VFS_OP_FSYNC); in orangefs_fsync()
453 if (!new_op) in orangefs_fsync()
455 new_op->upcall.req.fsync.refn = orangefs_inode->refn; in orangefs_fsync()
457 ret = service_operation(new_op, in orangefs_fsync()
465 op_release(new_op); in orangefs_fsync()