Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1234199
  • 博文数量: 122
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 4004
  • 用 户 组: 普通用户
  • 注册时间: 2014-02-20 08:27
文章分类
文章存档

2016年(1)

2015年(21)

2014年(100)

分类: LINUX

2015-01-23 17:14:02

一、基本原理
Linux块设备层使用了plug/unplug(蓄流/泄流)的机制来提升IO吞吐量。基本原理为:当IO请求提交时,不知直接提交给底层驱动,而是先将其放入一个队列中(相当于水池),待一定时机或周期后再将该队列中的请求统一下发。将请求放入队列的过程即plug(蓄流)过程,统一下发请求的过程即为unplug(泄流)过程。每个请求在队列中等待的时间不会太长,通常在ms级别。
如此设计,可以增加IO合并和排序的机会,便于提升磁盘访问效率。

二、plug
1、基本流程
从mapping层提交到块设备层的io请求为bio,bio会在块设备进行合并,并生成新的request,并经过IO调度(排序和合并)之后下发到底层。下发request时,通过请求队列的make_request_fn接口,其中实质为将请求放入per task的plug队列,当队列满或在进行调度时(schedule函数中)会根据当前进程的状态将该队列中的请求flush到派发队列中,并触发unplug(具体流程后面介绍)。

per task的plug队列:新内核版本中实现的机制。IO请求提交时先链入此队列,当该队列满时(>BLK_MAX_REQUEST_COUNT),会flush到相应设备的请求队列中(request_queue)。
优点:per task维护plug队列,可以避免频繁对设备的请求队列操作导致的锁竞争,能提升效率。

2、plug基本代码流程如下:
submit_bio->
    generic_make_request->
        make_request->
            blk_queue_bio->
                list_add_tail(&req->queuelist, &plug->list);//将请求加入plug队列


三、unplug
unplug分同步unplug和异步unplug两种方式。
同步unplug即当即通过调用blk_run_queue对下发请求队列中的情况。
异步unplug,通过唤醒kblockd工作队列来对请求队列中的请求进行下发。

1、kblockd工作队列的初始化:
1) 分配工作队列
主要代码流程:

blk_dev_init ->
    alloc_workqueue //分配工作队列

2) 初始化工作队列
blk_alloc_queue_node():

点击(此处)折叠或打开

  1. /*在指定node上分配请求队列*/
  2. struct request_queue *blk_alloc_queue_node(gfp_t gfp_mask, int node_id)
  3. {
  4. struct request_queue *q;
  5. int err;
  6. /*分配请求队列需要的内存,从slab中分配,并初始化为0*/
  7. q = kmem_cache_alloc_node(blk_requestq_cachep,
  8. gfp_mask | __GFP_ZERO, node_id);
  9. if (!q)
  10. return NULL;


  11. if (percpu_counter_init(&q->mq_usage_counter, 0))
  12. goto fail_q;


  13. q->id = ida_simple_get(&blk_queue_ida, 0, 0, gfp_mask);
  14. if (q->id < 0)
  15. goto fail_c;


  16. q->backing_dev_info.ra_pages =
  17. (VM_MAX_READAHEAD * 1024) / PAGE_CACHE_SIZE;
  18. q->backing_dev_info.state = 0;
  19. q->backing_dev_info.capabilities = BDI_CAP_MAP_COPY;
  20. q->backing_dev_info.name = "block";
  21. q->node = node_id;


  22. err = bdi_init(&q->backing_dev_info);
  23. if (err)
  24. goto fail_id;
  25. /*设置laptop模式下的定时器*/
  26. setup_timer(&q->backing_dev_info.laptop_mode_wb_timer,
  27.    laptop_mode_timer_fn, (unsigned long) q);
  28. /*
  29.  * 关键点:设置请求队列的超时定时器,默认超时时间为30s,当30s内IO请求未完成时,定时器到期,
  30.  * 进行重试或错误处理。这是IO 错误处理架构中的关键点之一,在内核老版本中(2.6.38?),该定时器
  31.  * 是在scsi中间层定义的,新版本中将其上移至块设备层。Fixme:为何要这样?*/
  32. setup_timer(&q->timeout, blk_rq_timed_out_timer, (unsigned long) q);
  33. /*初始化各个队列*/
  34. INIT_LIST_HEAD(&q->queue_head);
  35. INIT_LIST_HEAD(&q->timeout_list);
  36. INIT_LIST_HEAD(&q->icq_list);
  37. #ifdef CONFIG_BLK_CGROUP
  38. INIT_LIST_HEAD(&q->blkg_list);
  39. #endif
  40. INIT_LIST_HEAD(&q->flush_queue[0]);
  41. INIT_LIST_HEAD(&q->flush_queue[1]);
  42. INIT_LIST_HEAD(&q->flush_data_in_flight);
  43. /*初始化delay_work,用于在kblockd中异步unplug请求队列*/
  44. INIT_DELAYED_WORK(&q->delay_work, blk_delay_work);


  45. kobject_init(&q->kobj, &blk_queue_ktype);


  46. mutex_init(&q->sysfs_lock);
  47. spin_lock_init(&q->__queue_lock);


  48. /*
  49. * By default initialize queue_lock to internal lock and driver can
  50. * override it later if need be.
  51. */
  52. q->queue_lock = &q->__queue_lock;


  53. /*
  54. * A queue starts its life with bypass turned on to avoid
  55. * unnecessary bypass on/off overhead and nasty surprises during
  56. * init. The initial bypass will be finished when the queue is
  57. * registered by blk_register_queue().
  58. */
  59. q->bypass_depth = 1;
  60. __set_bit(QUEUE_FLAG_BYPASS, &q->queue_flags);


  61. init_waitqueue_head(&q->mq_freeze_wq);


  62. if (blkcg_init_queue(q))
  63. goto fail_id;


  64. return q;


  65. fail_id:
  66. ida_simple_remove(&blk_queue_ida, q->id);
  67. fail_c:
  68. percpu_counter_destroy(&q->mq_usage_counter);
  69. fail_q:
  70. kmem_cache_free(blk_requestq_cachep, q);
  71. return NULL;
  72. }
2) kblockd工作队列的工作内容
kblockd工作队列的工作内容有由blk_delay_work()函数实现,主要就是调__blk_run_queue进行unplug请求队列。

点击(此处)折叠或打开

  1. /*IO请求队列的delay_work,用于在kblockd中异步unplug请求队列*/
  2. static void blk_delay_work(struct work_struct *work)
  3. {
  4. struct request_queue *q;
  5. /*获取delay_work所在的请求队列*/
  6. q = container_of(work, struct request_queue, delay_work.work);
  7. spin_lock_irq(q->queue_lock);
  8. /*直接run queue,最终调用request_fn对队列中的请求逐一处理*/
  9. __blk_run_queue(q);
  10. spin_unlock_irq(q->queue_lock);
  11. }

2、unplug机制
内核中设计了两种unplug机制:
1)调度时进行unplug(异步方式)
当发生内核调度时,当前进程sleep前,先将当前task的plug列表中的请求flush到派发队列中,并进行unplug。
主要代码流程如下:
schedule->
    sched_submit_work ->
        blk_schedule_flush_plug()->

            blk_flush_plug_list(plug, true) ->注意:这里传入的from_schedule参数为true,表示将触发异步unplug,即唤醒kblockd工作队列来进行unplug操作。后续的kblockd的唤醒周期在块设备驱动中设置,比如scsi中设置为3ms。
                queue_unplugged->
                    blk_run_queue_async

queue_unplugged():

点击(此处)折叠或打开

  1. /*unplug请求队列,plug相当于蓄水,将请求放入池子(请求队列)中,unplug相当于放水,即开始调用请求队列的request_fn(scsi_request_fn)来处理请求队列中的请求,将请求提交到scsi层(块设备驱动层)*/
  2. static void queue_unplugged(struct request_queue *q, unsigned int depth,
  3.    bool from_schedule)
  4. __releases(q->queue_lock)
  5. {
  6. trace_block_unplug(q, depth, !from_schedule);
  7. /*调用块设备驱动层提供的request_fn接口处理请求队列中的请求,分异步和同步两种情况。*/
  8. if (from_schedule)
  9. /*异步unplug,即通过kblockd工作队列来处理,该工作队列定期唤醒(5s),通过这种方式可以控制流量,提高吞吐量*/
  10. blk_run_queue_async(q);
  11. else
  12. /*同步unplug,即直接调用设备驱动层提供的request_fn接口处理请求队列中的请求*/
  13. __blk_run_queue(q);
  14. spin_unlock(q->queue_lock);
  15. }

blk_run_queue_async():

点击(此处)折叠或打开

  1. /*异步unplug,即通过kblockd工作队列来处理,该工作队列定期唤醒(5s),通过这种方式可以控制流量,提高吞吐量*/
  2. void blk_run_queue_async(struct request_queue *q)
  3. {
  4. if (likely(!blk_queue_stopped(q) && !blk_queue_dead(q)))
  5. /*唤醒kblockd相关的工作队列,进行unplug处理,注意:这里的delay传入0表示立刻唤醒,kblockd对应的处理接口为:blk_delay_work*/
  6. mod_delayed_work(kblockd_workqueue, &q->delay_work, 0);
  7. }

scsi_request_fn()://scsi块设备驱动的request_fn()接口,其中当scsi命令下发失败时,会重设kblockd,延迟unplug请求队列。

点击(此处)折叠或打开

  1. static void scsi_request_fn(struct request_queue *q)
  2. {
  3. ...
  4. /*
  5. * Dispatch the command to the low-level driver.
  6. */
  7. /*将scsi命令下发到底层驱动,当返回非0时,表示命令下发失败,则当前的请求队列需要被plug*/
  8. rtn = scsi_dispatch_cmd(cmd);
  9. spin_lock_irq(q->queue_lock);
  10. /*命令下发失败,需要plug请求队列*/
  11. if (rtn)
  12. goto out_delay
  13. ...
  14. out_delay:
  15. if (sdev->device_busy == 0)
  16. /*命令下发失败,需要延迟处理,需plug请求队列,设置3ms定时启动kblockd工作队列,进行请求队列的unplug*/
  17. blk_delay_queue(q, SCSI_QUEUE_DELAY);
  18. blk_delay_queue
  19. /*在指定msecs时间后启动kblockd工作队列*/
  20. void blk_delay_queue(struct request_queue *q, unsigned long msecs)
  21. {
  22. if (likely(!blk_queue_dead(q)))
  23. queue_delayed_work(kblockd_workqueue, &q->delay_work,
  24.   msecs_to_jiffies(msecs));
  25. }

2)提交IO请求时(make_request)进行unplug
提交IO请求时(make_request),先将请求提交时先链入此队列,当该队列满时(>BLK_MAX_REQUEST_COUNT),会flush到相应设备的请求队列中(request_queue)。
主要代码流程为:
submit_bio->
    generic_make_request->
        make_request->
            blk_queue_bio->
                blk_flush_plug_list(plug, false) ->注意:这里传入的from_schedule参数为false,表示将触发同步unplug,即当即下发请求。
                    queue_unplugged->
                        blk_run_queue_async ->

                            __blk_run_queue

普通块设备的make_request接口在3.10内核版本中被设置为blk_queue_bio,相应代码分析如下:

点击(此处)折叠或打开

  1. /*在submit_bio中被调用,用于合并bio,并提交请求(request),请求提交到per task的plug list中*/
  2. void blk_queue_bio(struct request_queue *q, struct bio *bio)
  3. {
  4.     const bool sync = !!(bio->bi_rw & REQ_SYNC);
  5.     struct blk_plug *plug;
  6.     int el_ret, rw_flags, where = ELEVATOR_INSERT_SORT;
  7.     struct request *req;
  8.     unsigned int request_count = 0;

  9.     /*
  10.      * low level driver can indicate that it wants pages above a
  11.      * certain limit bounced to low memory (ie for highmem, or even
  12.      * ISA dma in theory)
  13.      */
  14.     /*bounce buffer(回弹缓冲区)使用*/
  15.     blk_queue_bounce(q, &bio);

  16.     if (bio_integrity_enabled(bio) && bio_integrity_prep(bio)) {
  17.         bio_endio(bio, -EIO);
  18.         return;
  19.     }

  20.     if (bio->bi_rw & (REQ_FLUSH | REQ_FUA)) {
  21.         spin_lock_irq(q->queue_lock);
  22.         where = ELEVATOR_INSERT_FLUSH;
  23.         goto get_rq;
  24.     }

  25.     /*
  26.      * Check if we can merge with the plugged list before grabbing
  27.      * any locks.
  28.      */
  29.     /*尝试将bio合并到request中*/
  30.     if (blk_attempt_plug_merge(q, bio, &request_count))
  31.         return;

  32.     spin_lock_irq(q->queue_lock);

  33.     el_ret = elv_merge(q, &req, bio);
  34.     /*向后合并*/
  35.     if (el_ret == ELEVATOR_BACK_MERGE) {
  36.         if (bio_attempt_back_merge(q, req, bio)) {
  37.             elv_bio_merged(q, req, bio);
  38.             if (!attempt_back_merge(q, req))
  39.                 elv_merged_request(q, req, el_ret);
  40.             goto out_unlock;
  41.         }
  42.     /*向前合并*/
  43.     } else if (el_ret == ELEVATOR_FRONT_MERGE) {
  44.         if (bio_attempt_front_merge(q, req, bio)) {
  45.             elv_bio_merged(q, req, bio);
  46.             if (!attempt_front_merge(q, req))
  47.                 elv_merged_request(q, req, el_ret);
  48.             goto out_unlock;
  49.         }
  50.     }
  51. /*不能合并,需要新建request来处理bio*/
  52. get_rq:
  53.     /*
  54.      * This sync check and mask will be re-done in init_request_from_bio(),
  55.      * but we need to set it earlier to expose the sync flag to the
  56.      * rq allocator and io schedulers.
  57.      */
  58.     rw_flags = bio_data_dir(bio);
  59.     /*判断是否需要sync,即直接将IO请求unplug(提交到块设备驱动层),不用等待kblockd来定期plug*/
  60.     if (sync)
  61.         rw_flags |= REQ_SYNC;

  62.     /*
  63.      * Grab a free request. This is might sleep but can not fail.
  64.      * Returns with the queue unlocked.
  65.      */
  66.     /*从请求队列中取一个request*/
  67.     req = get_request(q, rw_flags, bio, GFP_NOIO);
  68.     if (unlikely(!req)) {
  69.         bio_endio(bio, -ENODEV);    /* @q is dead */
  70.         goto out_unlock;
  71.     }

  72.     /*
  73.      * After dropping the lock and possibly sleeping here, our request
  74.      * may now be mergeable after it had proven unmergeable (above).
  75.      * We don't worry about that case for efficiency. It won't happen
  76.      * often, and the elevators are able to handle it.
  77.      */
  78.     /*将bio加入新的request中*/
  79.     init_request_from_bio(req, bio);

  80.     if (test_bit(QUEUE_FLAG_SAME_COMP, &q->queue_flags))
  81.         req->cpu = raw_smp_processor_id();

  82.     plug = current->plug;
  83.     /*如果有plug,则将请求加入到plug的list中,如果没有则直接调用__blk_run_queue提交请求*/
  84.     if (plug) {
  85.         /*
  86.          * If this is the first request added after a plug, fire
  87.          * of a plug trace. If others have been added before, check
  88.          * if we have multiple devices in this plug. If so, make a
  89.          * note to sort the list before dispatch.
  90.          */
  91.         if (list_empty(&plug->list))
  92.             trace_block_plug(q);
  93.         else {/*如果请求队列中的请求数超过了限值,则先unplug?*/
  94.             if (request_count >= BLK_MAX_REQUEST_COUNT) {
  95.                 blk_flush_plug_list(plug, false);
  96.                 trace_block_plug(q);
  97.             }
  98.         }
  99.         /*把请求加入到plug的list中,当plug的list满了后(>BLK_MAX_REQUEST_COUNT),会flush到相应设备的请求队列中(request_queue)*/
  100.         list_add_tail(&req->queuelist, &plug->list);
  101.         blk_account_io_start(req, true);
  102.     } else {
  103.         spin_lock_irq(q->queue_lock);
  104.         add_acct_request(q, req, where);
  105.         /*如果没有plug控制,最终调用此接口处理队列中的请求,最终会调用请求队列的request_fn接口处理请求*/
  106.         __blk_run_queue(q);
  107. out_unlock:
  108.         spin_unlock_irq(q->queue_lock);
  109.     }
  110. }

阅读(7812) | 评论(6) | 转发(2) |
给主人留下些什么吧!~~

humjb_19832015-01-30 09:22:13

镇水铁牛:上面说法有误,新旧内核都是有:
q->nr_requests = BLKDEV_MAX_RQ; 
blk_queue_congestion_threshold(q);
不过好像新内核多了个BLK_MAX_REQUEST_COUNT ,都是做流控的。

是的,你说的是request queue的长度,这个通常会在底层驱动中设置。
我前面说的BLK_MAX_REQUEST_COUNT是per CPU的plug list的长度,确实是做流控的。

回复 | 举报

镇水铁牛2015-01-29 23:23:35

镇水铁牛:旧内核是:
q->unplug_thresh = 4;  /* hmm */
q->unplug_delay = (3 * HZ) / 1000; /* 3 milliseconds */
新内核是:
q->nr_requests = BLKDEV_MAX_RQ; //这个值其实是需要修改的,SATA和SAS对这个值需求就不同。
blk_queue_congestion_threshold(q);//这里会做阈值缓冲

上面说法有误,新旧内核都是有:
q->nr_requests = BLKDEV_MAX_RQ; 
blk_queue_congestion_threshold(q);
不过好像新内核多了个BLK_MAX_REQUEST_COUNT ,都是做流控的。

回复 | 举报

镇水铁牛2015-01-29 23:17:11

humjb_1983:#define BLK_MAX_REQUEST_COUNT 16
plug list的长度限制为16

旧内核是:
q->unplug_thresh = 4;  /* hmm */
q->unplug_delay = (3 * HZ) / 1000; /* 3 milliseconds */
新内核是:
q->nr_requests = BLKDEV_MAX_RQ; //这个值其实是需要修改的,SATA和SAS对这个值需求就不同。
blk_queue_congestion_threshold(q);//这里会做阈值缓冲

回复 | 举报

humjb_19832015-01-29 17:20:42

镇水铁牛:request_queue定时器在2.6.27内核中,就是在blk-core.c中定义的,记得plug/unplug不仅仅有3ms限制,还有个4个request限制。

#define BLK_MAX_REQUEST_COUNT 16
plug list的长度限制为16

回复 | 举报

humjb_19832015-01-26 08:39:16

镇水铁牛:request_queue定时器在2.6.27内核中,就是在blk-core.c中定义的,记得plug/unplug不仅仅有3ms限制,还有个4个request限制。

呵呵,我们以前用的2.6.18的内核中,定时器是在scsi中间层定义,并进行错误处理的~~,现在上移了。
plug list是有长度限制的,具体我再确认下。

回复 | 举报