diff options
-rw-r--r-- | block/ll_rw_blk.c | 70 |
1 files changed, 37 insertions, 33 deletions
diff --git a/block/ll_rw_blk.c b/block/ll_rw_blk.c index d4beb9a89ee0..97f4e7ecedfe 100644 --- a/block/ll_rw_blk.c +++ b/block/ll_rw_blk.c | |||
@@ -1908,40 +1908,40 @@ static struct request *get_request(request_queue_t *q, int rw, struct bio *bio, | |||
1908 | { | 1908 | { |
1909 | struct request *rq = NULL; | 1909 | struct request *rq = NULL; |
1910 | struct request_list *rl = &q->rq; | 1910 | struct request_list *rl = &q->rq; |
1911 | struct io_context *ioc = current_io_context(GFP_ATOMIC); | 1911 | struct io_context *ioc = NULL; |
1912 | int priv; | 1912 | int may_queue, priv; |
1913 | 1913 | ||
1914 | if (rl->count[rw]+1 >= q->nr_requests) { | 1914 | may_queue = elv_may_queue(q, rw, bio); |
1915 | /* | 1915 | if (may_queue == ELV_MQUEUE_NO) |
1916 | * The queue will fill after this allocation, so set it as | 1916 | goto rq_starved; |
1917 | * full, and mark this process as "batching". This process | ||
1918 | * will be allowed to complete a batch of requests, others | ||
1919 | * will be blocked. | ||
1920 | */ | ||
1921 | if (!blk_queue_full(q, rw)) { | ||
1922 | ioc_set_batching(q, ioc); | ||
1923 | blk_set_queue_full(q, rw); | ||
1924 | } | ||
1925 | } | ||
1926 | 1917 | ||
1927 | switch (elv_may_queue(q, rw, bio)) { | 1918 | if (rl->count[rw]+1 >= queue_congestion_on_threshold(q)) { |
1928 | case ELV_MQUEUE_NO: | 1919 | if (rl->count[rw]+1 >= q->nr_requests) { |
1929 | goto rq_starved; | 1920 | ioc = current_io_context(GFP_ATOMIC); |
1930 | case ELV_MQUEUE_MAY: | 1921 | /* |
1931 | break; | 1922 | * The queue will fill after this allocation, so set |
1932 | case ELV_MQUEUE_MUST: | 1923 | * it as full, and mark this process as "batching". |
1933 | goto get_rq; | 1924 | * This process will be allowed to complete a batch of |
1934 | } | 1925 | * requests, others will be blocked. |
1935 | 1926 | */ | |
1936 | if (blk_queue_full(q, rw) && !ioc_batching(q, ioc)) { | 1927 | if (!blk_queue_full(q, rw)) { |
1937 | /* | 1928 | ioc_set_batching(q, ioc); |
1938 | * The queue is full and the allocating process is not a | 1929 | blk_set_queue_full(q, rw); |
1939 | * "batcher", and not exempted by the IO scheduler | 1930 | } else { |
1940 | */ | 1931 | if (may_queue != ELV_MQUEUE_MUST |
1941 | goto out; | 1932 | && !ioc_batching(q, ioc)) { |
1933 | /* | ||
1934 | * The queue is full and the allocating | ||
1935 | * process is not a "batcher", and not | ||
1936 | * exempted by the IO scheduler | ||
1937 | */ | ||
1938 | goto out; | ||
1939 | } | ||
1940 | } | ||
1941 | } | ||
1942 | set_queue_congested(q, rw); | ||
1942 | } | 1943 | } |
1943 | 1944 | ||
1944 | get_rq: | ||
1945 | /* | 1945 | /* |
1946 | * Only allow batching queuers to allocate up to 50% over the defined | 1946 | * Only allow batching queuers to allocate up to 50% over the defined |
1947 | * limit of requests, otherwise we could have thousands of requests | 1947 | * limit of requests, otherwise we could have thousands of requests |
@@ -1952,8 +1952,6 @@ get_rq: | |||
1952 | 1952 | ||
1953 | rl->count[rw]++; | 1953 | rl->count[rw]++; |
1954 | rl->starved[rw] = 0; | 1954 | rl->starved[rw] = 0; |
1955 | if (rl->count[rw] >= queue_congestion_on_threshold(q)) | ||
1956 | set_queue_congested(q, rw); | ||
1957 | 1955 | ||
1958 | priv = !test_bit(QUEUE_FLAG_ELVSWITCH, &q->queue_flags); | 1956 | priv = !test_bit(QUEUE_FLAG_ELVSWITCH, &q->queue_flags); |
1959 | if (priv) | 1957 | if (priv) |
@@ -1962,7 +1960,7 @@ get_rq: | |||
1962 | spin_unlock_irq(q->queue_lock); | 1960 | spin_unlock_irq(q->queue_lock); |
1963 | 1961 | ||
1964 | rq = blk_alloc_request(q, rw, bio, priv, gfp_mask); | 1962 | rq = blk_alloc_request(q, rw, bio, priv, gfp_mask); |
1965 | if (!rq) { | 1963 | if (unlikely(!rq)) { |
1966 | /* | 1964 | /* |
1967 | * Allocation failed presumably due to memory. Undo anything | 1965 | * Allocation failed presumably due to memory. Undo anything |
1968 | * we might have messed up. | 1966 | * we might have messed up. |
@@ -1987,6 +1985,12 @@ rq_starved: | |||
1987 | goto out; | 1985 | goto out; |
1988 | } | 1986 | } |
1989 | 1987 | ||
1988 | /* | ||
1989 | * ioc may be NULL here, and ioc_batching will be false. That's | ||
1990 | * OK, if the queue is under the request limit then requests need | ||
1991 | * not count toward the nr_batch_requests limit. There will always | ||
1992 | * be some limit enforced by BLK_BATCH_TIME. | ||
1993 | */ | ||
1990 | if (ioc_batching(q, ioc)) | 1994 | if (ioc_batching(q, ioc)) |
1991 | ioc->nr_batch_requests--; | 1995 | ioc->nr_batch_requests--; |
1992 | 1996 | ||