Blame view

block/blk-exec.c 2.56 KB
3dcf60bcb   Christoph Hellwig   block: add SPDX t...
1
  // SPDX-License-Identifier: GPL-2.0
86db1e297   Jens Axboe   block: continue l...
2
3
4
5
6
7
8
  /*
   * Functions related to setting various queue properties from drivers
   */
  #include <linux/kernel.h>
  #include <linux/module.h>
  #include <linux/bio.h>
  #include <linux/blkdev.h>
320ae51fe   Jens Axboe   blk-mq: new multi...
9
  #include <linux/blk-mq.h>
cf4aebc29   Clark Williams   sched: Move sched...
10
  #include <linux/sched/sysctl.h>
86db1e297   Jens Axboe   block: continue l...
11
12
  
  #include "blk.h"
bd166ef18   Jens Axboe   blk-mq-sched: add...
13
  #include "blk-mq-sched.h"
86db1e297   Jens Axboe   block: continue l...
14

86db1e297   Jens Axboe   block: continue l...
15
16
17
  /**
   * blk_end_sync_rq - executes a completion event on a request
   * @rq: request to complete
710027a48   Randy Dunlap   Add some block/ s...
18
   * @error: end I/O status of the request
86db1e297   Jens Axboe   block: continue l...
19
   */
2a842acab   Christoph Hellwig   block: introduce ...
20
  static void blk_end_sync_rq(struct request *rq, blk_status_t error)
86db1e297   Jens Axboe   block: continue l...
21
22
23
24
  {
  	struct completion *waiting = rq->end_io_data;
  
  	rq->end_io_data = NULL;
86db1e297   Jens Axboe   block: continue l...
25
26
27
28
29
30
31
  
  	/*
  	 * complete last, if this is a stack request the process (and thus
  	 * the rq pointer) could be invalid right after this complete()
  	 */
  	complete(waiting);
  }
86db1e297   Jens Axboe   block: continue l...
32
33
34
35
36
37
38
39
40
41
  
  /**
   * blk_execute_rq_nowait - insert a request into queue for execution
   * @q:		queue to insert the request in
   * @bd_disk:	matching gendisk
   * @rq:		request to insert
   * @at_head:    insert request at head or tail of queue
   * @done:	I/O completion handler
   *
   * Description:
710027a48   Randy Dunlap   Add some block/ s...
42
   *    Insert a fully prepared request at the back of the I/O scheduler queue
86db1e297   Jens Axboe   block: continue l...
43
   *    for execution.  Don't wait for completion.
e81ca6fe8   Muthukumar Ratty   [SCSI] block: Fix...
44
45
46
   *
   * Note:
   *    This function will invoke @done directly if the queue is dead.
86db1e297   Jens Axboe   block: continue l...
47
48
49
50
51
   */
  void blk_execute_rq_nowait(struct request_queue *q, struct gendisk *bd_disk,
  			   struct request *rq, int at_head,
  			   rq_end_io_fn *done)
  {
8ba61435d   Tejun Heo   block: add missin...
52
  	WARN_ON(irqs_disabled());
57292b58d   Christoph Hellwig   block: introduce ...
53
  	WARN_ON(!blk_rq_is_passthrough(rq));
e81ca6fe8   Muthukumar Ratty   [SCSI] block: Fix...
54
55
56
  
  	rq->rq_disk = bd_disk;
  	rq->end_io = done;
320ae51fe   Jens Axboe   blk-mq: new multi...
57

43a5e4e21   Ming Lei   block: blk-mq: su...
58
59
  	/*
  	 * don't check dying flag for MQ because the request won't
68bdf1ac2   Bart Van Assche   block: Fix spelli...
60
  	 * be reused after dying flag is set
43a5e4e21   Ming Lei   block: blk-mq: su...
61
  	 */
a1ce35fa4   Jens Axboe   block: remove dea...
62
  	blk_mq_sched_insert_request(rq, at_head, true, false);
86db1e297   Jens Axboe   block: continue l...
63
64
65
66
67
68
69
70
71
72
73
  }
  EXPORT_SYMBOL_GPL(blk_execute_rq_nowait);
  
  /**
   * blk_execute_rq - insert a request into queue for execution
   * @q:		queue to insert the request in
   * @bd_disk:	matching gendisk
   * @rq:		request to insert
   * @at_head:    insert request at head or tail of queue
   *
   * Description:
710027a48   Randy Dunlap   Add some block/ s...
74
   *    Insert a fully prepared request at the back of the I/O scheduler queue
86db1e297   Jens Axboe   block: continue l...
75
76
   *    for execution and wait for completion.
   */
b7819b925   Christoph Hellwig   block: remove the...
77
  void blk_execute_rq(struct request_queue *q, struct gendisk *bd_disk,
86db1e297   Jens Axboe   block: continue l...
78
79
80
  		   struct request *rq, int at_head)
  {
  	DECLARE_COMPLETION_ONSTACK(wait);
4b1977698   Mark Lord   block: Prevent ha...
81
  	unsigned long hang_check;
86db1e297   Jens Axboe   block: continue l...
82

86db1e297   Jens Axboe   block: continue l...
83
84
  	rq->end_io_data = &wait;
  	blk_execute_rq_nowait(q, bd_disk, rq, at_head, blk_end_sync_rq);
4b1977698   Mark Lord   block: Prevent ha...
85
86
87
88
  
  	/* Prevent hang_check timer from firing at us during very long I/O */
  	hang_check = sysctl_hung_task_timeout_secs;
  	if (hang_check)
5577022f4   Vladimir Davydov   block: account io...
89
  		while (!wait_for_completion_io_timeout(&wait, hang_check * (HZ/2)));
4b1977698   Mark Lord   block: Prevent ha...
90
  	else
5577022f4   Vladimir Davydov   block: account io...
91
  		wait_for_completion_io(&wait);
86db1e297   Jens Axboe   block: continue l...
92
  }
86db1e297   Jens Axboe   block: continue l...
93
  EXPORT_SYMBOL(blk_execute_rq);