btt/trace_requeue.c

   1 /*
   2  * blktrace output analysis: generate a timeline & gather statistics
   3  *
   4  * Copyright (C) 2006 Alan D. Brunelle <Alan.Brunelle@hp.com>
   5  *
   6  *  This program is free software; you can redistribute it and/or modify
   7  *  it under the terms of the GNU General Public License as published by
   8  *  the Free Software Foundation; either version 2 of the License, or
   9  *  (at your option) any later version.
  10  *
  11  *  This program is distributed in the hope that it will be useful,
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *  GNU General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU General Public License
  17  *  along with this program; if not, write to the Free Software
  18  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  *
  20  */
  21 #include "globals.h"
  22
  23 void trace_requeue(struct io *r_iop)
  24 {
  25         if (!io_setup(r_iop, IOP_R)) {
  26                 io_release(r_iop);
  27                 return;
  28         }
  29
  30         if (ready_requeue(r_iop, r_iop))
  31                 run_requeue(r_iop);
  32         else
  33                 add_retry(r_iop);
  34 }
  35
  36 int retry_requeue(struct io *r_iop)
  37 {
  38         if (!ready_requeue(r_iop, r_iop))
  39                 return 0;
  40
  41         run_requeue(r_iop);
  42         return 1;
  43 }
  44
  45 int ready_requeue(struct io *r_iop, struct io *top)
  46 {
  47         struct io *d_iop = dip_find_sec(r_iop->dip, IOP_D, BIT_START(r_iop));
  48         if (d_iop)
  49                 return ready_issue(d_iop, top);
  50         return 0;
  51 }
  52
  53 void run_requeue(struct io *r_iop)
  54 {
  55         LIST_HEAD(del_head);
  56         struct io *d_iop = dip_find_sec(r_iop->dip, IOP_D, BIT_START(r_iop));
  57
  58         __link(d_iop, r_iop);
  59         run_unissue(d_iop, &del_head);
  60         __unlink(d_iop, r_iop);
  61
  62         del_retry(r_iop);
  63         list_add_tail(&r_iop->f_head, &del_head);
  64         release_iops(&del_head);
  65 }