48 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
192 	list_for_each_entry_safe(op, temp, &orangefs_request_list, list) {  in orangefs_devreq_read()
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()
197 			spin_unlock(&op->lock);  in orangefs_devreq_read()
201 		fsid = fsid_of_op(op);  in orangefs_devreq_read()
211 				    llu(op->tag),  in orangefs_devreq_read()
212 				    get_opname_string(op));  in orangefs_devreq_read()
213 				spin_unlock(&op->lock);  in orangefs_devreq_read()
224 				   !(op->upcall.type ==  in orangefs_devreq_read()
226 				     op->upcall.type ==  in orangefs_devreq_read()
228 				     op->upcall.type ==  in orangefs_devreq_read()
232 				    llu(op->tag), get_opname_string(op));  in orangefs_devreq_read()
236 				spin_unlock(&op->lock);  in orangefs_devreq_read()
245 		cur_op = op;  in orangefs_devreq_read()
365 	struct orangefs_kernel_op_s *op = NULL;  in orangefs_devreq_write_iter()  local
415 	op = orangefs_devreq_remove_op(head.tag);  in orangefs_devreq_write_iter()
416 	if (!op) {  in orangefs_devreq_write_iter()
423 	if (!copy_from_iter_full(&op->downcall, downcall_size, iter)) {  in orangefs_devreq_write_iter()
428 	if (op->downcall.status)  in orangefs_devreq_write_iter()
436 	if ((head_size + downcall_size + op->downcall.trailer_size) != total) {  in orangefs_devreq_write_iter()
443 			   op->downcall.trailer_size,  in orangefs_devreq_write_iter()
449 	if ((op->downcall.type != ORANGEFS_VFS_OP_READDIR) &&  in orangefs_devreq_write_iter()
450 	    (op->downcall.trailer_size != 0)) {  in orangefs_devreq_write_iter()
453 			   op->downcall.type);  in orangefs_devreq_write_iter()
458 	if ((op->downcall.type == ORANGEFS_VFS_OP_READDIR) &&  in orangefs_devreq_write_iter()
459 	    (op->downcall.trailer_size == 0)) {  in orangefs_devreq_write_iter()
462 			   op->downcall.type);  in orangefs_devreq_write_iter()
466 	if (op->downcall.type != ORANGEFS_VFS_OP_READDIR)  in orangefs_devreq_write_iter()
469 	op->downcall.trailer_buf = vzalloc(op->downcall.trailer_size);  in orangefs_devreq_write_iter()
470 	if (!op->downcall.trailer_buf)  in orangefs_devreq_write_iter()
473 	if (!copy_from_iter_full(op->downcall.trailer_buf,  in orangefs_devreq_write_iter()
474 			         op->downcall.trailer_size, iter)) {  in orangefs_devreq_write_iter()
476 		vfree(op->downcall.trailer_buf);  in orangefs_devreq_write_iter()
485 	spin_lock(&op->lock);  in orangefs_devreq_write_iter()
486 	if (unlikely(op_is_cancel(op))) {  in orangefs_devreq_write_iter()
487 		spin_unlock(&op->lock);  in orangefs_devreq_write_iter()
488 		put_cancel(op);  in orangefs_devreq_write_iter()
489 	} else if (unlikely(op_state_given_up(op))) {  in orangefs_devreq_write_iter()
490 		spin_unlock(&op->lock);  in orangefs_devreq_write_iter()
491 		complete(&op->waitq);  in orangefs_devreq_write_iter()
493 		set_op_state_serviced(op);  in orangefs_devreq_write_iter()
497 			     get_opname_string(op),  in orangefs_devreq_write_iter()
498 			     op->op_state,  in orangefs_devreq_write_iter()
500 		spin_unlock(&op->lock);  in orangefs_devreq_write_iter()
505 	op->downcall.status = -(ORANGEFS_ERROR_BIT | 9);  in orangefs_devreq_write_iter()
510 	op->downcall.status = -(ORANGEFS_ERROR_BIT | 8);  in orangefs_devreq_write_iter()